sql method

Future<List<ArrowRecordBatch>> sql({
  1. required String query,
  2. List<TableRef>? tables,
  3. ArrowTable? params,
  4. List<String>? namespace,
  5. String? branch,
})

Implementation

Future<List<ArrowRecordBatch>> sql({
  required String query,
  List<TableRef>? tables,
  ArrowTable? params,
  List<String>? namespace,
  String? branch,
}) async {
  final rows = <ArrowRecordBatch>[];
  await for (final chunk in sqlStream(query: query, tables: tables, params: params, namespace: namespace, branch: branch)) {
    rows.add(chunk);
  }
  return rows;
}