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

Class QueryTracker

java.lang.Object

org.apache.hadoop.service.AbstractService

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

All Implemented Interfaces:

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

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

Tracks queries running within a daemon

Nested Class Summary

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

org.apache.hadoop.service.Service.STATE

Constructor Summary

Constructors

Constructor and Description
QueryTracker(org.apache.hadoop.conf.Configuration conf, String[] localDirsBase, String clusterId)

Method Summary

Modifier and Type	Method and Description
boolean	checkPermissionsForQuery(QueryIdentifier queryId)
void	rememberCompletedDag(QueryIdentifier queryIdentifier)
void	serviceStart()
void	serviceStop()

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

QueryTracker

public QueryTracker(org.apache.hadoop.conf.Configuration conf,
                    String[] localDirsBase,
                    String clusterId)

Method Detail

rememberCompletedDag

public void rememberCompletedDag(QueryIdentifier queryIdentifier)

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

checkPermissionsForQuery

public boolean checkPermissionsForQuery(QueryIdentifier queryId)
                                 throws IOException

Throws:

IOException