org.apache.hadoop.hive.llap.protocol

Interface LlapTaskUmbilicalProtocol

All Superinterfaces:

org.apache.hadoop.ipc.VersionedProtocol

All Known Implementing Classes:

LlapTaskCommunicator.LlapTaskUmbilicalProtocolImpl

public interface LlapTaskUmbilicalProtocol
extends org.apache.hadoop.ipc.VersionedProtocol

Field Summary

Fields

Modifier and Type	Field and Description
static long	versionID

Method Summary

Modifier and Type	Method and Description
boolean	canCommit(org.apache.tez.dag.records.TezTaskAttemptID taskid)
org.apache.tez.runtime.api.impl.TezHeartbeatResponse	heartbeat(org.apache.tez.runtime.api.impl.TezHeartbeatRequest request)
void	nodeHeartbeat(org.apache.hadoop.io.Text hostname, int port)
void	taskKilled(org.apache.tez.dag.records.TezTaskAttemptID taskAttemptId)

Methods inherited from interface org.apache.hadoop.ipc.VersionedProtocol

getProtocolSignature, getProtocolVersion

Field Detail

versionID

static final long versionID

See Also:

Constant Field Values

Method Detail

canCommit

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

Throws:

IOException

heartbeat

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

Throws:

IOException

org.apache.tez.dag.api.TezException

nodeHeartbeat

void nodeHeartbeat(org.apache.hadoop.io.Text hostname,
                   int port)
            throws IOException

Throws:

IOException

taskKilled

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

Throws:

IOException