Package org.apache.drill.exec.expr

Class StatisticsProvider<T extends Comparable<T>>

java.lang.Object

org.apache.drill.common.expression.visitors.AbstractExprVisitor<ColumnStatistics<?>,Void,RuntimeException>

org.apache.drill.exec.expr.StatisticsProvider<T>

All Implemented Interfaces:

ExprVisitor<ColumnStatistics<?>,Void,RuntimeException>

public class StatisticsProvider<T extends Comparable<T>>
extends AbstractExprVisitor<ColumnStatistics<?>,Void,RuntimeException>

Constructor Summary

Constructors

Constructor	Description
StatisticsProvider(Map<SchemaPath,ColumnStatistics<?>> columnStatMap, long rowCount, UdfUtilities udfUtilities)

Method Summary

Modifier and Type	Method	Description
static <V> ColumnStatistics<V>	getColumnStatistics(V minVal, V maxVal, long nullsCount, TypeProtos.MinorType type)	Returns ColumnStatistics instance with set min, max values and nulls count statistics specified in the arguments.
static <V> ColumnStatistics<V>	getConstantColumnStatistics(V minMaxValue, LogicalExpression expr)	Returns ColumnStatistics instance with min and max values set to minMaxValue and nulls count set to 0.
static <V> ColumnStatistics<V>	getConstantColumnStatistics(V minMaxValue, TypeProtos.MinorType type)	Returns ColumnStatistics instance with min and max values set to minMaxValue and nulls count set to 0.
long	getRowCount()
ColumnStatistics<Boolean>	visitBooleanConstant(ValueExpressions.BooleanExpression expr, Void value)
ColumnStatistics<Long>	visitDateConstant(ValueExpressions.DateExpression expr, Void value)
ColumnStatistics<Double>	visitDoubleConstant(ValueExpressions.DoubleExpression expr, Void value)
ColumnStatistics<Float>	visitFloatConstant(ValueExpressions.FloatExpression expr, Void value)
ColumnStatistics<?>	visitFunctionHolderExpression(FunctionHolderExpression holderExpr, Void value)
ColumnStatistics<Integer>	visitIntConstant(ValueExpressions.IntExpression expr, Void value)
ColumnStatistics<Long>	visitLongConstant(ValueExpressions.LongExpression expr, Void value)
ColumnStatistics<String>	visitQuotedStringConstant(ValueExpressions.QuotedString expr, Void value)
ColumnStatistics<Integer>	visitTimeConstant(ValueExpressions.TimeExpression expr, Void value)
ColumnStatistics<Long>	visitTimeStampConstant(ValueExpressions.TimeStampExpression expr, Void value)
ColumnStatistics<?>	visitTypedFieldExpr(TypedFieldExpr typedFieldExpr, Void value)
ColumnStatistics<?>	visitUnknown(LogicalExpression e, Void value)	Handles implementation-specific expressions not known to the visitor structure.
ColumnStatistics<BigInteger>	visitVarDecimalConstant(ValueExpressions.VarDecimalExpression expr, Void value)

Methods inherited from class org.apache.drill.common.expression.visitors.AbstractExprVisitor

visitAnyValueExpression, visitBooleanOperator, visitCastExpression, visitConvertExpression, visitDecimal18Constant, visitDecimal28Constant, visitDecimal38Constant, visitDecimal9Constant, visitFunctionCall, visitIfExpression, visitIntervalDayConstant, visitIntervalYearConstant, visitNullConstant, visitNullExpression, visitParameter, visitSchemaPath

Methods inherited from class java.lang.Object

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

Constructor Details

StatisticsProvider

public StatisticsProvider(Map<SchemaPath,ColumnStatistics<?>> columnStatMap,
 long rowCount,
 UdfUtilities udfUtilities)

Method Details

getRowCount

public long getRowCount()

visitUnknown

public ColumnStatistics<?> visitUnknown(LogicalExpression e,
 Void value)

Description copied from class: AbstractExprVisitor

Handles implementation-specific expressions not known to the visitor structure. Since there are no "visitFoo" methods for these "unknown" expressions, subclassses should use the functionally-equivalent instanceof approach to parse out these "unknown" expressions.

Specified by:

visitUnknown in interface ExprVisitor<ColumnStatistics<?>,Void,RuntimeException>

Overrides:

visitUnknown in class AbstractExprVisitor<ColumnStatistics<?>,Void,RuntimeException>

visitTypedFieldExpr

public ColumnStatistics<?> visitTypedFieldExpr(TypedFieldExpr typedFieldExpr,
 Void value)

Specified by:

visitTypedFieldExpr in interface ExprVisitor<ColumnStatistics<?>,Void,RuntimeException>

Overrides:

visitTypedFieldExpr in class AbstractExprVisitor<ColumnStatistics<?>,Void,RuntimeException>

visitIntConstant

public ColumnStatistics<Integer> visitIntConstant(ValueExpressions.IntExpression expr,
 Void value)

Specified by:

visitIntConstant in interface ExprVisitor<ColumnStatistics<?>,Void,RuntimeException>

Overrides:

visitIntConstant in class AbstractExprVisitor<ColumnStatistics<?>,Void,RuntimeException>

visitBooleanConstant

public ColumnStatistics<Boolean> visitBooleanConstant(ValueExpressions.BooleanExpression expr,
 Void value)

Specified by:

