protected class LlapTaskCommunicator.LlapTaskUmbilicalProtocolImpl extends Object implements LlapTaskUmbilicalProtocol
versionID
Constructor and Description |
---|
LlapTaskUmbilicalProtocolImpl(org.apache.tez.common.TezTaskUmbilicalProtocol tezUmbilical) |
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,
int port) |
void |
taskKilled(org.apache.tez.dag.records.TezTaskAttemptID taskAttemptId) |
public LlapTaskUmbilicalProtocolImpl(org.apache.tez.common.TezTaskUmbilicalProtocol tezUmbilical)
public boolean canCommit(org.apache.tez.dag.records.TezTaskAttemptID taskid) throws IOException
canCommit
in interface LlapTaskUmbilicalProtocol
IOException
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
heartbeat
in interface LlapTaskUmbilicalProtocol
IOException
org.apache.tez.dag.api.TezException
public void nodeHeartbeat(org.apache.hadoop.io.Text hostname, int port) throws IOException
nodeHeartbeat
in interface LlapTaskUmbilicalProtocol
IOException
public void taskKilled(org.apache.tez.dag.records.TezTaskAttemptID taskAttemptId) throws IOException
taskKilled
in interface LlapTaskUmbilicalProtocol
IOException
public long getProtocolVersion(String protocol, long clientVersion) throws IOException
getProtocolVersion
in interface org.apache.hadoop.ipc.VersionedProtocol
IOException
public org.apache.hadoop.ipc.ProtocolSignature getProtocolSignature(String protocol, long clientVersion, int clientMethodsHash) throws IOException
getProtocolSignature
in interface org.apache.hadoop.ipc.VersionedProtocol
IOException
Copyright © 2016 The Apache Software Foundation. All rights reserved.