streamQueryColumnar method

@override Stream<Result<TypedColumnarResult>> streamQueryColumnar(String connectionId, String sql, { int fetchSize = 1000, int? chunkSize, })

Batched streaming with columnar v2 wire when supported (odbc_stream_start_batched_options). See IQueryService.streamQueryColumnar for semantics and fallbacks.

Implementation

@override
Stream<Result<TypedColumnarResult>> streamQueryColumnar(
  String connectionId,
  String sql, {
  int fetchSize = 1000,
  int? chunkSize,
}) =>
    _query.streamQueryColumnar(
      connectionId,
      sql,
      fetchSize: fetchSize,
      chunkSize: chunkSize,
    );