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,
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, 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 informationjobManagerName
- Name of the JobManager actorUnknownHostException
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.