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 |
---|
MiniCluster
MiniCluster to execute Flink jobs locally.
|
MiniCluster.HaServices
HA Services to use.
|
MiniCluster.RpcServiceFactory
Internal factory for
RpcService . |
MiniClusterConfiguration
Configuration object for the
MiniCluster . |
MiniClusterConfiguration.Builder
Builder for the MiniClusterConfiguration.
|
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.
|
Class and Description |
---|
MiniCluster
MiniCluster to execute Flink jobs locally.
|
Class and Description |
---|
MiniCluster
MiniCluster to execute Flink jobs locally.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.