Module streaming

Streaming implementation for the Spark Connect Client

Re-exports

pub use crate::spark::write_stream_operation_start::Trigger;

Structs

DataStreamReader

DataStreamReader represents the entrypoint to create a streaming DataFrame

DataStreamWriter

DataStreamWriter provides the ability to output a StreamingQuery which can then be used to monitor the active stream

StreamingQuery

Represents the active streaming created from a start on the writer

Enums

OutputMode

Streaming Output Modes