Package | Description |
---|---|
org.apache.flink.client.program | |
org.apache.flink.runtime.minicluster | |
org.apache.flink.streaming.util | |
org.apache.flink.test.util |
Class and Description |
---|
MiniCluster
MiniCluster to execute Flink jobs locally.
|
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–2020 The Apache Software Foundation. All rights reserved.