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

Class AMReporter

java.lang.Object

org.apache.hadoop.service.AbstractService

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

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.service.Service

public class AMReporter
extends org.apache.hadoop.service.AbstractService

Responsible for communicating with various AMs.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	AMReporter.AMNodeInfo

Nested classes/interfaces inherited from interface org.apache.hadoop.service.Service

org.apache.hadoop.service.Service.STATE

Constructor Summary

Constructors

Constructor and Description
AMReporter(int numExecutors, int maxThreads, AtomicReference<InetSocketAddress> localAddress, QueryFailedHandler queryFailedHandler, org.apache.hadoop.conf.Configuration conf, DaemonId daemonId, SocketFactory socketFactory)

Method Summary

Modifier and Type	Method and Description
protected LlapTaskUmbilicalProtocol	createUmbilical(AMReporter.AMNodeInfo amNodeInfo)
void	queryComplete(QueryIdentifier queryIdentifier)
AMReporter.AMNodeInfo	registerTask(String amLocation, int port, String umbilicalUser, org.apache.hadoop.security.token.Token<org.apache.tez.common.security.JobTokenIdentifier> jobToken, QueryIdentifier queryIdentifier, org.apache.tez.dag.records.TezTaskAttemptID attemptId, boolean isGuaranteed)
void	serviceStart()
void	serviceStop()
void	taskKilled(String amLocation, int port, String umbilicalUser, org.apache.hadoop.security.token.Token<org.apache.tez.common.security.JobTokenIdentifier> jobToken, QueryIdentifier queryIdentifier, org.apache.tez.dag.records.TezTaskAttemptID taskAttemptId)
void	unregisterTask(String amLocation, int port, QueryIdentifier queryIdentifier, org.apache.tez.dag.records.TezTaskAttemptID ta)

Methods inherited from class org.apache.hadoop.service.AbstractService

close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, serviceInit, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop

Methods inherited from class java.lang.Object

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

Constructor Detail

AMReporter

public AMReporter(int numExecutors,
                  int maxThreads,
                  AtomicReference<InetSocketAddress> localAddress,
                  QueryFailedHandler queryFailedHandler,
                  org.apache.hadoop.conf.Configuration conf,
                  DaemonId daemonId,
                  SocketFactory socketFactory)

Method Detail

serviceStart

public void serviceStart()

Overrides:

serviceStart in class org.apache.hadoop.service.AbstractService

serviceStop

public void serviceStop()

Overrides:

serviceStop in class org.apache.hadoop.service.AbstractService

registerTask

public AMReporter.AMNodeInfo registerTask(String amLocation,
                                          int port,
                                          String umbilicalUser,
                                          org.apache.hadoop.security.token.Token<org.apache.tez.common.security.JobTokenIdentifier> jobToken,
                                          QueryIdentifier queryIdentifier,
                                          org.apache.tez.dag.records.TezTaskAttemptID attemptId,
                                          boolean isGuaranteed)

unregisterTask

public void unregisterTask(String amLocation,
                           int port,
                           QueryIdentifier queryIdentifier,
                           org.apache.tez.dag.records.TezTaskAttemptID ta)

taskKilled

public void taskKilled(String amLocation,
                       int port,
                       String umbilicalUser,
                       org.apache.hadoop.security.token.Token<org.apache.tez.common.security.JobTokenIdentifier> jobToken,
                       QueryIdentifier queryIdentifier,
                       org.apache.tez.dag.records.TezTaskAttemptID taskAttemptId)

queryComplete

public void queryComplete(QueryIdentifier queryIdentifier)

createUmbilical

protected LlapTaskUmbilicalProtocol createUmbilical(AMReporter.AMNodeInfo amNodeInfo)
                                             throws IOException,
                                                    InterruptedException

Throws:

IOException

InterruptedException