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