visitBooleanConstant in interface ExprVisitor<ColumnStatistics<?>,Void,RuntimeException>

Overrides:

visitBooleanConstant in class AbstractExprVisitor<ColumnStatistics<?>,Void,RuntimeException>

visitLongConstant

public ColumnStatistics<Long> visitLongConstant(ValueExpressions.LongExpression expr,
 Void value)

Specified by:

visitLongConstant in interface ExprVisitor<ColumnStatistics<?>,Void,RuntimeException>

Overrides:

visitLongConstant in class AbstractExprVisitor<ColumnStatistics<?>,Void,RuntimeException>

visitFloatConstant

public ColumnStatistics<Float> visitFloatConstant(ValueExpressions.FloatExpression expr,
 Void value)

Specified by:

visitFloatConstant in interface ExprVisitor<ColumnStatistics<?>,Void,RuntimeException>

Overrides:

visitFloatConstant in class AbstractExprVisitor<ColumnStatistics<?>,Void,RuntimeException>

visitDoubleConstant

public ColumnStatistics<Double> visitDoubleConstant(ValueExpressions.DoubleExpression expr,
 Void value)

Specified by:

visitDoubleConstant in interface ExprVisitor<ColumnStatistics<?>,Void,RuntimeException>

Overrides:

visitDoubleConstant in class AbstractExprVisitor<ColumnStatistics<?>,Void,RuntimeException>

visitDateConstant

public ColumnStatistics<Long> visitDateConstant(ValueExpressions.DateExpression expr,
 Void value)

Specified by:

visitDateConstant in interface ExprVisitor<ColumnStatistics<?>,Void,RuntimeException>

Overrides:

visitDateConstant in class AbstractExprVisitor<ColumnStatistics<?>,Void,RuntimeException>

visitTimeStampConstant

public ColumnStatistics<Long> visitTimeStampConstant(ValueExpressions.TimeStampExpression expr,
 Void value)

Specified by:

visitTimeStampConstant in interface ExprVisitor<ColumnStatistics<?>,Void,RuntimeException>

Overrides:

visitTimeStampConstant in class AbstractExprVisitor<ColumnStatistics<?>,Void,RuntimeException>

visitTimeConstant

public ColumnStatistics<Integer> visitTimeConstant(ValueExpressions.TimeExpression expr,
 Void value)

Specified by:

visitTimeConstant in interface ExprVisitor<ColumnStatistics<?>,Void,RuntimeException>

Overrides:

visitTimeConstant in class AbstractExprVisitor<ColumnStatistics<?>,Void,RuntimeException>

visitQuotedStringConstant

public ColumnStatistics<String> visitQuotedStringConstant(ValueExpressions.QuotedString expr,
 Void value)

Specified by:

visitQuotedStringConstant in interface ExprVisitor<ColumnStatistics<?>,Void,RuntimeException>

Overrides:

visitQuotedStringConstant in class AbstractExprVisitor<ColumnStatistics<?>,Void,RuntimeException>

visitVarDecimalConstant

public ColumnStatistics<BigInteger> visitVarDecimalConstant(ValueExpressions.VarDecimalExpression expr,
 Void value)

Specified by:

visitVarDecimalConstant in interface ExprVisitor<ColumnStatistics<?>,Void,RuntimeException>

Overrides:

visitVarDecimalConstant in class AbstractExprVisitor<ColumnStatistics<?>,Void,RuntimeException>

visitFunctionHolderExpression

public ColumnStatistics<?> visitFunctionHolderExpression(FunctionHolderExpression holderExpr,
 Void value)

Specified by:

visitFunctionHolderExpression in interface ExprVisitor<ColumnStatistics<?>,Void,RuntimeException>

Overrides:

visitFunctionHolderExpression in class AbstractExprVisitor<ColumnStatistics<?>,Void,RuntimeException>

getColumnStatistics

public static <V> ColumnStatistics<V> getColumnStatistics(V minVal,
 V maxVal,
 long nullsCount,
 TypeProtos.MinorType type)

Returns ColumnStatistics instance with set min, max values and nulls count statistics specified in the arguments.

Type Parameters:

V - type of min and max values

Parameters:

minVal - min value

maxVal - max value

nullsCount - nulls count

type - type of the column

Returns:

ColumnStatistics instance with set min, max values and nulls count statistics

getConstantColumnStatistics

public static <V> ColumnStatistics<V> getConstantColumnStatistics(V minMaxValue,
 LogicalExpression expr)

Returns ColumnStatistics instance with min and max values set to minMaxValue and nulls count set to 0. Resulting ColumnStatistics instance corresponds to a constant value, so nulls count is set to 0.

Type Parameters:

V - type of min and max values

Parameters:

minMaxValue - value of min and max statistics

expr - source of column type

Returns:

ColumnStatistics instance with min and max values set to minMaxValue and nulls count set to 0

getConstantColumnStatistics

public static <V> ColumnStatistics<V> getConstantColumnStatistics(V minMaxValue,
 TypeProtos.MinorType type)

Returns ColumnStatistics instance with min and max values set to minMaxValue and nulls count set to 0. Resulting ColumnStatistics instance corresponds to a constant value, so nulls count is set to 0.

Type Parameters:

V - type of min and max values

Parameters:

minMaxValue - value of min and max statistics

type - column type

Returns:

ColumnStatistics instance with min and max values set to minMaxValue and nulls count set to 0