Interface | Description |
---|---|
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.
|
MiniClusterJobClient |
A
JobClient for a MiniCluster . |
Enum | Description |
---|---|
MiniCluster.HaServices |
HA Services to use.
|
MiniClusterJobClient.JobFinalizationBehavior |
Determines the behavior of the
MiniClusterJobClient when the job finishes. |
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–2022 The Apache Software Foundation. All rights reserved.