createTableWithArrowSchema method

Future<void> createTableWithArrowSchema({
  1. required String name,
  2. required ArrowSchema schema,
  3. DatasetArrowBatches? batches,
  4. CreateMode mode = CreateMode.create,
  5. List<String>? namespace,
  6. String? branch,
  7. Map<String, dynamic>? metadata,
})

Implementation

Future<void> createTableWithArrowSchema({
  required String name,
  required ArrowSchema schema,
  DatasetArrowBatches? batches,
  CreateMode mode = CreateMode.create,
  List<String>? namespace,
  String? branch,
  Map<String, dynamic>? metadata,
}) async {
  final input = _DatasetArrowWriteInputStream(
    start: {
      "kind": "start",
      "name": name,
      "mode": mode.value,
      "namespace": namespace,
      "branch": branch,
      "metadata": _metadataEntries(metadata),
    },
    chunks: batches ?? const Stream<ArrowRecordBatch>.empty(),
    schema: schema,
  );
  await _drainArrowWriteStream("create_table", input);
}