spark技术分享

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

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

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

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

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

ForeachWriterProvider ForeachWriterProvider is…​FIXME

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

ConsoleSink for Showing DataFrames to Console

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

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

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

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

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

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

2015-08-23admin阅读(1133)赞(0)

MemorySinkV2 MemorySinkV2 is…​FIXME

2015-08-22admin阅读(1329)赞(0)

RateStreamSource RateStreamSource is a streaming source that generates consecutive numbers with timestamp that can ...

2015-08-21admin阅读(1513)赞(0)

RateSourceProvider RateSourceProvider is a StreamSourceProvider for RateStreamSource (that acts as the source for ...