pub trait QueryStreamChunkWriter: Write {
// Required methods
fn emitted_chunk_count(&self) -> u64;
fn emitted_total_bytes(&self) -> u64;
}Expand description
Arrow IPC chunk 收集器。 Arrow IPC chunk collector.
Required Methods§
Sourcefn emitted_chunk_count(&self) -> u64
fn emitted_chunk_count(&self) -> u64
返回当前已经写出的 chunk 数量。 Return the number of chunks emitted so far.
Sourcefn emitted_total_bytes(&self) -> u64
fn emitted_total_bytes(&self) -> u64
返回当前已经写出的总字节数。 Return the total emitted byte size so far.