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) |
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)
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 String[] getLocalDirs() throws IOException
IOException
public String[] getLocalDirsNoCreate()
public String getTokenUserName()
public String getTokenAppId()
public void setupUmbilicalUgi(String umbilicalUser, org.apache.hadoop.security.token.Token<org.apache.tez.common.security.JobTokenIdentifier> appToken, String amHost, int amPort)
public org.apache.hadoop.security.UserGroupInformation getUmbilicalUgi()
Copyright © 2021 The Apache Software Foundation. All rights reserved.