org.apache.hadoop.hive.llap.tezplugins.helpers

Class SourceStateTracker

java.lang.Object

org.apache.hadoop.hive.llap.tezplugins.helpers.SourceStateTracker

public class SourceStateTracker
extends Object

Constructor Summary

Constructors

Constructor and Description
SourceStateTracker(org.apache.tez.serviceplugins.api.TaskCommunicatorContext taskCommunicatorContext, LlapTaskCommunicator taskCommunicator)

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.hive.llap.daemon.rpc.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(org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.QueryIdentifierProto currentQueryIdentifierProto) 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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SourceStateTracker

public SourceStateTracker(org.apache.tez.serviceplugins.api.TaskCommunicatorContext taskCommunicatorContext,
                          LlapTaskCommunicator taskCommunicator)

Method Detail

resetState

public void resetState(org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.QueryIdentifierProto currentQueryIdentifierProto)

To be invoked after each DAG completes.

registerTaskForStateUpdates

public void registerTaskForStateUpdates(String host,
                                        int port,
                                        List<org.apache.tez.runtime.api.impl.InputSpec> inputSpecList)

Used to register a task for state updates. Effectively registers for state updates to go to the specific node.

Parameters:

host -

port -

inputSpecList -

sourceStateUpdated

public void sourceStateUpdated(String sourceName,
                               org.apache.tez.dag.api.event.VertexState sourceState)

Handled notifications on state updates for sources

Parameters:

sourceName -

sourceState -

getFragmentRuntimeInfo

public org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.FragmentRuntimeInfo getFragmentRuntimeInfo(String vertexName,
                                                                                                                  int fragmentNumber,
                                                                                                                  int priority)

Constructs FragmentRuntimeInfo for scheduling within LLAP daemons. Also caches state based on state updates.

Parameters:

vertexName -

fragmentNumber -

priority -

Returns: