public class QueryInfo extends Object
Constructor and Description |
---|
QueryInfo(QueryIdentifier queryIdentifier,
String appIdString,
String dagIdString,
String dagName,
String hiveQueryIdString,
int dagIdentifier,
String user,
ConcurrentMap<String,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) |
Modifier and Type | Method and Description |
---|---|
LlapNodeId |
getAmNodeId() |
String |
getAppIdString() |
int |
getDagIdentifier() |
String |
getDagIdString() |
String |
getHiveQueryIdString() |
String[] |
getLocalDirs()
Get, and create if required, local-dirs for a query
|
String[] |
getLocalDirsNoCreate() |
QueryIdentifier |
getQueryIdentifier() |
List<QueryFragmentInfo> |
getRegisteredFragments() |
ConcurrentMap<String,LlapDaemonProtocolProtos.SourceStateProto> |
getSourceStateMap() |
String |
getTokenAppId() |
String |
getTokenUserName() |
org.apache.hadoop.security.UserGroupInformation |
getUmbilicalUgi() |
String |
getUser() |
boolean |
isExternalQuery() |
QueryFragmentInfo |
registerFragment(String vertexName,
int fragmentNumber,
int attemptNumber,
LlapDaemonProtocolProtos.SignableVertexSpec vertexSpec,
String fragmentIdString) |
void |
returnUmbilicalUgi(org.apache.hadoop.security.UserGroupInformation ugi) |
void |
unregisterFragment(QueryFragmentInfo fragmentInfo) |
public QueryInfo(QueryIdentifier queryIdentifier, String appIdString, String dagIdString, String dagName, String hiveQueryIdString, int dagIdentifier, String user, ConcurrentMap<String,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)
public QueryIdentifier getQueryIdentifier()
public String getAppIdString()
public String getDagIdString()
public String getHiveQueryIdString()
public int getDagIdentifier()
public String getUser()
public ConcurrentMap<String,LlapDaemonProtocolProtos.SourceStateProto> getSourceStateMap()
public LlapNodeId getAmNodeId()
public QueryFragmentInfo registerFragment(String vertexName, int fragmentNumber, int attemptNumber, LlapDaemonProtocolProtos.SignableVertexSpec vertexSpec, String fragmentIdString)
public void unregisterFragment(QueryFragmentInfo fragmentInfo)
public List<QueryFragmentInfo> getRegisteredFragments()
public boolean isExternalQuery()
public String[] getLocalDirs() throws IOException
IOException
public String[] getLocalDirsNoCreate()
public String getTokenUserName()
public String getTokenAppId()
public org.apache.hadoop.security.UserGroupInformation getUmbilicalUgi()
public void returnUmbilicalUgi(org.apache.hadoop.security.UserGroupInformation ugi)
Copyright © 2022 The Apache Software Foundation. All rights reserved.