Package | Description |
---|---|
org.apache.hadoop.hive.llap.daemon | |
org.apache.hadoop.hive.llap.daemon.impl |
Modifier and Type | Method and Description |
---|---|
void |
QueryFailedHandler.queryFailed(QueryIdentifier queryIdentifier) |
void |
KilledTaskHandler.taskKilled(String amLocation,
int port,
String user,
org.apache.hadoop.security.token.Token<org.apache.tez.common.security.JobTokenIdentifier> jobToken,
QueryIdentifier queryIdentifier,
org.apache.tez.dag.records.TezTaskAttemptID taskAttemptId) |
Modifier and Type | Method and Description |
---|---|
QueryIdentifier |
TaskExecutorService.findQueryByFragment(String fragmentId) |
QueryIdentifier |
Scheduler.findQueryByFragment(String fragmentId) |
QueryIdentifier |
QueryInfo.getQueryIdentifier() |
QueryIdentifier |
AMReporter.AMNodeInfo.getQueryIdentifier() |
Modifier and Type | Method and Description |
---|---|
boolean |
QueryTracker.checkPermissionsForQuery(QueryIdentifier queryId) |
void |
AMReporter.queryComplete(QueryIdentifier queryIdentifier) |
void |
ContainerRunnerImpl.queryFailed(QueryIdentifier queryIdentifier) |
AMReporter.AMNodeInfo |
AMReporter.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 |
QueryTracker.rememberCompletedDag(QueryIdentifier queryIdentifier) |
void |
AMReporter.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 |
AMReporter.unregisterTask(String amLocation,
int port,
QueryIdentifier queryIdentifier,
org.apache.tez.dag.records.TezTaskAttemptID ta) |
Constructor and Description |
---|
AMNodeInfo(LlapNodeId amNodeId,
String umbilicalUser,
org.apache.hadoop.security.token.Token<org.apache.tez.common.security.JobTokenIdentifier> jobToken,
QueryIdentifier currentQueryIdentifier,
org.apache.hadoop.io.retry.RetryPolicy retryPolicy,
long timeout,
SocketFactory socketFactory,
org.apache.hadoop.conf.Configuration conf) |
QueryInfo(QueryIdentifier queryIdentifier,
String appIdString,
String dagIdString,
String dagName,
String hiveQueryIdString,
int dagIdentifier,
String user,
ConcurrentMap<String,org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SourceStateProto> sourceStateMap,
String[] localDirsBase,
org.apache.hadoop.fs.FileSystem localFs,
String tokenUserName,
String tokenAppId,
LlapNodeId amNodeId,
String tokenIdentifier,
org.apache.hadoop.security.token.Token<org.apache.tez.common.security.JobTokenIdentifier> appToken,
boolean isExternalQuery) |
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.