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