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) –