org.apache.drill.test

Class ProfileParser

java.lang.Object

org.apache.drill.test.ProfileParser

public class ProfileParser
extends Object

Parses a query profile and provides access to various bits of the profile for diagnostic purposes during tests.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ProfileParser.Aggregator
static class	ProfileParser.CostPrinter Print out the tree showing a comparison of estimated vs.
static class	ProfileParser.FindOpVisitor
static class	ProfileParser.FragInfo Information for a fragment, including the operators in that fragment and the set of minor fragments.
static class	ProfileParser.MinorFragInfo Information about a minor fragment as parsed from the profile.
static class	ProfileParser.OperatorProfile Detailed information about each operator within a minor fragment for a major fragment.
static class	ProfileParser.OperatorSummary Information about an operator definition: the plan-time information that appears in the plan portion of the profile.
static class	ProfileParser.TimePrinter
static class	ProfileParser.TreePrinter Print the operator tree for analysis.
static class	ProfileParser.TreeVisitor Visit a tree of operator definitions to support printing, analysis and other tasks.

Constructor Summary

Constructors

Constructor and Description
ProfileParser(File file)

Method Summary

Modifier and Type	Method and Description
void	buildTree() Reconstruct the operator tree from parsed information.
List<FieldDef>	getColumns(String plan)
JsonArray	getFragmentProfile()
List<ProfileParser.OperatorSummary>	getOpDefn(String target)
List<ProfileParser.OperatorSummary>	getOpDefsOfType(int type)
Map<Integer,String>	getOperators()
Map<Integer,ProfileParser.OperatorProfile>	getOpInfo() We often run test queries single threaded to make analysis of the profile easier.
List<ProfileParser.OperatorProfile>	getOpsOfType(int type) For a single-slice query, get all operators of a given numeric operator type.
String	getPlan()
List<String>	getPlans()
String	getQuery()
List<String>	getScans()
static long	percent(long value, long total)
void	print() For a single-slice query, print a summary of the operator stack and costs.
void	printPlan()
void	printTime()
void	simplePrint()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ProfileParser

public ProfileParser(File file)
              throws IOException

Throws:

IOException

Method Detail

buildTree

public void buildTree()

Reconstruct the operator tree from parsed information.

getQuery

public String getQuery()

getPlan

public String getPlan()

getPlans

public List<String> getPlans()

getScans

public List<String> getScans()

getColumns

public List<FieldDef> getColumns(String plan)

getOperators

public Map<Integer,String> getOperators()

getFragmentProfile

public JsonArray getFragmentProfile()

getOpInfo

public Map<Integer,ProfileParser.OperatorProfile> getOpInfo()

We often run test queries single threaded to make analysis of the profile easier. For a single-threaded (single slice) query, get a map from operator ID to operator information as preparation for additional analysis.

Returns:

getOpsOfType

public List<ProfileParser.OperatorProfile> getOpsOfType(int type)

For a single-slice query, get all operators of a given numeric operator type.

Parameters:

type - the operator type as specified in UserBitShared.CoreOperatorType

Returns:

a list of operators of the given type

getOpDefsOfType

public List<ProfileParser.OperatorSummary> getOpDefsOfType(int type)

printPlan

public void printPlan()

printTime

public void printTime()

print

public void print()

For a single-slice query, print a summary of the operator stack and costs. At present, works for a linear query with on single-input operators.

simplePrint

public void simplePrint()

percent

public static long percent(long value,
                           long total)

getOpDefn

public List<ProfileParser.OperatorSummary> getOpDefn(String target)