Interface | Description |
---|---|
ChangelogResult<C> |
A result that is represented as a changelog consisting of insert and delete records.
|
DynamicResult<C> |
A result of a dynamic table program.
|
MaterializedResult<C> |
A result that is materialized and can be viewed by navigating through a snapshot.
|
Class | Description |
---|---|
ChangelogCollectStreamResult<C> |
Collects results and returns them as a changelog.
|
CollectStreamResult<C> |
A result that works similarly to
DataStreamUtils.collect(DataStream) . |
CollectStreamTableSink |
Table sink for collecting the results locally using sockets.
|
ExecutionContext<T> |
Context for executing table programs.
|
LocalExecutor |
Executor that performs the Flink communication locally.
|
MaterializedCollectStreamResult<C> |
Collects results and returns them as table snapshots.
|
ResultStore |
Maintains dynamic results.
|
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.