org.apache.hadoop.hive.llap.tezplugins

Class LlapTaskCommunicator.LlapTaskUmbilicalProtocolImpl

java.lang.Object

org.apache.hadoop.hive.llap.tezplugins.LlapTaskCommunicator.LlapTaskUmbilicalProtocolImpl

All Implemented Interfaces:

LlapTaskUmbilicalProtocol, org.apache.hadoop.ipc.VersionedProtocol

Enclosing class:

LlapTaskCommunicator

protected class LlapTaskCommunicator.LlapTaskUmbilicalProtocolImpl
extends Object
implements LlapTaskUmbilicalProtocol

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.hive.llap.protocol.LlapTaskUmbilicalProtocol

LlapTaskUmbilicalProtocol.BooleanArray, LlapTaskUmbilicalProtocol.TezAttemptArray

Field Summary

Fields inherited from interface org.apache.hadoop.hive.llap.protocol.LlapTaskUmbilicalProtocol

versionID

Constructor Summary

Constructors

Constructor and Description
LlapTaskUmbilicalProtocolImpl(org.apache.tez.common.TezTaskUmbilicalProtocol tezUmbilical)

Method Summary

Modifier and Type	Method and Description
boolean	canCommit(org.apache.tez.dag.records.TezTaskAttemptID taskid)
org.apache.hadoop.ipc.ProtocolSignature	getProtocolSignature(String protocol, long clientVersion, int clientMethodsHash)
long	getProtocolVersion(String protocol, long clientVersion)
org.apache.tez.runtime.api.impl.TezHeartbeatResponse	heartbeat(org.apache.tez.runtime.api.impl.TezHeartbeatRequest request)
void	nodeHeartbeat(org.apache.hadoop.io.Text hostname, org.apache.hadoop.io.Text uniqueId, int port, LlapTaskUmbilicalProtocol.TezAttemptArray aw, LlapTaskUmbilicalProtocol.BooleanArray guaranteed)
void	taskKilled(org.apache.tez.dag.records.TezTaskAttemptID taskAttemptId)

Methods inherited from class java.lang.Object

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

Constructor Detail

LlapTaskUmbilicalProtocolImpl

public LlapTaskUmbilicalProtocolImpl(org.apache.tez.common.TezTaskUmbilicalProtocol tezUmbilical)

Method Detail

canCommit

public boolean canCommit(org.apache.tez.dag.records.TezTaskAttemptID taskid)
                  throws IOException

Specified by:

canCommit in interface LlapTaskUmbilicalProtocol

Throws:

IOException

heartbeat

public org.apache.tez.runtime.api.impl.TezHeartbeatResponse heartbeat(org.apache.tez.runtime.api.impl.TezHeartbeatRequest request)
                                                               throws IOException,
                                                                      org.apache.tez.dag.api.TezException

Specified by:

heartbeat in interface LlapTaskUmbilicalProtocol

Throws:

IOException

org.apache.tez.dag.api.TezException

nodeHeartbeat

public void nodeHeartbeat(org.apache.hadoop.io.Text hostname,
                          org.apache.hadoop.io.Text uniqueId,
                          int port,
                          LlapTaskUmbilicalProtocol.TezAttemptArray aw,
                          LlapTaskUmbilicalProtocol.BooleanArray guaranteed)
                   throws IOException

Specified by:

nodeHeartbeat in interface LlapTaskUmbilicalProtocol

Throws:

IOException

taskKilled

public void taskKilled(org.apache.tez.dag.records.TezTaskAttemptID taskAttemptId)
                throws IOException

Specified by:

taskKilled in interface LlapTaskUmbilicalProtocol

Throws:

IOException

getProtocolVersion

public long getProtocolVersion(String protocol,
                               long clientVersion)
                        throws IOException

Specified by:

getProtocolVersion in interface org.apache.hadoop.ipc.VersionedProtocol

Throws:

IOException

getProtocolSignature

public org.apache.hadoop.ipc.ProtocolSignature getProtocolSignature(String protocol,
                                                                    long clientVersion,
                                                                    int clientMethodsHash)
                                                             throws IOException

Specified by:

getProtocolSignature in interface org.apache.hadoop.ipc.VersionedProtocol

Throws:

IOException