createTableWithSchema method

Future<void> createTableWithSchema({
  1. required String database,
  2. required String name,
  3. required ArrowSchema schema,
  4. SqliteArrowBatches? batches,
  5. SqliteCreateMode mode = SqliteCreateMode.create,
  6. List<String>? namespace,
})

Implementation

Future<void> createTableWithSchema({
  required String database,
  required String name,
  required ArrowSchema schema,
  SqliteArrowBatches? batches,
  SqliteCreateMode mode = SqliteCreateMode.create,
  List<String>? namespace,
}) async {
  final input = _SqliteArrowWriteInputStream(
    start: {"kind": "start", "database": database, "name": name, "mode": mode.value, "namespace": namespace},
    chunks: batches ?? const Stream<ArrowRecordBatch>.empty(),
    schema: schema,
  );
  await _drainArrowWriteStream("create_table", input);
}