public class QueryInfo extends Object
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) |
Modifier and Type | Method and Description |
---|---|
String |
getAppIdString() |
int |
getDagIdentifier() |
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() |
String |
getUser() |
QueryFragmentInfo |
registerFragment(String vertexName,
int fragmentNumber,
int attemptNumber,
LlapDaemonProtocolProtos.SignableVertexSpec vertexSpec,
String fragmentIdString) |
void |
unregisterFragment(QueryFragmentInfo fragmentInfo) |
public 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)
public QueryIdentifier getQueryIdentifier()
public String getAppIdString()
public int getDagIdentifier()
public String getUser()
public ConcurrentMap<String,LlapDaemonProtocolProtos.SourceStateProto> getSourceStateMap()
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()
Copyright © 2016 The Apache Software Foundation. All rights reserved.