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() |
Modifier and Type | Method and Description |
---|---|
boolean |
QueryTracker.checkPermissionsForQuery(QueryIdentifier queryId) |
void |
ContainerRunnerImpl.queryFailed(QueryIdentifier queryIdentifier) |
void |
QueryTracker.registerDagQueryId(QueryIdentifier queryIdentifier,
String hiveQueryIdString) |
void |
AMReporter.registerTask(String amLocation,
int port,
String user,
org.apache.hadoop.security.token.Token<org.apache.tez.common.security.JobTokenIdentifier> jobToken,
QueryIdentifier queryIdentifier) |
void |
QueryTracker.rememberCompletedDag(QueryIdentifier queryIdentifier) |
void |
AMReporter.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) |
Constructor and Description |
---|
QueryInfo(QueryIdentifier queryIdentifier,
String appIdString,
String dagName,
int dagIdentifier,
String user,
ConcurrentMap<String,LlapDaemonProtocolProtos.SourceStateProto> sourceStateMap,
String[] localDirsBase,
org.apache.hadoop.fs.FileSystem localFs,
String tokenUserName,
String tokenAppId) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.