spark技术分享

2015-09-09admin阅读(1413)赞(0)

EventTimeWatermark Unary Logical Operator

2015-09-08admin阅读(1511)赞(0)

BaseStreamingSource Contract BaseStreamingSource is…​FIXME

2015-09-07admin阅读(1607)赞(0)

StreamingQueryListenerBus — Notification Bus for Streaming Events

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

IncrementalExecution — QueryExecution of Streaming Datasets

2015-09-05admin阅读(1387)赞(0)

TriggerExecutor TriggerExecutor is the interface for trigger executors that StreamExecution uses to execute a batc ...

2015-09-04admin阅读(1435)赞(0)

QueryExecutionThread QueryExecutionThread is…​FIXME

2015-09-03admin阅读(1617)赞(0)

ProgressReporter Contract ProgressReporter is the contract of stream execution progress reporters that continually ...

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

StreamingQueryWrapper — Serializable StreamExecution

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

StreamExecution — Base of Streaming Query Executions

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

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