
Micro-Batch Stream Processing
Micro-Batch Stream Processing (Structured Streaming V1)

Micro-Batch Stream Processing (Structured Streaming V1)

EpochCoordinator EpochCoordinator is a ThreadSafeRpcEndpoint that receive messages from…FIXME Epoch ...

StreamWriter StreamWriter is…FIXME

RateStreamContinuousReader RateStreamContinuousReader is a ContinuousReader that…FIXME

ContinuousMemoryStream ContinuousMemoryStream is…FIXME

DataSourceReader Contract DataSourceReader is…FIXME

ContinuousReader Contract — DataSourceReaders For Continuous Stream Processing

ContinuousReadSupport Contract — Data Sources with ContinuousReaders

StreamWriteSupport Contract — DataSourceV2 Sinks with Custom StreamWriter

ContinuousExecutionRelation Leaf Logical Operator