public class LlapTaskCommunicator
extends org.apache.tez.dag.app.TezTaskCommunicatorImpl
Modifier and Type | Class and Description |
---|---|
protected class |
LlapTaskCommunicator.LlapTaskUmbilicalProtocolImpl |
Constructor and Description |
---|
LlapTaskCommunicator(org.apache.tez.serviceplugins.api.TaskCommunicatorContext taskCommunicatorContext) |
Modifier and Type | Method and Description |
---|---|
protected LlapProtocolClientProxy |
createLlapProtocolClientProxy(int numThreads,
org.apache.hadoop.conf.Configuration conf) |
void |
dagComplete(int dagIdentifier) |
String |
getCompletedLogsUrl(org.apache.tez.dag.records.TezTaskAttemptID attemptID,
org.apache.hadoop.yarn.api.records.NodeId containerNodeId) |
String |
getInProgressLogsUrl(org.apache.tez.dag.records.TezTaskAttemptID attemptID,
org.apache.hadoop.yarn.api.records.NodeId containerNodeId) |
void |
initialize() |
void |
onVertexStateUpdated(org.apache.tez.dag.api.event.VertexStateUpdate vertexStateUpdate) |
void |
registerContainerEnd(org.apache.hadoop.yarn.api.records.ContainerId containerId,
org.apache.tez.serviceplugins.api.ContainerEndReason endReason,
String diagnostics) |
void |
registerKnownNode(LlapNodeId nodeId) |
void |
registerPingingNode(LlapNodeId nodeId) |
void |
registerRunningContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId,
String hostname,
int port) |
void |
registerRunningTaskAttempt(org.apache.hadoop.yarn.api.records.ContainerId containerId,
org.apache.tez.runtime.api.impl.TaskSpec taskSpec,
Map<String,org.apache.hadoop.yarn.api.records.LocalResource> additionalResources,
org.apache.hadoop.security.Credentials credentials,
boolean credentialsChanged,
int priority) |
void |
sendStateUpdate(LlapNodeId nodeId,
LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto request) |
void |
shutdown() |
void |
start() |
protected void |
startRpcServer() |
void |
unregisterRunningTaskAttempt(org.apache.tez.dag.records.TezTaskAttemptID taskAttemptId,
org.apache.tez.serviceplugins.api.TaskAttemptEndReason endReason,
String diagnostics) |
public LlapTaskCommunicator(org.apache.tez.serviceplugins.api.TaskCommunicatorContext taskCommunicatorContext)
public void initialize() throws Exception
initialize
in interface org.apache.tez.common.ServicePluginLifecycle
initialize
in class org.apache.tez.serviceplugins.api.TaskCommunicator
Exception
public void start()
start
in interface org.apache.tez.common.ServicePluginLifecycle
start
in class org.apache.tez.dag.app.TezTaskCommunicatorImpl
public void shutdown()
shutdown
in interface org.apache.tez.common.ServicePluginLifecycle
shutdown
in class org.apache.tez.dag.app.TezTaskCommunicatorImpl
protected void startRpcServer()
startRpcServer
in class org.apache.tez.dag.app.TezTaskCommunicatorImpl
protected LlapProtocolClientProxy createLlapProtocolClientProxy(int numThreads, org.apache.hadoop.conf.Configuration conf)
public void registerRunningContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId, String hostname, int port)
registerRunningContainer
in class org.apache.tez.dag.app.TezTaskCommunicatorImpl
public void registerContainerEnd(org.apache.hadoop.yarn.api.records.ContainerId containerId, org.apache.tez.serviceplugins.api.ContainerEndReason endReason, String diagnostics)
registerContainerEnd
in class org.apache.tez.dag.app.TezTaskCommunicatorImpl
public void registerRunningTaskAttempt(org.apache.hadoop.yarn.api.records.ContainerId containerId, org.apache.tez.runtime.api.impl.TaskSpec taskSpec, Map<String,org.apache.hadoop.yarn.api.records.LocalResource> additionalResources, org.apache.hadoop.security.Credentials credentials, boolean credentialsChanged, int priority)
registerRunningTaskAttempt
in class org.apache.tez.dag.app.TezTaskCommunicatorImpl
public void unregisterRunningTaskAttempt(org.apache.tez.dag.records.TezTaskAttemptID taskAttemptId, org.apache.tez.serviceplugins.api.TaskAttemptEndReason endReason, String diagnostics)
unregisterRunningTaskAttempt
in class org.apache.tez.dag.app.TezTaskCommunicatorImpl
public void dagComplete(int dagIdentifier)
dagComplete
in class org.apache.tez.dag.app.TezTaskCommunicatorImpl
public void onVertexStateUpdated(org.apache.tez.dag.api.event.VertexStateUpdate vertexStateUpdate)
onVertexStateUpdated
in class org.apache.tez.dag.app.TezTaskCommunicatorImpl
public void sendStateUpdate(LlapNodeId nodeId, LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto request)
public String getInProgressLogsUrl(org.apache.tez.dag.records.TezTaskAttemptID attemptID, org.apache.hadoop.yarn.api.records.NodeId containerNodeId)
getInProgressLogsUrl
in class org.apache.tez.serviceplugins.api.TaskCommunicator
public String getCompletedLogsUrl(org.apache.tez.dag.records.TezTaskAttemptID attemptID, org.apache.hadoop.yarn.api.records.NodeId containerNodeId)
getCompletedLogsUrl
in class org.apache.tez.serviceplugins.api.TaskCommunicator
public void registerKnownNode(LlapNodeId nodeId)
public void registerPingingNode(LlapNodeId nodeId)
Copyright © 2016 The Apache Software Foundation. All rights reserved.