org.apache.reef.runtime.common.evaluator

Class DefaultDriverConnection

java.lang.Object

org.apache.reef.runtime.common.evaluator.DefaultDriverConnection

All Implemented Interfaces:

AutoCloseable, DriverConnection

public final class DefaultDriverConnection
extends Object
implements DriverConnection

Default implementation for re-establishing connection to driver after driver restart. In this default implementation, information about re-started driver will be obtained by querying Http server.

Constructor Summary

Constructors

Constructor and Description
DefaultDriverConnection()

Method Summary

Modifier and Type	Method and Description
void	close()
String	getDriverRemoteIdentifier()

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultDriverConnection

@Inject
public DefaultDriverConnection()

Method Detail

getDriverRemoteIdentifier

public String getDriverRemoteIdentifier()

Specified by:

getDriverRemoteIdentifier in interface DriverConnection

Returns:

driver remove identifier to facilitate reconnection to the (restarted) driver

close

public void close()

Specified by:

close in interface AutoCloseable