insertStream method

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

Implementation

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