structured-streaming 第10页

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

StreamingQueryWrapper — Serializable StreamExecution

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

StreamExecution — Base of Streaming Query Executions

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

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

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

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

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

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

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

ForeachWriterProvider ForeachWriterProvider is…​FIXME

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

ConsoleSink for Showing DataFrames to Console

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

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

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

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

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

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