structured-streaming 第10页

2015-09-02admin阅读(1774)赞(0)

StreamingQueryWrapper — Serializable StreamExecution

2015-09-01admin阅读(2738)赞(0)

StreamExecution — Base of Streaming Query Executions

2015-08-31admin阅读(3105)赞(0)

ForeachBatchSink ForeachBatchSink is a streaming sink that is used for the foreachBatch source. ForeachBatchSink ...

2015-08-30admin阅读(1706)赞(0)

ForeachSink ForeachSink is a typed streaming sink that passes rows (of the type T) to ForeachWriter (one record at ...

2015-08-29admin阅读(4667)赞(0)

ForeachWriter ForeachWriter is the contract for a foreach writer that is a streaming format that controls streamin ...

2015-08-28admin阅读(1536)赞(0)

ForeachWriterProvider ForeachWriterProvider is…​FIXME

2015-08-27admin阅读(1604)赞(0)

ConsoleSink for Showing DataFrames to Console

2015-08-26admin阅读(1640)赞(0)

ConsoleSinkProvider ConsoleSinkProvider is a DataSourceV2 with StreamWriteSupport for [spark-sql-streaming-Console ...

2015-08-25admin阅读(1682)赞(0)

MemoryStream MemoryStream is a streaming Source that produces values to memory. MemoryStream uses the internal ...

2015-08-24admin阅读(1636)赞(0)

MemorySink MemorySink is a streaming Sink that stores records in memory. It is particularly useful for testing. ...