public final class StandaloneUtils extends Object
Modifier and Type | Method and Description |
---|---|
static StandaloneLeaderRetrievalService |
createLeaderRetrievalService(Configuration configuration)
Creates a
StandaloneLeaderRetrievalService from the given configuration. |
static StandaloneLeaderRetrievalService |
createLeaderRetrievalService(Configuration configuration,
boolean resolveInitialHostName)
Creates a
StandaloneLeaderRetrievalService from the given configuration. |
static StandaloneLeaderRetrievalService |
createLeaderRetrievalService(Configuration configuration,
boolean resolveInitialHostName,
String jobManagerName)
Creates a
StandaloneLeaderRetrievalService form the given configuration and the
JobManager name. |
public static StandaloneLeaderRetrievalService createLeaderRetrievalService(Configuration configuration) throws UnknownHostException
StandaloneLeaderRetrievalService
from the given configuration. The
host and port for the remote Akka URL are retrieved from the provided configuration.configuration
- Configuration instance containing the host and port informationUnknownHostException
public static StandaloneLeaderRetrievalService createLeaderRetrievalService(Configuration configuration, boolean resolveInitialHostName) throws UnknownHostException
StandaloneLeaderRetrievalService
from the given configuration. The
host and port for the remote Akka URL are retrieved from the provided configuration.configuration
- Configuration instance containing the host and port informationresolveInitialHostName
- If true, resolves the hostname of the StandaloneLeaderRetrievalServiceUnknownHostException
public static StandaloneLeaderRetrievalService createLeaderRetrievalService(Configuration configuration, boolean resolveInitialHostName, String jobManagerName) throws UnknownHostException
StandaloneLeaderRetrievalService
form the given configuration and the
JobManager name. The host and port for the remote Akka URL are retrieved from the provided
configuration. Instead of using the standard JobManager Akka name, the provided one is used
for the remote Akka URL.configuration
- Configuration instance containing hte host and port informationresolveInitialHostName
- If true, resolves the hostname of the StandaloneLeaderRetrievalServicejobManagerName
- Name of the JobManager actorUnknownHostException
- if the host name cannot be resolved into an InetAddress
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.