databricks-zerobus-ingest-sdk 2.4.0

A high-performance Rust client for streaming data ingestion into Databricks Delta tables using the Zerobus service
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

//! Ingestion streams, organized per transport.
//!
//! [`grpc`] holds proto / JSON streaming over a bidirectional gRPC stream.
//! Arrow Flight (Beta) still lives in the top-level `arrow_stream` module.
//!
//! TODO: move Arrow Flight under here and lift the transport-agnostic parts
//! of `grpc/` (callbacks, `flush` / `wait_for_offset` / `close`, `ingest_*`)
//! into a shared core.

mod grpc;

pub use grpc::ZerobusStream;

#[cfg(feature = "testing")]
pub use grpc::CallbackHandlerHarness;