org.apache.hadoop.hive.llap.daemon.impl

Class LlapTaskReporter

java.lang.Object

org.apache.hadoop.hive.llap.daemon.impl.LlapTaskReporter

All Implemented Interfaces:

org.apache.tez.runtime.internals.api.TaskReporterInterface

public class LlapTaskReporter
extends Object
implements org.apache.tez.runtime.internals.api.TaskReporterInterface

Responsible for communication between tasks running in a Container and the ApplicationMaster. Takes care of sending heartbeats (regular and OOB) to the AM - to send generated events, and to retrieve events specific to this task.

Constructor Summary

Constructors

Constructor and Description
LlapTaskReporter(SchedulerFragmentCompletingListener completionListener, LlapTaskUmbilicalProtocol umbilical, long amPollInterval, long sendCounterInterval, int maxEventsToGet, AtomicLong requestCounter, String containerIdStr, String fragmentId, org.apache.tez.runtime.api.impl.TezEvent initialEvent, String fragmentRequestId, WmFragmentCounters wmCounters)

Method Summary

Modifier and Type	Method and Description
void	addEvents(org.apache.tez.dag.records.TezTaskAttemptID taskAttemptID, Collection<org.apache.tez.runtime.api.impl.TezEvent> events)
boolean	canCommit(org.apache.tez.dag.records.TezTaskAttemptID taskAttemptID)
void	registerTask(org.apache.tez.runtime.RuntimeTask task, org.apache.tez.runtime.task.ErrorReporter errorReporter) Register a task to be tracked.
void	shutdown()
boolean	taskFailed(org.apache.tez.dag.records.TezTaskAttemptID tezTaskAttemptID, org.apache.tez.runtime.api.TaskFailureType taskFailureType, Throwable throwable, String diagnostics, org.apache.tez.runtime.api.impl.EventMetaData srcMeta)
boolean	taskKilled(org.apache.tez.dag.records.TezTaskAttemptID tezTaskAttemptID, Throwable throwable, String diagnostics, org.apache.tez.runtime.api.impl.EventMetaData srcMeta)
boolean	taskSucceeded(org.apache.tez.dag.records.TezTaskAttemptID taskAttemptID)
void	unregisterTask(org.apache.tez.dag.records.TezTaskAttemptID taskAttemptID) This method should always be invoked before setting up heartbeats for another task running in the same container.

Methods inherited from class java.lang.Object

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

Constructor Detail

LlapTaskReporter

public LlapTaskReporter(SchedulerFragmentCompletingListener completionListener,
                        LlapTaskUmbilicalProtocol umbilical,
                        long amPollInterval,
                        long sendCounterInterval,
                        int maxEventsToGet,
                        AtomicLong requestCounter,
                        String containerIdStr,
                        String fragmentId,
                        org.apache.tez.runtime.api.impl.TezEvent initialEvent,
                        String fragmentRequestId,
                        WmFragmentCounters wmCounters)

Method Detail

registerTask

public void registerTask(org.apache.tez.runtime.RuntimeTask task,
                         org.apache.tez.runtime.task.ErrorReporter errorReporter)

Register a task to be tracked. Heartbeats will be sent out for this task to fetch events, etc.

Specified by:

registerTask in interface org.apache.tez.runtime.internals.api.TaskReporterInterface

unregisterTask

public void unregisterTask(org.apache.tez.dag.records.TezTaskAttemptID taskAttemptID)

This method should always be invoked before setting up heartbeats for another task running in the same container.

Specified by:

unregisterTask in interface org.apache.tez.runtime.internals.api.TaskReporterInterface

shutdown

public void shutdown()

Specified by:

shutdown in interface org.apache.tez.runtime.internals.api.TaskReporterInterface

taskSucceeded

public boolean taskSucceeded(org.apache.tez.dag.records.TezTaskAttemptID taskAttemptID)
                      throws IOException,
                             org.apache.tez.dag.api.TezException

Specified by:

taskSucceeded in interface org.apache.tez.runtime.internals.api.TaskReporterInterface

Throws:

IOException

org.apache.tez.dag.api.TezException

taskFailed

public boolean taskFailed(org.apache.tez.dag.records.TezTaskAttemptID tezTaskAttemptID,
                          org.apache.tez.runtime.api.TaskFailureType taskFailureType,
                          Throwable throwable,
                          String diagnostics,
                          org.apache.tez.runtime.api.impl.EventMetaData srcMeta)
                   throws IOException,
                          org.apache.tez.dag.api.TezException

Specified by:

taskFailed in interface org.apache.tez.runtime.internals.api.TaskReporterInterface

Throws:

IOException

org.apache.tez.dag.api.TezException

taskKilled

public boolean taskKilled(org.apache.tez.dag.records.TezTaskAttemptID tezTaskAttemptID,
                          Throwable throwable,
                          String diagnostics,
                          org.apache.tez.runtime.api.impl.EventMetaData srcMeta)
                   throws IOException,
                          org.apache.tez.dag.api.TezException

Specified by:

taskKilled in interface org.apache.tez.runtime.internals.api.TaskReporterInterface

Throws:

IOException

org.apache.tez.dag.api.TezException

addEvents

public void addEvents(org.apache.tez.dag.records.TezTaskAttemptID taskAttemptID,
                      Collection<org.apache.tez.runtime.api.impl.TezEvent> events)

Specified by:

addEvents in interface org.apache.tez.runtime.internals.api.TaskReporterInterface

canCommit

public boolean canCommit(org.apache.tez.dag.records.TezTaskAttemptID taskAttemptID)
                  throws IOException

Specified by:

canCommit in interface org.apache.tez.runtime.internals.api.TaskReporterInterface

Throws:

IOException