Class and Description |
---|
MiniCluster
MiniCluster to execute Flink jobs locally.
|
MiniClusterConfiguration
Configuration object for the
MiniCluster . |
Class and Description |
---|
MiniCluster
MiniCluster to execute Flink jobs locally.
|
MiniClusterConfiguration
Configuration object for the
MiniCluster . |
Class and Description |
---|
JobExecutor
Interface for
JobGraph executors. |
JobExecutorService
Interface to control
JobExecutor . |
MiniCluster.RpcServiceFactory
Internal factory for
RpcService . |
MiniClusterConfiguration
Configuration object for the
MiniCluster . |
MiniClusterConfiguration.Builder
Builder for the MiniClusterConfiguration.
|
RpcServiceSharing
Enum which defines whether the mini cluster components use a shared RpcService or whether every
component gets its own dedicated RpcService started.
|
Class and Description |
---|
JobExecutor
Interface for
JobGraph executors. |
Class and Description |
---|
JobExecutor
Interface for
JobGraph executors. |
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.