org.apache.flink.client.deployment

Interface ClusterClientServiceLoader

All Known Implementing Classes:

DefaultClusterClientServiceLoader

public interface ClusterClientServiceLoader

An interface used to discover the appropriate cluster client factory based on the provided Configuration.

Method Summary

Modifier and Type	Method and Description
java.util.stream.Stream<String>	getApplicationModeTargetNames() Loads and returns a stream of the names of all available execution target names for Application Mode.
<ClusterID> ClusterClientFactory<ClusterID>	getClusterClientFactory(Configuration configuration) Discovers the appropriate ClusterClientFactory based on the provided configuration.

Method Detail

getClusterClientFactory

<ClusterID> ClusterClientFactory<ClusterID> getClusterClientFactory(Configuration configuration)

Discovers the appropriate ClusterClientFactory based on the provided configuration.

Parameters:

configuration - the configuration based on which the appropriate factory is going to be used.

Returns:

the appropriate ClusterClientFactory.

getApplicationModeTargetNames

java.util.stream.Stream<String> getApplicationModeTargetNames()

Loads and returns a stream of the names of all available execution target names for Application Mode.