bulk_ingest

micromegas::analytics::replication

Function bulk_ingest 

Source 
pub async fn bulk_ingest(
    lake: Arc<DataLakeConnection>,
    table_name: &str,
    rb_stream: FlightRecordBatchStream,
) -> Result<i64, Error>
Expand description

Ingests data from a FlightRecordBatchStream into the specified table.