addColumnsWithSchema method

Future<void> addColumnsWithSchema({
  1. required String database,
  2. required String table,
  3. required ArrowSchema schema,
  4. List<String>? namespace,
})

Implementation

Future<void> addColumnsWithSchema({
  required String database,
  required String table,
  required ArrowSchema schema,
  List<String>? namespace,
}) async {
  final response = await _invokeContent(
    "add_columns",
    BinaryContent(
      data: ArrowIpcSchema.fromSchema(schema).bytes,
      headers: {"database": database, "table": table, "namespace": namespace, "content_type": _arrowIpcStreamMimeType},
    ),
  );
  if (response is! EmptyContent) {
    throw _unexpectedResponseError("add_columns");
  }
}