public class QueryPlan
extends java.lang.Object
implements java.io.Serializable
Modifier and Type | Field and Description |
---|---|
protected LineageInfo |
linfo
Lineage information for the query.
|
Constructor and Description |
---|
QueryPlan() |
QueryPlan(java.lang.String queryString,
BaseSemanticAnalyzer sem,
java.lang.Long startTime) |
Modifier and Type | Method and Description |
---|---|
ColumnAccessInfo |
getColumnAccessInfo()
Gets the column access information.
|
java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.Long>> |
getCounters() |
java.util.Set<java.lang.String> |
getDone() |
FetchTask |
getFetchTask() |
java.util.HashMap<java.lang.String,java.lang.String> |
getIdToTableNameMap() |
java.util.HashSet<ReadEntity> |
getInputs() |
java.lang.String |
getJSONKeyValue(java.lang.Object key,
java.lang.Object value) |
java.lang.String |
getJSONMap(java.util.Map map) |
java.lang.String |
getJSONQuery(Query query) |
java.lang.String |
getJSONValue(java.lang.Object value) |
LineageInfo |
getLineageInfo()
Gets the lineage information.
|
java.util.HashSet<WriteEntity> |
getOutputs() |
Query |
getQuery() |
java.lang.String |
getQueryId() |
Query |
getQueryPlan() |
QueryProperties |
getQueryProperties() |
java.lang.Long |
getQueryStartTime() |
java.lang.String |
getQueryStr() |
java.lang.String |
getQueryString() |
java.util.List<ReducerTimeStatsPerJob> |
getReducerTimeStatsPerJobList() |
java.util.ArrayList<Task<? extends java.io.Serializable>> |
getRootTasks() |
java.util.Set<java.lang.String> |
getStarted() |
TableAccessInfo |
getTableAccessInfo()
Gets the table access information.
|
void |
setColumnAccessInfo(ColumnAccessInfo columnAccessInfo)
Sets the column access information.
|
void |
setDone() |
void |
setFetchTask(FetchTask fetchTask) |
void |
setIdToTableNameMap(java.util.HashMap<java.lang.String,java.lang.String> idToTableNameMap) |
void |
setInputs(java.util.HashSet<ReadEntity> inputs) |
void |
setLineageInfo(LineageInfo linfo)
Sets the lineage information.
|
void |
setOutputs(java.util.HashSet<WriteEntity> outputs) |
void |
setQuery(Query query) |
void |
setQueryId(java.lang.String queryId) |
void |
setQueryStartTime(java.lang.Long queryStartTime) |
void |
setQueryString(java.lang.String queryString) |
void |
setRootTasks(java.util.ArrayList<Task<? extends java.io.Serializable>> rootTasks) |
void |
setStarted() |
void |
setTableAccessInfo(TableAccessInfo tableAccessInfo)
Sets the table access information.
|
java.lang.String |
toBinaryString() |
java.lang.String |
toString() |
java.lang.String |
toThriftJSONString() |
protected LineageInfo linfo
public QueryPlan()
public QueryPlan(java.lang.String queryString, BaseSemanticAnalyzer sem, java.lang.Long startTime)
public java.lang.String getQueryStr()
public java.lang.String getQueryId()
public Query getQueryPlan() throws java.io.IOException
java.io.IOException
public java.lang.String getJSONValue(java.lang.Object value)
public java.lang.String getJSONKeyValue(java.lang.Object key, java.lang.Object value)
public java.lang.String getJSONMap(java.util.Map map)
public java.lang.String getJSONQuery(Query query)
public java.lang.String toString()
toString
in class java.lang.Object
public java.lang.String toThriftJSONString() throws java.io.IOException
java.io.IOException
public java.lang.String toBinaryString() throws java.io.IOException
java.io.IOException
public void setStarted()
public void setDone()
public java.util.Set<java.lang.String> getStarted()
public java.util.Set<java.lang.String> getDone()
public java.util.ArrayList<Task<? extends java.io.Serializable>> getRootTasks()
public void setRootTasks(java.util.ArrayList<Task<? extends java.io.Serializable>> rootTasks)
public FetchTask getFetchTask()
public void setFetchTask(FetchTask fetchTask)
public java.util.HashSet<ReadEntity> getInputs()
public void setInputs(java.util.HashSet<ReadEntity> inputs)
public java.util.HashSet<WriteEntity> getOutputs()
public void setOutputs(java.util.HashSet<WriteEntity> outputs)
public java.util.HashMap<java.lang.String,java.lang.String> getIdToTableNameMap()
public void setIdToTableNameMap(java.util.HashMap<java.lang.String,java.lang.String> idToTableNameMap)
public java.lang.String getQueryString()
public void setQueryString(java.lang.String queryString)
public Query getQuery()
public java.util.List<ReducerTimeStatsPerJob> getReducerTimeStatsPerJobList()
public void setQuery(Query query)
public java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.Long>> getCounters()
public void setQueryId(java.lang.String queryId)
public LineageInfo getLineageInfo()
public void setLineageInfo(LineageInfo linfo)
linfo
- The LineageInfo structure that is set in the optimization phase.public TableAccessInfo getTableAccessInfo()
public void setTableAccessInfo(TableAccessInfo tableAccessInfo)
taInfo
- The TableAccessInfo structure that is set right before the optimization phase.public ColumnAccessInfo getColumnAccessInfo()
public void setColumnAccessInfo(ColumnAccessInfo columnAccessInfo)
columnAccessInfo
- The ColumnAccessInfo structure that is set immediately after
the optimization phase.public QueryProperties getQueryProperties()
public java.lang.Long getQueryStartTime()
public void setQueryStartTime(java.lang.Long queryStartTime)
Copyright © 2012 The Apache Software Foundation