greptimedb 0.0.1

Synchronous, completion-driven, thread-affine Rust SDK for GreptimeDB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
//! Synchronous Arrow Flight `DoGet` queries.
//!
//! [`QueryStream`] submits a `GreptimeRequest` inside a Flight ticket and decodes
//! the returned IPC stream into record batches and columnar rows.

pub mod decode;
pub mod stream;

pub use arrow_array::RecordBatch;
pub use arrow_schema::{DataType, Field, Schema, SchemaRef};
pub use decode::{
    decode_flight_record_batch, decode_flight_schema, decode_record_batch_to_columnar_batch,
};
pub use stream::QueryStream;