insertStream method

Future<void> insertStream({
  1. required String database,
  2. required String table,
  3. required SqliteArrowBatches chunks,
  4. List<String>? namespace,
})

Implementation

Future<void> insertStream({
  required String database,
  required String table,
  required SqliteArrowBatches chunks,
  List<String>? namespace,
}) async {
  final input = _SqliteArrowWriteInputStream(
    start: {"kind": "start", "database": database, "table": table, "namespace": namespace},
    chunks: chunks,
  );
  await _drainArrowWriteStream("insert", input);
}