Interface | Description |
---|---|
JobExecutor |
Interface for
JobGraph executors. |
JobExecutorService |
Interface to control
JobExecutor . |
MiniCluster.RpcServiceFactory |
Internal factory for
RpcService . |
Class | Description |
---|---|
MiniCluster |
MiniCluster to execute Flink jobs locally.
|
MiniCluster.CommonRpcServiceFactory |
Factory which returns always the common
RpcService . |
MiniClusterConfiguration |
Configuration object for the
MiniCluster . |
MiniClusterConfiguration.Builder |
Builder for the MiniClusterConfiguration.
|
Enum | Description |
---|---|
RpcServiceSharing |
Enum which defines whether the mini cluster components use a shared RpcService or whether every
component gets its own dedicated RpcService started.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.