public interface LlapTaskUmbilicalProtocol
extends org.apache.hadoop.ipc.VersionedProtocol
Modifier and Type | Interface and Description |
---|---|
static class |
LlapTaskUmbilicalProtocol.BooleanArray |
static class |
LlapTaskUmbilicalProtocol.TezAttemptArray |
Modifier and Type | Field and Description |
---|---|
static long |
versionID |
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) |
static final long versionID
boolean canCommit(org.apache.tez.dag.records.TezTaskAttemptID taskid) throws IOException
IOException
org.apache.tez.runtime.api.impl.TezHeartbeatResponse heartbeat(org.apache.tez.runtime.api.impl.TezHeartbeatRequest request) throws IOException, org.apache.tez.dag.api.TezException
IOException
org.apache.tez.dag.api.TezException
void nodeHeartbeat(org.apache.hadoop.io.Text hostname, org.apache.hadoop.io.Text uniqueId, int port, LlapTaskUmbilicalProtocol.TezAttemptArray aw, LlapTaskUmbilicalProtocol.BooleanArray guaranteed) throws IOException
IOException
void taskKilled(org.apache.tez.dag.records.TezTaskAttemptID taskAttemptId) throws IOException
IOException
Copyright © 2022 The Apache Software Foundation. All rights reserved.