Go to the source code of this file.
|
def | bench_batch_streaming_ingest.getOptions (args=None) |
|
def | bench_batch_streaming_ingest.create_table (omni_con, table_name, is_temporary=False, max_rollback_epochs=-1) |
|
def | bench_batch_streaming_ingest.gen_data (num_rows) |
|
def | bench_batch_streaming_ingest.bench_streaming_sql_inserts (omni_con, table_name, data) |
|
def | bench_batch_streaming_ingest.bench_bulk_columnar (omni_con, table_name, data) |
|
def | bench_batch_streaming_ingest.bench_bulk_arrow (omni_con, table_name, data) |
|
def | bench_batch_streaming_ingest.bench_streaming_columnar (omni_con, table_name, data) |
|
def | bench_batch_streaming_ingest.main (argv) |
|