@PublicAPI public class RMConnection extends Connection<RMAuthentication>
RMAuthentication
for further authentication.Modifier and Type | Method and Description |
---|---|
static RMConnection |
getInstance() |
org.apache.log4j.Logger |
getLogger()
Retrieves a corresponding logger.
|
static RMAuthentication |
join(String url)
Returns the
RMAuthentication from the specified
URL. |
static RMAuthentication |
waitAndJoin(String url)
Connects to the resource manager using given URL.
|
static RMAuthentication |
waitAndJoin(String url,
long timeout)
Connects to the resource manager with a specified timeout value.
|
connect, getNetworkInterfaceFor, normalize, waitAndConnect, waitAndConnect
public org.apache.log4j.Logger getLogger()
Loggable
public static RMConnection getInstance()
public static RMAuthentication join(String url) throws RMException
RMAuthentication
from the specified
URL. If resource manager is not available or initializing throws an exception.url
- the URL of the resource manager to join.RMException
- thrown if the connection to the resource manager cannot be
established.public static RMAuthentication waitAndJoin(String url) throws RMException
RMException
public static RMAuthentication waitAndJoin(String url, long timeout) throws RMException
RMException