structured-streaming 第9页

2015-09-12admin阅读(1115)赞(0)

MemoryPlan Logical Operator MemoryPlan is a leaf logical operator (i.e. LogicalPlan) that is used to query the dat ...

2015-09-11admin阅读(1608)赞(0)

Deduplicate Unary Logical Operator Deduplicate is a unary logical operator (i.e. LogicalPlan) that is created to r ...

2015-09-10admin阅读(1512)赞(0)

FlatMapGroupsWithState Unary Logical Operator

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

EventTimeWatermark Unary Logical Operator

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

BaseStreamingSource Contract BaseStreamingSource is…​FIXME

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

StreamingQueryListenerBus — Notification Bus for Streaming Events

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

IncrementalExecution — QueryExecution of Streaming Datasets

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

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

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

QueryExecutionThread QueryExecutionThread is…​FIXME

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

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