ingest_hudi_funcs
ingest_funcs
easy_sql
sql_config
read_hudi(table)
read_hudi
read_kafka(result_table)
read_kafka
write_hudi(cdc_table = '', partition = 2)
write_hudi
table (str) –
result_table (str) –
cdc_table (str) –
partition (int) –