Class | Description |
---|---|
CollectBatchTableSink |
Table sink for collecting the results locally all at once using accumulators.
|
CollectStreamTableSink |
Table sink for collecting the results locally using sockets.
|
ExecutionContext<ClusterID> |
Context for executing table programs.
|
ExecutionContext.Builder |
Builder for
ExecutionContext . |
ExecutionContext.SessionState |
Represents the state that should be reused in one session.
|
LocalExecutor |
Executor that performs the Flink communication locally.
|
ProgramDeployer |
The helper class to deploy a table program on the cluster.
|
ResultStore |
Maintains dynamic results.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.