ingest_hudi_funcs

Module Contents

Functions

read_hudi(table)
read_kafka(result_table)
write_hudi(cdc_table = '', partition = 2)

ingest_hudi_funcs.read_hudi(table)

Parameters

table (str) –

ingest_hudi_funcs.read_kafka(result_table)

Parameters

result_table (str) –

ingest_hudi_funcs.write_hudi(cdc_table='', partition=2)

Parameters

• cdc_table (str) –

• partition (int) –