标签：structured-streaming

2015-07-22admin阅读(1626)赞(0)

StreamingQuery StreamingQuery is the contract for a streaming query that is executed continuously and concurrently ...

2015-07-21admin阅读(1286)赞(0)

Trigger — How Frequently to Check Sources For New Data

2015-07-20admin阅读(2843)赞(0)

OutputMode Output mode (OutputMode) describes what data is written to a streaming sink when there is new data avai ...

2015-07-19admin阅读(2037)赞(0)

DataStreamWriter — Writing Datasets To Streaming Data Sinks

2015-07-18admin阅读(1329)赞(0)

DataStreamReader — Loading Data from Streaming Data Source

2015-07-17admin阅读(1977)赞(0)

MicroBatchReader Contract — DataSourceReaders For Micro-Batch Stream Processing

2015-07-16admin阅读(2437)赞(0)

MicroBatchReadSupport Contract — Data Sources with MicroBatchReaders

2015-07-15admin阅读(1380)赞(0)

MicroBatchExecution — StreamExecution in Micro-Batch Stream Processing

2015-07-14admin阅读(1529)赞(0)

Micro-Batch Stream Processing (Structured Streaming V1)

2015-07-13admin阅读(1137)赞(0)

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