org.apache.flink.client.deployment

Class DefaultClusterClientServiceLoader

java.lang.Object

org.apache.flink.client.deployment.DefaultClusterClientServiceLoader

All Implemented Interfaces:

ClusterClientServiceLoader

@Internal
public class DefaultClusterClientServiceLoader
extends Object
implements ClusterClientServiceLoader

A service provider for cluster client factories.

Constructor Summary

Constructors

Constructor and Description
DefaultClusterClientServiceLoader()

Method Summary

Modifier and Type	Method and Description
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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultClusterClientServiceLoader

public DefaultClusterClientServiceLoader()

Method Detail

getClusterClientFactory

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

Description copied from interface: ClusterClientServiceLoader

Discovers the appropriate ClusterClientFactory based on the provided configuration.

Specified by:

getClusterClientFactory in interface ClusterClientServiceLoader

Parameters:

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

Returns:

the appropriate ClusterClientFactory.

getApplicationModeTargetNames

public Stream<String> getApplicationModeTargetNames()

Description copied from interface: ClusterClientServiceLoader

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

Specified by:

getApplicationModeTargetNames in interface ClusterClientServiceLoader