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

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	LlapTaskUmbilicalProtocol.BooleanArray
static class	LlapTaskUmbilicalProtocol.TezAttemptArray

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, 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 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,
                   org.apache.hadoop.io.Text uniqueId,
                   int port,
                   LlapTaskUmbilicalProtocol.TezAttemptArray aw,
                   LlapTaskUmbilicalProtocol.BooleanArray guaranteed)
            throws IOException

Throws:

IOException

taskKilled

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

Throws:

IOException