标签：structured-streaming

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

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

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

Trigger — How Frequently to Check Sources For New Data

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

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

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

DataStreamWriter — Writing Datasets To Streaming Data Sinks

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

DataStreamReader — Loading Data from Streaming Data Source

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

MicroBatchReader Contract — DataSourceReaders For Micro-Batch Stream Processing

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

MicroBatchReadSupport Contract — Data Sources with MicroBatchReaders

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

MicroBatchExecution — StreamExecution in Micro-Batch Stream Processing

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

Micro-Batch Stream Processing (Structured Streaming V1)

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

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