org.apache.drill.exec.work

Class EndpointListener<RET,V>

java.lang.Object

org.apache.drill.exec.rpc.BaseRpcOutcomeListener<RET>

org.apache.drill.exec.work.EndpointListener<RET,V>

All Implemented Interfaces:

RpcOutcomeListener<RET>

public abstract class EndpointListener<RET,V>
extends BaseRpcOutcomeListener<RET>

Field Summary

Fields

Modifier and Type	Field and Description
protected CoordinationProtos.DrillbitEndpoint	endpoint
protected V	value

Constructor Summary

Constructors

Constructor and Description
EndpointListener(CoordinationProtos.DrillbitEndpoint endpoint, V value)

Method Summary

Modifier and Type	Method and Description
protected CoordinationProtos.DrillbitEndpoint	getEndpoint()
protected V	getValue()

Methods inherited from class org.apache.drill.exec.rpc.BaseRpcOutcomeListener

failed, interrupted, success

Methods inherited from class java.lang.Object

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

Field Detail

endpoint

protected final CoordinationProtos.DrillbitEndpoint endpoint

value

protected final V value

Constructor Detail

EndpointListener

public EndpointListener(CoordinationProtos.DrillbitEndpoint endpoint,
                        V value)

Method Detail

getEndpoint

protected CoordinationProtos.DrillbitEndpoint getEndpoint()

getValue

protected V getValue()