public class SourceStateTracker extends Object
Constructor and Description |
---|
SourceStateTracker(org.apache.tez.serviceplugins.api.TaskCommunicatorContext taskCommunicatorContext,
LlapTaskCommunicator taskCommunicator) |
Modifier and Type | Method and Description |
---|---|
LlapDaemonProtocolProtos.FragmentRuntimeInfo |
getFragmentRuntimeInfo(String vertexName,
int fragmentNumber,
int priority)
Constructs FragmentRuntimeInfo for scheduling within LLAP daemons.
|
void |
registerTaskForStateUpdates(String host,
int port,
List<org.apache.tez.runtime.api.impl.InputSpec> inputSpecList)
Used to register a task for state updates.
|
void |
resetState(int newDagId)
To be invoked after each DAG completes.
|
void |
sourceStateUpdated(String sourceName,
org.apache.tez.dag.api.event.VertexState sourceState)
Handled notifications on state updates for sources
|
public SourceStateTracker(org.apache.tez.serviceplugins.api.TaskCommunicatorContext taskCommunicatorContext, LlapTaskCommunicator taskCommunicator)
public void resetState(int newDagId)
public void registerTaskForStateUpdates(String host, int port, List<org.apache.tez.runtime.api.impl.InputSpec> inputSpecList)
host
- port
- inputSpecList
- public void sourceStateUpdated(String sourceName, org.apache.tez.dag.api.event.VertexState sourceState)
sourceName
- sourceState
- public LlapDaemonProtocolProtos.FragmentRuntimeInfo getFragmentRuntimeInfo(String vertexName, int fragmentNumber, int priority)
vertexName
- fragmentNumber
- priority
- Copyright © 2016 The Apache Software Foundation. All rights reserved.