Uses of Interface
org.apache.drill.common.expression.LogicalExpression
Package
Description
Logical expression tree representation.
Logical function definitions.
Visitors for validating or optimizing logical expressions.
Logical operators in a query graph.
TODO - write docs for this package
Drill expression materialization and evaluation facilities.
Kafka storage plugin.
MongoDB storage plugin.
-
Uses of LogicalExpression in org.apache.drill.common.expression
Modifier and TypeClassDescriptionclass
class
class
class
class
class
class
Represents an actual call (a reference) to a declared function.class
class
class
MajorTypeInLogicalExpression is a LogicalExpression, which wraps a given @{TypeProtos.MajorType}class
class
This is the path for the column in the tableclass
class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
Identifies method parameter based on given name and type.static class
static class
static class
protected static class
static class
Modifier and TypeFieldDescriptionfinal LogicalExpression
IfExpression.IfCondition.condition
final LogicalExpression
IfExpression.elseExpression
final LogicalExpression
IfExpression.IfCondition.expression
Modifier and TypeFieldDescriptionprotected final org.apache.drill.shaded.guava.com.google.common.collect.ImmutableList<LogicalExpression>
FunctionCall.args
final org.apache.drill.shaded.guava.com.google.common.collect.ImmutableList<LogicalExpression>
FunctionHolderExpression.args
Modifier and TypeMethodDescriptionFunctionCall.arg
(int i) static LogicalExpression
ExpressionFunction.create
(String functionName, List<LogicalExpression> expressions) static LogicalExpression
FunctionCallFactory.createAnyValue
(String functionName, List<LogicalExpression> args) static LogicalExpression
FunctionCallFactory.createAnyValue
(ExpressionPosition ep, LogicalExpression expr) static LogicalExpression
FunctionCallFactory.createBooleanOperator
(String functionName, List<LogicalExpression> args) static LogicalExpression
FunctionCallFactory.createBooleanOperator
(String functionName, ExpressionPosition ep, List<LogicalExpression> args) static LogicalExpression
FunctionCallFactory.createByOp
(List<LogicalExpression> args, ExpressionPosition ep, List<String> opTypes) static LogicalExpression
FunctionCallFactory.createCast
(TypeProtos.MajorType type, ExpressionPosition ep, LogicalExpression expr) static LogicalExpression
FunctionCallFactory.createConvert
(String function, String conversionType, LogicalExpression expr, ExpressionPosition ep) static LogicalExpression
FunctionCallFactory.createExpression
(String functionName, List<LogicalExpression> args) static LogicalExpression
FunctionCallFactory.createExpression
(String functionName, ExpressionPosition ep, List<LogicalExpression> args) static LogicalExpression
FunctionCallFactory.createExpression
(String functionName, ExpressionPosition ep, LogicalExpression... e) LogicalExpression.De.deserialize
(com.fasterxml.jackson.core.JsonParser jp, com.fasterxml.jackson.databind.DeserializationContext ctxt) static LogicalExpression
ValueExpressions.getBigInt
(long l) static LogicalExpression
ValueExpressions.getBit
(boolean b) static LogicalExpression
static LogicalExpression
ValueExpressions.getDate
(long milliSecond) static LogicalExpression
ValueExpressions.getDate
(GregorianCalendar date) static LogicalExpression
ValueExpressions.getFloat4
(float f) static LogicalExpression
ValueExpressions.getFloat8
(double d) AnyValueExpression.getInput()
CastExpression.getInput()
ConvertExpression.getInput()
static LogicalExpression
ValueExpressions.getInt
(int i) static LogicalExpression
ValueExpressions.getIntervalDay
(long intervalInMillis) static LogicalExpression
ValueExpressions.getIntervalYear
(int months) static LogicalExpression
ValueExpressions.getNumericExpression
(String sign, String s, ExpressionPosition ep) static LogicalExpression
ValueExpressions.getParameterExpression
(String name, TypeProtos.MajorType type) static LogicalExpression
ValueExpressions.getTime
(int milliSeconds) static LogicalExpression
ValueExpressions.getTime
(GregorianCalendar time) static LogicalExpression
ValueExpressions.getTimeStamp
(long milliSeconds) static LogicalExpression
ValueExpressions.getTimeStamp
(GregorianCalendar date) static LogicalExpression
ValueExpressions.getVarDecimal
(BigDecimal input, int precision, int scale) Modifier and TypeMethodDescriptionFunctionCall.args()
AnyValueExpression.iterator()
CastExpression.iterator()
ConvertExpression.iterator()
FunctionCall.iterator()
IfExpression.iterator()
MajorTypeInLogicalExpression.iterator()
NullExpression.iterator()
SchemaPath.iterator()
TypedFieldExpr.iterator()
TypedNullConstant.iterator()
ValueExpressions.DateExpression.iterator()
ValueExpressions.Decimal18Expression.iterator()
ValueExpressions.Decimal28Expression.iterator()
ValueExpressions.Decimal38Expression.iterator()
ValueExpressions.Decimal9Expression.iterator()
ValueExpressions.DoubleExpression.iterator()
ValueExpressions.FloatExpression.iterator()
ValueExpressions.IntervalDayExpression.iterator()
ValueExpressions.IntervalYearExpression.iterator()
ValueExpressions.IntExpression.iterator()
ValueExpressions.LongExpression.iterator()
ValueExpressions.ParameterExpression.iterator()
ValueExpressions.TimeExpression.iterator()
ValueExpressions.TimeStampExpression.iterator()
ValueExpressions.ValueExpression.iterator()
ValueExpressions.VarDecimalExpression.iterator()
Modifier and TypeMethodDescriptionstatic LogicalExpression
FunctionCallFactory.createAnyValue
(ExpressionPosition ep, LogicalExpression expr) static LogicalExpression
FunctionCallFactory.createCast
(TypeProtos.MajorType type, ExpressionPosition ep, LogicalExpression expr) static LogicalExpression
FunctionCallFactory.createConvert
(String function, String conversionType, LogicalExpression expr, ExpressionPosition ep) static LogicalExpression
FunctionCallFactory.createExpression
(String functionName, ExpressionPosition ep, LogicalExpression... e) void
LogicalExpression.Se.serialize
(LogicalExpression value, com.fasterxml.jackson.core.JsonGenerator jgen, com.fasterxml.jackson.databind.SerializerProvider provider) IfExpression.Builder.setElse
(LogicalExpression elseExpression) static String
ExpressionStringBuilder.toString
(LogicalExpression expr) static void
ExpressionStringBuilder.toString
(LogicalExpression expr, StringBuilder sb) ExpressionStringBuilder.visitUnknown
(LogicalExpression e, StringBuilder sb) Modifier and TypeMethodDescriptionabstract FunctionHolderExpression
FunctionHolderExpression.copy
(List<LogicalExpression> args) static LogicalExpression
ExpressionFunction.create
(String functionName, List<LogicalExpression> expressions) static LogicalExpression
FunctionCallFactory.createAnyValue
(String functionName, List<LogicalExpression> args) static LogicalExpression
FunctionCallFactory.createBooleanOperator
(String functionName, List<LogicalExpression> args) static LogicalExpression
FunctionCallFactory.createBooleanOperator
(String functionName, ExpressionPosition ep, List<LogicalExpression> args) static LogicalExpression
FunctionCallFactory.createByOp
(List<LogicalExpression> args, ExpressionPosition ep, List<String> opTypes) static LogicalExpression
FunctionCallFactory.createExpression
(String functionName, List<LogicalExpression> args) static LogicalExpression
FunctionCallFactory.createExpression
(String functionName, ExpressionPosition ep, List<LogicalExpression> args) OutputTypeDeterminer.FixedType.getOutputType
(List<LogicalExpression> expressions) OutputTypeDeterminer.getOutputType
(List<LogicalExpression> expressions) OutputTypeDeterminer.NullIfNullType.getOutputType
(List<LogicalExpression> expressions) OutputTypeDeterminer.SameAsAnySoft.getOutputType
(List<LogicalExpression> expressions) OutputTypeDeterminer.SameAsFirstInput.getOutputType
(List<LogicalExpression> expressions) ModifierConstructorDescriptionAnyValueExpression
(LogicalExpression input, ExpressionPosition pos) CastExpression
(LogicalExpression input, TypeProtos.MajorType type, ExpressionPosition pos) ConvertExpression
(String convertFunction, String encodingType, LogicalExpression input, ExpressionPosition pos) IfCondition
(LogicalExpression condition, LogicalExpression expression) ModifierConstructorDescriptionBooleanOperator
(String name, List<LogicalExpression> args, ExpressionPosition pos) FunctionCall
(String name, List<LogicalExpression> args, ExpressionPosition pos) FunctionHolderExpression
(String nameUsed, ExpressionPosition pos, List<LogicalExpression> args) -
Uses of LogicalExpression in org.apache.drill.common.expression.fn
Modifier and TypeMethodDescriptionFuncHolder.getExpr
(String name, List<LogicalExpression> args, ExpressionPosition pos) Return a reference to this function given a function alias and a list of actual arguments. -
Uses of LogicalExpression in org.apache.drill.common.expression.parser
Modifier and TypeFieldDescriptionExprParser.AddExprContext.e
ExprParser.AndExprContext.e
ExprParser.AnyValueCallContext.e
ExprParser.AtomContext.e
ExprParser.CaseElseStatContext.e
ExprParser.CaseStatementContext.e
ExprParser.CastCallContext.e
ExprParser.CondExprContext.e
ExprParser.ConvertCallContext.e
ExprParser.EquExprContext.e
ExprParser.ExpressionContext.e
ExprParser.FunctionCallContext.e
ExprParser.IfStatementContext.e
ExprParser.LookupContext.e
ExprParser.MulExprContext.e
ExprParser.OrExprContext.e
ExprParser.ParseContext.e
ExprParser.RelExprContext.e
ExprParser.UnaryExprContext.e
ExprParser.XorExprContext.e
-
Uses of LogicalExpression in org.apache.drill.common.expression.visitors
Modifier and TypeMethodDescriptionConditionalExprOptimizer.visitAnyValueExpression
(AnyValueExpression cast, Void value) ConditionalExprOptimizer.visitBooleanOperator
(BooleanOperator op, Void value) ConditionalExprOptimizer.visitCastExpression
(CastExpression cast, Void value) ConditionalExprOptimizer.visitConvertExpression
(ConvertExpression cast, Void value) ConditionalExprOptimizer.visitFunctionCall
(FunctionCall call, Void value) ConditionalExprOptimizer.visitFunctionHolderExpression
(FunctionHolderExpression holder, Void value) ConditionalExprOptimizer.visitIfExpression
(IfExpression ifExpr, Void value) ConditionalExprOptimizer.visitUnknown
(LogicalExpression e, Void value) Modifier and TypeMethodDescriptionstatic boolean
AggregateChecker.isAggregating
(LogicalExpression e, ErrorCollector errors) AbstractExprVisitor.visitUnknown
(LogicalExpression e, VAL value) Handles implementation-specific expressions not known to the visitor structure.AggregateChecker.visitUnknown
(LogicalExpression e, ErrorCollector errors) ConditionalExprOptimizer.visitUnknown
(LogicalExpression e, Void value) ExpressionValidator.visitUnknown
(LogicalExpression e, ErrorCollector value) ExprVisitor.visitUnknown
(LogicalExpression e, VAL value) -
Uses of LogicalExpression in org.apache.drill.common.logical.data
Modifier and TypeMethodDescriptionFilter.getExpr()
Flatten.getExpr()
NamedExpression.getExpr()
Order.Ordering.getExpr()
JoinCondition.getLeft()
JoinCondition.getRight()
Modifier and TypeMethodDescriptionWindow.Builder.addAggregation
(FieldReference ref, LogicalExpression expr) Join.Builder.addCondition
(String relationship, LogicalExpression left, LogicalExpression right) GroupingAggregate.Builder.addExpr
(FieldReference ref, LogicalExpression expr) Project.Builder.addExpr
(FieldReference ref, LogicalExpression expr) GroupingAggregate.Builder.addKey
(FieldReference ref, LogicalExpression expr) Order.Builder.addOrdering
(org.apache.calcite.rel.RelFieldCollation.Direction direction, LogicalExpression e, org.apache.calcite.rel.RelFieldCollation.NullDirection collation) Window.Builder.addWithin
(FieldReference within, LogicalExpression expr) ModifierConstructorDescriptionFilter
(LogicalExpression expr) Flatten
(FieldReference name, LogicalExpression expr, boolean drop) JoinCondition
(String relationship, LogicalExpression left, LogicalExpression right) NamedExpression
(LogicalExpression expr, FieldReference ref) Ordering
(String strOrderingSpec, LogicalExpression expr, String strNullOrdering) Constructs a sort specification.Ordering
(org.apache.calcite.rel.RelFieldCollation.Direction direction, LogicalExpression e) Ordering
(org.apache.calcite.rel.RelFieldCollation.Direction direction, LogicalExpression e, org.apache.calcite.rel.RelFieldCollation.NullDirection nullOrdering) -
Uses of LogicalExpression in org.apache.drill.common.parser
Modifier and TypeMethodDescriptionstatic LogicalExpression
Initializes logical expression lexer and parser, add error listener that converts all syntax error intoExpressionParsingException
. -
Uses of LogicalExpression in org.apache.drill.exec.compile.sig
Modifier and TypeMethodDescriptionstatic Set<LogicalExpression>
ConstantExpressionIdentifier.getConstantExpressionSet
(LogicalExpression e) Get a list of expressions that mark boundaries into a constant space.Modifier and TypeMethodDescriptionstatic Set<LogicalExpression>
ConstantExpressionIdentifier.getConstantExpressionSet
(LogicalExpression e) Get a list of expressions that mark boundaries into a constant space.ConstantExpressionIdentifier.visitUnknown
(LogicalExpression e, IdentityHashMap<LogicalExpression, Object> value) Modifier and TypeMethodDescriptionConstantExpressionIdentifier.visitAnyValueExpression
(AnyValueExpression e, IdentityHashMap<LogicalExpression, Object> value) ConstantExpressionIdentifier.visitBooleanConstant
(ValueExpressions.BooleanExpression e, IdentityHashMap<LogicalExpression, Object> value) ConstantExpressionIdentifier.visitBooleanOperator
(BooleanOperator op, IdentityHashMap<LogicalExpression, Object> value) ConstantExpressionIdentifier.visitCastExpression
(CastExpression e, IdentityHashMap<LogicalExpression, Object> value) ConstantExpressionIdentifier.visitConvertExpression
(ConvertExpression e, IdentityHashMap<LogicalExpression, Object> value) ConstantExpressionIdentifier.visitDateConstant
(ValueExpressions.DateExpression intExpr, IdentityHashMap<LogicalExpression, Object> value) ConstantExpressionIdentifier.visitDecimal18Constant
(ValueExpressions.Decimal18Expression decExpr, IdentityHashMap<LogicalExpression, Object> value) ConstantExpressionIdentifier.visitDecimal28Constant
(ValueExpressions.Decimal28Expression decExpr, IdentityHashMap<LogicalExpression, Object> value) ConstantExpressionIdentifier.visitDecimal38Constant
(ValueExpressions.Decimal38Expression decExpr, IdentityHashMap<LogicalExpression, Object> value) ConstantExpressionIdentifier.visitDecimal9Constant
(ValueExpressions.Decimal9Expression decExpr, IdentityHashMap<LogicalExpression, Object> value) ConstantExpressionIdentifier.visitDoubleConstant
(ValueExpressions.DoubleExpression dExpr, IdentityHashMap<LogicalExpression, Object> value) ConstantExpressionIdentifier.visitFloatConstant
(ValueExpressions.FloatExpression fExpr, IdentityHashMap<LogicalExpression, Object> value) ConstantExpressionIdentifier.visitFunctionCall
(FunctionCall call, IdentityHashMap<LogicalExpression, Object> value) ConstantExpressionIdentifier.visitFunctionHolderExpression
(FunctionHolderExpression holder, IdentityHashMap<LogicalExpression, Object> value) ConstantExpressionIdentifier.visitIfExpression
(IfExpression ifExpr, IdentityHashMap<LogicalExpression, Object> value) ConstantExpressionIdentifier.visitIntConstant
(ValueExpressions.IntExpression intExpr, IdentityHashMap<LogicalExpression, Object> value) ConstantExpressionIdentifier.visitIntervalDayConstant
(ValueExpressions.IntervalDayExpression intExpr, IdentityHashMap<LogicalExpression, Object> value) ConstantExpressionIdentifier.visitIntervalYearConstant
(ValueExpressions.IntervalYearExpression intExpr, IdentityHashMap<LogicalExpression, Object> value) ConstantExpressionIdentifier.visitLongConstant
(ValueExpressions.LongExpression intExpr, IdentityHashMap<LogicalExpression, Object> value) ConstantExpressionIdentifier.visitNullConstant
(TypedNullConstant e, IdentityHashMap<LogicalExpression, Object> value) ConstantExpressionIdentifier.visitNullExpression
(NullExpression e, IdentityHashMap<LogicalExpression, Object> value) ConstantExpressionIdentifier.visitParameter
(ValueExpressions.ParameterExpression e, IdentityHashMap<LogicalExpression, Object> value) ConstantExpressionIdentifier.visitQuotedStringConstant
(ValueExpressions.QuotedString e, IdentityHashMap<LogicalExpression, Object> value) ConstantExpressionIdentifier.visitSchemaPath
(SchemaPath path, IdentityHashMap<LogicalExpression, Object> value) ConstantExpressionIdentifier.visitTimeConstant
(ValueExpressions.TimeExpression intExpr, IdentityHashMap<LogicalExpression, Object> value) ConstantExpressionIdentifier.visitTimeStampConstant
(ValueExpressions.TimeStampExpression intExpr, IdentityHashMap<LogicalExpression, Object> value) ConstantExpressionIdentifier.visitTypedFieldExpr
(TypedFieldExpr e, IdentityHashMap<LogicalExpression, Object> value) ConstantExpressionIdentifier.visitUnknown
(LogicalExpression e, IdentityHashMap<LogicalExpression, Object> value) ConstantExpressionIdentifier.visitVarDecimalConstant
(ValueExpressions.VarDecimalExpression decExpr, IdentityHashMap<LogicalExpression, Object> value) -
Uses of LogicalExpression in org.apache.drill.exec.expr
Modifier and TypeClassDescriptionclass
BooleanPredicate<C extends Comparable<C>>
class
ComparisonPredicate<C extends Comparable<C>>
Comparison predicates for metadata filter pushdown.class
Represents the call of a function within a query and includes the actual arguments and a reference to the function declaration (as a "function holder.")class
class
Wrapper around a representation of a "Holder" to represent that Holder as an expression.class
IsPredicate<C extends Comparable<C>>
class
Wraps a value vector field to be read, providing metadata about the field.class
Modifier and TypeMethodDescriptionstatic LogicalExpression
ExpressionTreeMaterializer.addCastExpression
(LogicalExpression fromExpr, TypeProtos.MajorType toType, FunctionLookupContext functionLookupContext, ErrorCollector errorCollector) static LogicalExpression
ExpressionTreeMaterializer.addCastExpression
(LogicalExpression fromExpr, TypeProtos.MajorType toType, FunctionLookupContext functionLookupContext, ErrorCollector errorCollector, boolean exactResolver) static LogicalExpression
ExpressionTreeMaterializer.convertToNullableType
(LogicalExpression fromExpr, TypeProtos.MinorType toType, FunctionLookupContext functionLookupContext, ErrorCollector errorCollector) static <C extends Comparable<C>>
LogicalExpressionBooleanPredicate.createBooleanPredicate
(String function, String name, List<LogicalExpression> args, ExpressionPosition pos) static <C extends Comparable<C>>
LogicalExpressionComparisonPredicate.createComparisonPredicate
(String function, LogicalExpression left, LogicalExpression right) static <C extends Comparable<C>>
LogicalExpressionIsPredicate.createIsPredicate
(String function, LogicalExpression expr) ValueVectorWriteExpression.getChild()
static LogicalExpression
ExpressionTreeMaterializer.materialize
(LogicalExpression expr, Map<VectorAccessible, BatchReference> batches, ErrorCollector errorCollector, FunctionLookupContext functionLookupContext, boolean allowComplexWriterExpr, boolean unionTypeEnabled) Materializes logical expression taking into account passed parameters.static LogicalExpression
ExpressionTreeMaterializer.materialize
(LogicalExpression expr, VectorAccessible batch, ErrorCollector errorCollector, FunctionLookupContext functionLookupContext) static LogicalExpression
ExpressionTreeMaterializer.materialize
(LogicalExpression expr, VectorAccessible batch, ErrorCollector errorCollector, FunctionLookupContext functionLookupContext, boolean allowComplexWriterExpr) static LogicalExpression
ExpressionTreeMaterializer.materialize
(LogicalExpression expr, VectorAccessible batch, ErrorCollector errorCollector, FunctionLookupContext functionLookupContext, boolean allowComplexWriterExpr, boolean unionTypeEnabled) Materializes logical expression taking into account passed parameters.static LogicalExpression
ExpressionTreeMaterializer.materializeAndCheckErrors
(LogicalExpression expr, VectorAccessible batch, FunctionLookupContext functionLookupContext) static LogicalExpression
ExpressionTreeMaterializer.materializeFilterExpr
(LogicalExpression expr, TupleMetadata fieldTypes, ErrorCollector errorCollector, FunctionLookupContext functionLookupContext) CloneVisitor.visitBooleanConstant
(ValueExpressions.BooleanExpression e, Void value) FilterBuilder.visitBooleanConstant
(ValueExpressions.BooleanExpression booleanExpression, Set<LogicalExpression> value) CloneVisitor.visitBooleanOperator
(BooleanOperator op, Void value) FilterBuilder.visitBooleanOperator
(BooleanOperator op, Set<LogicalExpression> value) CloneVisitor.visitCastExpression
(CastExpression e, Void value) CloneVisitor.visitConvertExpression
(ConvertExpression e, Void value) CloneVisitor.visitDateConstant
(ValueExpressions.DateExpression intExpr, Void value) FilterBuilder.visitDateConstant
(ValueExpressions.DateExpression dateExpr, Set<LogicalExpression> value) CloneVisitor.visitDecimal18Constant
(ValueExpressions.Decimal18Expression decExpr, Void value) CloneVisitor.visitDecimal28Constant
(ValueExpressions.Decimal28Expression decExpr, Void value) CloneVisitor.visitDecimal38Constant
(ValueExpressions.Decimal38Expression decExpr, Void value) CloneVisitor.visitDecimal9Constant
(ValueExpressions.Decimal9Expression decExpr, Void value) CloneVisitor.visitDoubleConstant
(ValueExpressions.DoubleExpression dExpr, Void value) FilterBuilder.visitDoubleConstant
(ValueExpressions.DoubleExpression dExpr, Set<LogicalExpression> value) CloneVisitor.visitFloatConstant
(ValueExpressions.FloatExpression fExpr, Void value) FilterBuilder.visitFloatConstant
(ValueExpressions.FloatExpression fExpr, Set<LogicalExpression> value) CloneVisitor.visitFunctionCall
(FunctionCall call, Void value) CloneVisitor.visitFunctionHolderExpression
(FunctionHolderExpression holder, Void value) FilterBuilder.visitFunctionHolderExpression
(FunctionHolderExpression funcHolderExpr, Set<LogicalExpression> value) CloneVisitor.visitIfExpression
(IfExpression ifExpr, Void value) CloneVisitor.visitIntConstant
(ValueExpressions.IntExpression intExpr, Void value) FilterBuilder.visitIntConstant
(ValueExpressions.IntExpression intExpr, Set<LogicalExpression> value) CloneVisitor.visitIntervalDayConstant
(ValueExpressions.IntervalDayExpression intExpr, Void value) CloneVisitor.visitIntervalYearConstant
(ValueExpressions.IntervalYearExpression intExpr, Void value) CloneVisitor.visitLongConstant
(ValueExpressions.LongExpression intExpr, Void value) FilterBuilder.visitLongConstant
(ValueExpressions.LongExpression intExpr, Set<LogicalExpression> value) CloneVisitor.visitNullConstant
(TypedNullConstant e, Void value) CloneVisitor.visitNullExpression
(NullExpression e, Void value) CloneVisitor.visitQuotedStringConstant
(ValueExpressions.QuotedString e, Void value) FilterBuilder.visitQuotedStringConstant
(ValueExpressions.QuotedString quotedString, Set<LogicalExpression> value) CloneVisitor.visitSchemaPath
(SchemaPath path, Void value) CloneVisitor.visitTimeConstant
(ValueExpressions.TimeExpression intExpr, Void value) FilterBuilder.visitTimeConstant
(ValueExpressions.TimeExpression timeExpr, Set<LogicalExpression> value) CloneVisitor.visitTimeStampConstant
(ValueExpressions.TimeStampExpression intExpr, Void value) FilterBuilder.visitTimeStampConstant
(ValueExpressions.TimeStampExpression tsExpr, Set<LogicalExpression> value) FilterBuilder.visitTypedFieldExpr
(TypedFieldExpr typedFieldExpr, Set<LogicalExpression> value) CloneVisitor.visitUnknown
(LogicalExpression e, Void value) FilterBuilder.visitUnknown
(LogicalExpression e, Set<LogicalExpression> value) CloneVisitor.visitVarDecimalConstant
(ValueExpressions.VarDecimalExpression decExpr, Void value) FilterBuilder.visitVarDecimalConstant
(ValueExpressions.VarDecimalExpression decExpr, Set<LogicalExpression> value) Modifier and TypeMethodDescriptionComparisonPredicate.iterator()
DrillFuncHolderExpr.iterator()
HiveFuncHolderExpr.iterator()
HoldingContainerExpression.iterator()
IsPredicate.iterator()
ValueVectorReadExpression.iterator()
ValueVectorWriteExpression.iterator()
Modifier and TypeMethodDescriptionstatic LogicalExpression
ExpressionTreeMaterializer.addCastExpression
(LogicalExpression fromExpr, TypeProtos.MajorType toType, FunctionLookupContext functionLookupContext, ErrorCollector errorCollector) static LogicalExpression
ExpressionTreeMaterializer.addCastExpression
(LogicalExpression fromExpr, TypeProtos.MajorType toType, FunctionLookupContext functionLookupContext, ErrorCollector errorCollector, boolean exactResolver) ClassGenerator.addExpr
(LogicalExpression ex) ClassGenerator.addExpr
(LogicalExpression ex, ClassGenerator.BlkCreateMode mode) EvaluationVisitor.addExpr
(LogicalExpression e, ClassGenerator<?> generator) static FilterPredicate<?>
FilterBuilder.buildFilterPredicate
(LogicalExpression expr, Set<LogicalExpression> constantBoundaries, UdfUtilities udfUtilities, boolean omitUnsupportedExprs) static LogicalExpression
ExpressionTreeMaterializer.convertToNullableType
(LogicalExpression fromExpr, TypeProtos.MinorType toType, FunctionLookupContext functionLookupContext, ErrorCollector errorCollector) static <C extends Comparable<C>>
LogicalExpressionComparisonPredicate.createComparisonPredicate
(String function, LogicalExpression left, LogicalExpression right) static <C extends Comparable<C>>
LogicalExpressionIsPredicate.createIsPredicate
(String function, LogicalExpression expr) static <V> ColumnStatistics<V>
StatisticsProvider.getConstantColumnStatistics
(V minMaxValue, LogicalExpression expr) ReturnsColumnStatistics
instance with min and max values set tominMaxValue
and nulls count set to 0.static LogicalExpression
ExpressionTreeMaterializer.materialize
(LogicalExpression expr, Map<VectorAccessible, BatchReference> batches, ErrorCollector errorCollector, FunctionLookupContext functionLookupContext, boolean allowComplexWriterExpr, boolean unionTypeEnabled) Materializes logical expression taking into account passed parameters.static LogicalExpression
ExpressionTreeMaterializer.materialize
(LogicalExpression expr, VectorAccessible batch, ErrorCollector errorCollector, FunctionLookupContext functionLookupContext) static LogicalExpression
ExpressionTreeMaterializer.materialize
(LogicalExpression expr, VectorAccessible batch, ErrorCollector errorCollector, FunctionLookupContext functionLookupContext, boolean allowComplexWriterExpr) static LogicalExpression
ExpressionTreeMaterializer.materialize
(LogicalExpression expr, VectorAccessible batch, ErrorCollector errorCollector, FunctionLookupContext functionLookupContext, boolean allowComplexWriterExpr, boolean unionTypeEnabled) Materializes logical expression taking into account passed parameters.static LogicalExpression
ExpressionTreeMaterializer.materializeAndCheckErrors
(LogicalExpression expr, VectorAccessible batch, FunctionLookupContext functionLookupContext) static LogicalExpression
ExpressionTreeMaterializer.materializeFilterExpr
(LogicalExpression expr, TupleMetadata fieldTypes, ErrorCollector errorCollector, FunctionLookupContext functionLookupContext) CloneVisitor.visitUnknown
(LogicalExpression e, Void value) FilterBuilder.visitUnknown
(LogicalExpression e, Set<LogicalExpression> value) HashVisitor.visitUnknown
(LogicalExpression e, Void value) StatisticsProvider.visitUnknown
(LogicalExpression e, Void value) Modifier and TypeMethodDescriptionstatic FilterPredicate<?>
FilterBuilder.buildFilterPredicate
(LogicalExpression expr, Set<LogicalExpression> constantBoundaries, UdfUtilities udfUtilities, boolean omitUnsupportedExprs) DrillFuncHolderExpr.copy
(List<LogicalExpression> args) HiveFuncHolderExpr.copy
(List<LogicalExpression> args) static <C extends Comparable<C>>
LogicalExpressionBooleanPredicate.createBooleanPredicate
(String function, String name, List<LogicalExpression> args, ExpressionPosition pos) FilterBuilder.visitBooleanConstant
(ValueExpressions.BooleanExpression booleanExpression, Set<LogicalExpression> value) FilterBuilder.visitBooleanOperator
(BooleanOperator op, Set<LogicalExpression> value) FilterBuilder.visitDateConstant
(ValueExpressions.DateExpression dateExpr, Set<LogicalExpression> value) FilterBuilder.visitDoubleConstant
(ValueExpressions.DoubleExpression dExpr, Set<LogicalExpression> value) FilterBuilder.visitFloatConstant
(ValueExpressions.FloatExpression fExpr, Set<LogicalExpression> value) FilterBuilder.visitFunctionHolderExpression
(FunctionHolderExpression funcHolderExpr, Set<LogicalExpression> value) FilterBuilder.visitIntConstant
(ValueExpressions.IntExpression intExpr, Set<LogicalExpression> value) FilterBuilder.visitLongConstant
(ValueExpressions.LongExpression intExpr, Set<LogicalExpression> value) FilterBuilder.visitQuotedStringConstant
(ValueExpressions.QuotedString quotedString, Set<LogicalExpression> value) FilterBuilder.visitTimeConstant
(ValueExpressions.TimeExpression timeExpr, Set<LogicalExpression> value) FilterBuilder.visitTimeStampConstant
(ValueExpressions.TimeStampExpression tsExpr, Set<LogicalExpression> value) FilterBuilder.visitTypedFieldExpr
(TypedFieldExpr typedFieldExpr, Set<LogicalExpression> value) FilterBuilder.visitUnknown
(LogicalExpression e, Set<LogicalExpression> value) FilterBuilder.visitVarDecimalConstant
(ValueExpressions.VarDecimalExpression decExpr, Set<LogicalExpression> value) ModifierConstructorDescriptionValueVectorWriteExpression
(TypedFieldId fieldId, LogicalExpression child) ValueVectorWriteExpression
(TypedFieldId fieldId, LogicalExpression child, boolean safe) ModifierConstructorDescriptionDrillFuncHolderExpr
(String nameUsed, DrillFuncHolder holder, List<LogicalExpression> args, ExpressionPosition pos) HiveFuncHolderExpr
(String nameUsed, HiveFuncHolder holder, List<LogicalExpression> args, ExpressionPosition pos) -
Uses of LogicalExpression in org.apache.drill.exec.expr.annotations
Modifier and TypeMethodDescriptionFunctionTemplate.ReturnType.getType
(List<LogicalExpression> logicalExpressions, FunctionAttributes attributes) -
Uses of LogicalExpression in org.apache.drill.exec.expr.fn
Modifier and TypeMethodDescriptionstatic LogicalExpression
FunctionGenerationHelper.getOrderingComparator
(boolean null_high, ClassGenerator.HoldingContainer left, ClassGenerator.HoldingContainer right, FunctionLookupContext functionLookupContext) Finds ordering comparator ("compare_to...") FunctionHolderExpression with a specified ordering for NULL (and considering NULLS equal).static LogicalExpression
FunctionGenerationHelper.getOrderingComparatorNullsHigh
(ClassGenerator.HoldingContainer left, ClassGenerator.HoldingContainer right, FunctionLookupContext registry) Finds ordering comparator ("compare_to...") FunctionHolderExpression with a "NULL high" ordering (and considering NULLS equal).Modifier and TypeMethodDescriptionDrillFuncHolder.getExpr
(String name, List<LogicalExpression> args, ExpressionPosition pos) HiveFuncHolder.getExpr
(String name, List<LogicalExpression> args, ExpressionPosition pos) DrillFuncHolder.getReturnType
(List<LogicalExpression> logicalExpressions) static TypeProtos.DataMode
FunctionUtils.getReturnTypeDataMode
(List<LogicalExpression> logicalExpressions, FunctionAttributes attributes) Calculates return type data mode based on give logical expressions. -
Uses of LogicalExpression in org.apache.drill.exec.expr.fn.impl
Modifier and TypeMethodDescriptionValueVectorHashHelper.getHash64
(LogicalExpression[] hashFieldsExp, TypedFieldId[] hashFieldIds) -
Uses of LogicalExpression in org.apache.drill.exec.expr.fn.interpreter
Modifier and TypeMethodDescriptionstatic void
InterpreterEvaluator.evaluate
(int recordCount, UdfUtilities udfUtilities, VectorAccessible incoming, ValueVector outVV, LogicalExpression expr) static void
InterpreterEvaluator.evaluate
(RecordBatch incoming, ValueVector outVV, LogicalExpression expr) static ValueHolder
InterpreterEvaluator.evaluateConstantExpr
(UdfUtilities udfUtilities, LogicalExpression expr) InterpreterEvaluator.EvalVisitor.visitUnknown
(LogicalExpression e, Integer inIndex) -
Uses of LogicalExpression in org.apache.drill.exec.expr.fn.output
Modifier and TypeMethodDescriptionConcatReturnTypeInference.getType
(List<LogicalExpression> logicalExpressions, FunctionAttributes attributes) Defines function return type and sets precision if it can be calculated.DecimalReturnTypeInference.DecimalAddReturnTypeInference.getType
(List<LogicalExpression> logicalExpressions, FunctionAttributes attributes) This return type is used by add and subtract functions for decimal data type.DecimalReturnTypeInference.DecimalAggReturnTypeInference.getType
(List<LogicalExpression> logicalExpressions, FunctionAttributes attributes) DecimalReturnTypeInference.DecimalAvgAggReturnTypeInference.getType
(List<LogicalExpression> logicalExpressions, FunctionAttributes attributes) DecimalReturnTypeInference.DecimalCastReturnTypeInference.getType
(List<LogicalExpression> logicalExpressions, FunctionAttributes attributes) DecimalReturnTypeInference.DecimalDivScaleReturnTypeInference.getType
(List<LogicalExpression> logicalExpressions, FunctionAttributes attributes) Return type is used by divide functions for decimal data type.DecimalReturnTypeInference.DecimalMaxScaleReturnTypeInference.getType
(List<LogicalExpression> logicalExpressions, FunctionAttributes attributes) DecimalReturnTypeInference.DecimalModScaleReturnTypeInference.getType
(List<LogicalExpression> logicalExpressions, FunctionAttributes attributes) Return type is used by divide functions for decimal data type.DecimalReturnTypeInference.DecimalSetScaleReturnTypeInference.getType
(List<LogicalExpression> logicalExpressions, FunctionAttributes attributes) DecimalReturnTypeInference.DecimalSumAggReturnTypeInference.getType
(List<LogicalExpression> logicalExpressions, FunctionAttributes attributes) DecimalReturnTypeInference.DecimalSumScaleReturnTypeInference.getType
(List<LogicalExpression> logicalExpressions, FunctionAttributes attributes) DecimalReturnTypeInference.DecimalZeroScaleReturnTypeInference.getType
(List<LogicalExpression> logicalExpressions, FunctionAttributes attributes) Return type is used for functions where we need to remove the scale part.DefaultReturnTypeInference.getType
(List<LogicalExpression> logicalExpressions, FunctionAttributes attributes) Calculates return type and its nullability.PadReturnTypeInference.getType
(List<LogicalExpression> logicalExpressions, FunctionAttributes attributes) Defines function return type and sets precision if it pad length parameter is int expression.ReturnTypeInference.getType
(List<LogicalExpression> logicalExpressions, FunctionAttributes attributes) SameInOutLengthReturnTypeInference.getType
(List<LogicalExpression> logicalExpressions, FunctionAttributes attributes) Defines function return type and sets precision and scale if input type has them.StringCastReturnTypeInference.getType
(List<LogicalExpression> logicalExpressions, FunctionAttributes attributes) Defines function return type and sets cast length as type precision if cast length is simple long expression. -
Uses of LogicalExpression in org.apache.drill.exec.physical.base
Modifier and TypeFieldDescriptionprotected final LogicalExpression
AbstractJoinPop.condition
protected LogicalExpression
AbstractGroupScanWithMetadata.filter
protected LogicalExpression
AbstractGroupScanWithMetadata.GroupScanWithMetadataFilterer.filterExpression
Modifier and TypeMethodDescriptionAbstractJoinPop.getCondition()
AbstractGroupScan.getFilter()
AbstractGroupScanWithMetadata.getFilter()
GroupScan.getFilter()
static LogicalExpression
PhysicalOperatorUtil.materializeExpression
(LogicalExpression expr, VectorAccessible incoming, FragmentContext context) Helper method to materialize the given logical expression using theExpressionTreeMaterializer
.Modifier and TypeMethodDescriptionAbstractGroupScan.applyFilter
(LogicalExpression filterExpr, UdfUtilities udfUtilities, FunctionImplementationRegistry functionImplementationRegistry, OptionManager optionManager) AbstractGroupScanWithMetadata.applyFilter
(LogicalExpression filterExpr, UdfUtilities udfUtilities, FunctionImplementationRegistry functionImplementationRegistry, OptionManager optionManager) Applies specified filterfilterExpr
to current group scan and produces filtering at: table level: if filter matches all the the data or prunes all the data, sets corresponding value toAbstractGroupScanWithMetadata.isMatchAllMetadata()
and returns null segment level: if filter matches all the the data or prunes all the data, sets corresponding value toAbstractGroupScanWithMetadata.isMatchAllMetadata()
and returns null if segment metadata was pruned, prunes underlying metadata partition level: if filter matches all the the data or prunes all the data, sets corresponding value toAbstractGroupScanWithMetadata.isMatchAllMetadata()
and returns null if partition metadata was pruned, prunes underlying metadata file level: if filter matches all the the data or prunes all the data, sets corresponding value toAbstractGroupScanWithMetadata.isMatchAllMetadata()
and returns nullGroupScan.applyFilter
(LogicalExpression filterExpr, UdfUtilities udfUtilities, FunctionImplementationRegistry functionImplementationRegistry, OptionManager optionManager) AbstractGroupScanWithMetadata.GroupScanWithMetadataFilterer.filterExpression
(LogicalExpression filterExpression) AbstractGroupScanWithMetadata.getFilterPredicate
(LogicalExpression filterExpr, UdfUtilities udfUtilities, FunctionLookupContext functionImplementationRegistry, OptionManager optionManager, boolean omitUnsupportedExprs) static FilterPredicate<?>
AbstractGroupScanWithMetadata.getFilterPredicate
(LogicalExpression filterExpr, UdfUtilities udfUtilities, FunctionLookupContext functionImplementationRegistry, OptionManager optionManager, boolean omitUnsupportedExprs, boolean supportsFileImplicitColumns, TupleMetadata schema) Returns parquet filter predicate built from specifiedfilterExpr
.static LogicalExpression
PhysicalOperatorUtil.materializeExpression
(LogicalExpression expr, VectorAccessible incoming, FragmentContext context) Helper method to materialize the given logical expression using theExpressionTreeMaterializer
.void
AbstractGroupScanWithMetadata.setFilter
(LogicalExpression filter) void
AbstractGroupScanWithMetadata.setFilterForRuntime
(LogicalExpression filterExpr, OptimizerRulesContext optimizerContext) Set the filter - thus enabling runtime rowgroup pruning The runtime pruning can be disabled with an option.ModifierConstructorDescriptionprotected
AbstractGroupScanWithMetadata
(String userName, List<SchemaPath> columns, LogicalExpression filter) AbstractJoinPop
(PhysicalOperator leftOp, PhysicalOperator rightOp, org.apache.calcite.rel.core.JoinRelType joinType, boolean semiJoin, LogicalExpression joinCondition, List<JoinCondition> joinConditions) -
Uses of LogicalExpression in org.apache.drill.exec.physical.config
Modifier and TypeMethodDescriptionFilter.getExpr()
HashPartitionSender.getExpr()
AbstractDeMuxExchange.getExpression()
HashToRandomExchange.getExpression()
PartitionRange.getFinish()
PartitionRange.getStart()
ModifierConstructorDescriptionAbstractDeMuxExchange
(PhysicalOperator child, LogicalExpression expr) Filter
(PhysicalOperator child, LogicalExpression expr, float selectivity) HashPartitionSender
(int oppositeMajorFragmentId, PhysicalOperator child, LogicalExpression expr, List<MinorFragmentEndpoint> endpoints) HashPartitionSender
(int oppositeMajorFragmentId, PhysicalOperator child, LogicalExpression expr, List<MinorFragmentEndpoint> endpoints, int outgoingBatchSize) HashToMergeExchange
(PhysicalOperator child, LogicalExpression expr, List<Order.Ordering> orderExprs) HashToRandomExchange
(PhysicalOperator child, LogicalExpression expr) NestedLoopJoinPOP
(PhysicalOperator left, PhysicalOperator right, org.apache.calcite.rel.core.JoinRelType joinType, LogicalExpression condition) PartitionRange
(LogicalExpression start, LogicalExpression finish) UnorderedDeMuxExchange
(PhysicalOperator child, LogicalExpression expr) -
Uses of LogicalExpression in org.apache.drill.exec.physical.impl.aggregate
Modifier and TypeMethodDescriptionprotected void
StreamingAggBatch.addRecordValues
(ClassGenerator<StreamingAggregator> cg, LogicalExpression[] valueExprs) protected void
StreamingAggBatch.outputRecordKeys
(ClassGenerator<StreamingAggregator> cg, TypedFieldId[] keyOutputIds, LogicalExpression[] keyExprs) protected void
StreamingAggBatch.outputRecordKeysPrev
(ClassGenerator<StreamingAggregator> cg, TypedFieldId[] keyOutputIds, LogicalExpression[] keyExprs) void
HashAggregator.setup
(HashAggregate hashAggrConfig, HashTableConfig htConfig, FragmentContext context, OperatorContext oContext, RecordBatch incoming, HashAggBatch outgoing, LogicalExpression[] valueExprs, List<TypedFieldId> valueFieldIds, ClassGenerator<?> cg, TypedFieldId[] keyFieldIds, VectorContainer outContainer, int extraRowBytes) void
HashAggTemplate.setup
(HashAggregate hashAggrConfig, HashTableConfig htConfig, FragmentContext context, OperatorContext oContext, RecordBatch incoming, HashAggBatch outgoing, LogicalExpression[] valueExprs, List<TypedFieldId> valueFieldIds, ClassGenerator<?> cg, TypedFieldId[] groupByOutFieldIds, VectorContainer outContainer, int extraRowBytes) protected void
StreamingAggBatch.setupIsSame
(ClassGenerator<StreamingAggregator> cg, LogicalExpression[] keyExprs) protected void
StreamingAggBatch.setupIsSameApart
(ClassGenerator<StreamingAggregator> cg, LogicalExpression[] keyExprs) -
Uses of LogicalExpression in org.apache.drill.exec.physical.impl.filter
ModifierConstructorDescriptionReturnValueExpression
(LogicalExpression child, boolean returnTrueOnOne) -
Uses of LogicalExpression in org.apache.drill.exec.physical.impl.join
Modifier and TypeMethodDescriptionstatic void
JoinUtils.addLeastRestrictiveCasts
(LogicalExpression[] leftExpressions, VectorAccessible leftBatch, LogicalExpression[] rightExpressions, VectorAccessible rightBatch, FragmentContext context) Utility method used by joins to add implicit casts on one of the sides of the join condition in case the two expressions have different types. -
Uses of LogicalExpression in org.apache.drill.exec.physical.impl.project
Modifier and TypeMethodDescriptionProjectBatchBuilder.addEvalVector
(String outputName, LogicalExpression expr) void
ProjectMemoryManager.addNewField
(ValueVector vvOut, LogicalExpression logicalExpression) ProjectBatchBuilder.addOutputVector
(String name, LogicalExpression expr) OutputWidthVisitor.visitUnknown
(LogicalExpression logicalExpression, OutputWidthVisitorState state) -
Uses of LogicalExpression in org.apache.drill.exec.planner.common
Modifier and TypeMethodDescriptionprotected LogicalExpression
DrillFilterRelBase.getFilterExpression
(DrillParseContext context) -
Uses of LogicalExpression in org.apache.drill.exec.planner.index
Modifier and TypeFieldDescriptionprotected final Set<LogicalExpression>
DrillIndexDefinition.allIndexColumns
final Map<LogicalExpression,
org.apache.calcite.rel.RelFieldCollation> CollationContext.collationMap
protected final List<LogicalExpression>
DrillIndexDefinition.indexColumns
The indexColumns is the list of column(s) on which this index is created.IndexLogicalPlanCallContext.leftOutPathsInFunctions
IndexPhysicalPlanCallContext.leftOutPathsInFunctions
protected final List<LogicalExpression>
DrillIndexDefinition.nonIndexColumns
nonIndexColumns: the list of columns that are included in the index as 'covering' columns but are not themselves indexed.protected final List<LogicalExpression>
DrillIndexDefinition.rowKeyColumns
IndexLogicalPlanCallContext.sortExprs
IndexPhysicalPlanCallContext.sortExprs
Modifier and TypeMethodDescriptionstatic LogicalExpression
RexToExpression.toDrill
(DrillParseContext context, DrillProjectRelBase project, org.apache.calcite.rel.RelNode input, org.apache.calcite.rex.RexNode expr) RexToExpression.RexToDrillExt.visitCall
(org.apache.calcite.rex.RexCall call) RexToExpression.RexToDrillExt.visitCorrelVariable
(org.apache.calcite.rex.RexCorrelVariable correlVariable) RexToExpression.RexToDrillExt.visitDynamicParam
(org.apache.calcite.rex.RexDynamicParam dynamicParam) RexToExpression.RexToDrillExt.visitFieldAccess
(org.apache.calcite.rex.RexFieldAccess fieldAccess) RexToExpression.RexToDrillExt.visitInputRef
(org.apache.calcite.rex.RexInputRef inputRef) RexToExpression.RexToDrillExt.visitLocalRef
(org.apache.calcite.rex.RexLocalRef localRef) RexToExpression.RexToDrillExt.visitOver
(org.apache.calcite.rex.RexOver over) RexToExpression.RexToDrillExt.visitRangeRef
(org.apache.calcite.rex.RexRangeRef rangeRef) Modifier and TypeMethodDescriptionMap<LogicalExpression,
org.apache.calcite.rel.RelFieldCollation> DrillIndexDefinition.getCollationMap()
Map<LogicalExpression,
org.apache.calcite.rel.RelFieldCollation> IndexDefinition.getCollationMap()
Get a mapping of the LogicalExpresion/SchemaPath to its field collation - e.g Ascending/Descending, Nulls First/Nulls LastMap<org.apache.calcite.rex.RexNode,
LogicalExpression> IndexableExprMarker.getEqualOnCastChar()
IndexableExprMarker.getExpressionsOnlyInEquality()
return the expressions that were only in equality condition _and_ only once.FunctionalIndexInfo.getExprMap()
FunctionalIndexInfo.getExprMap()
static Map<LogicalExpression,
Integer> IndexPlanUtils.getExprsFromRowType
(org.apache.calcite.rel.type.RelDataType indexScanRowType) Map<org.apache.calcite.rex.RexNode,
LogicalExpression> IndexableExprMarker.getIndexableExpression()
DrillIndexDefinition.getIndexColumns()
IndexDefinition.getIndexColumns()
Get the list of columns in the index key.IndexCallContext.getLeftOutPathsInFunctions()
IndexLogicalPlanCallContext.getLeftOutPathsInFunctions()
IndexPhysicalPlanCallContext.getLeftOutPathsInFunctions()
Map<LogicalExpression,
Set<org.apache.calcite.rex.RexNode>> RexToExpression.RexToDrillExt.getMapExprToRex()
DrillIndexDefinition.getNonIndexColumns()
IndexDefinition.getNonIndexColumns()
Get the list of columns that are in the 'included' or 'covered' fields.FunctionalIndexInfo.getPathsInFunctionExpr()
static Map<LogicalExpression,
Integer> IndexPlanUtils.getProjectExprs
(List<org.apache.calcite.rex.RexNode> projectRexs, DrillProjectRelBase project, org.apache.calcite.rel.RelNode input) PathInExpr.getRemainderPaths()
PathInExpr.getRemainderPathsInFunctions()
DrillIndexDefinition.getRowKeyColumns()
IndexDefinition.getRowKeyColumns()
Get the list of columns (typically 1 column) that constitute the row key (primary key)IndexCallContext.getSortExprs()
IndexLogicalPlanCallContext.getSortExprs()
IndexPhysicalPlanCallContext.getSortExprs()
Modifier and TypeMethodDescriptionint
DrillIndexDefinition.getIndexColumnOrdinal
(LogicalExpression path) int
IndexDefinition.getIndexColumnOrdinal
(LogicalExpression path) Check to see if the field name is an index column and if so return the ordinal position in the indexFunctionalIndexInfo.getNewPathFromExpr
(LogicalExpression expr) return a plain field path if the incoming index expression 'expr' is replaced to be a plain fieldPathInExpr.visitUnknown
(LogicalExpression e, Void value) Modifier and TypeMethodDescriptionboolean
DrillIndexDefinition.allColumnsIndexed
(Collection<LogicalExpression> columns) boolean
IndexDefinition.allColumnsIndexed
(Collection<LogicalExpression> columns) Check if this index have all the columns specified in the supplied list of columns indexedstatic org.apache.calcite.rel.RelCollation
IndexPlanUtils.buildCollationForExpressions
(Map<LogicalExpression, Integer> projectExprs, IndexDescriptor indexDesc, IndexCallContext context) Given index, compute the collations for a list of projected expressions(from Scan's rowType or Project's ) in the contextprotected boolean
DrillIndexDefinition.columnsInIndexFields
(Collection<LogicalExpression> columns, Collection<LogicalExpression> indexFields) static List<org.apache.calcite.rex.RexNode>
IndexPlanUtils.getLeadingFilters
(Map<LogicalExpression, org.apache.calcite.rex.RexNode> leadingPrefixMap, List<LogicalExpression> indexCols) static List<org.apache.calcite.rex.RexNode>
IndexPlanUtils.getLeadingFilters
(Map<LogicalExpression, org.apache.calcite.rex.RexNode> leadingPrefixMap, List<LogicalExpression> indexCols) static org.apache.calcite.rex.RexNode
IndexPlanUtils.getLeadingPrefixMap
(Map<LogicalExpression, org.apache.calcite.rex.RexNode> leadingPrefixMap, List<LogicalExpression> indexCols, IndexConditionInfo.Builder builder, org.apache.calcite.rex.RexNode condition) static org.apache.calcite.rex.RexNode
IndexPlanUtils.getLeadingPrefixMap
(Map<LogicalExpression, org.apache.calcite.rex.RexNode> leadingPrefixMap, List<LogicalExpression> indexCols, IndexConditionInfo.Builder builder, org.apache.calcite.rex.RexNode condition) IndexConditionInfo.Builder.indexConditionRelatedToFields
(List<LogicalExpression> relevantPaths, org.apache.calcite.rex.RexNode condition) Given a list of Index Expressions(usually indexed fields/functions from one or a set of indexes), separate a filter condition into 1), relevant subset of conditions (by relevant, it means at least one given index Expression was found) and, 2), the rest in remainderConditionboolean
DrillIndexDefinition.isCoveringIndex
(List<LogicalExpression> columns) boolean
IndexDefinition.isCoveringIndex
(List<LogicalExpression> columns) Check if this index 'covers' all the columns specified in the supplied list of columnsboolean
DrillIndexDefinition.pathExactIn
(SchemaPath path, Collection<LogicalExpression> exprs) org.apache.calcite.rex.RexNode
SimpleRexRemap.rewriteEqualOnCharToLike
(org.apache.calcite.rex.RexNode expr, Map<org.apache.calcite.rex.RexNode, LogicalExpression> equalOnCastCharExprs) org.apache.calcite.rex.RexNode
SimpleRexRemap.rewriteWithMap
(org.apache.calcite.rex.RexNode srcRex, Map<org.apache.calcite.rex.RexNode, LogicalExpression> mapRexToExpr) SimpleRexRemap.setExpressionMap
(Map<LogicalExpression, LogicalExpression> exprMap) Set the map of src expression to target expression, expressions not in the map do not have assigned destinationsSimpleRexRemap.setExpressionMap
(Map<LogicalExpression, LogicalExpression> exprMap) Set the map of src expression to target expression, expressions not in the map do not have assigned destinationsvoid
IndexCallContext.setLeftOutPathsInFunctions
(Set<LogicalExpression> exprs) void
IndexLogicalPlanCallContext.setLeftOutPathsInFunctions
(Set<LogicalExpression> exprs) void
IndexPhysicalPlanCallContext.setLeftOutPathsInFunctions
(Set<LogicalExpression> exprs) void
IndexProperties.setProperties
(Map<LogicalExpression, org.apache.calcite.rex.RexNode> prefixMap, boolean satisfiesCollation, org.apache.calcite.rex.RexNode indexColumnsRemainderFilter, Statistics stats) void
IndexSelector.DrillIndexProperties.setProperties
(Map<LogicalExpression, org.apache.calcite.rex.RexNode> prefixMap, boolean satisfiesCollation, org.apache.calcite.rex.RexNode indexColumnsRemainderFilter, Statistics stats) boolean
DrillIndexDefinition.someColumnsIndexed
(Collection<LogicalExpression> columns) boolean
IndexDefinition.someColumnsIndexed
(Collection<LogicalExpression> columns) Check if this index has some columns specified in the supplied list of columns indexedprotected boolean
DrillIndexDefinition.someColumnsInIndexFields
(Collection<LogicalExpression> columns, Collection<LogicalExpression> indexFields) ModifierConstructorDescriptionAbstractIndexDescriptor
(List<LogicalExpression> indexCols, CollationContext indexCollationContext, List<LogicalExpression> nonIndexCols, List<LogicalExpression> rowKeyColumns, String indexName, String tableName, IndexDefinition.IndexType type, org.apache.calcite.rel.RelFieldCollation.NullDirection nullsDirection) CollationContext
(Map<LogicalExpression, org.apache.calcite.rel.RelFieldCollation> collationMap, List<org.apache.calcite.rel.RelFieldCollation> relFieldCollations) DrillIndexDefinition
(List<LogicalExpression> indexCols, CollationContext indexCollationContext, List<LogicalExpression> nonIndexCols, List<LogicalExpression> rowKeyColumns, String indexName, String tableName, IndexDefinition.IndexType type, org.apache.calcite.rel.RelFieldCollation.NullDirection nullsDirection) DrillIndexDescriptor
(List<LogicalExpression> indexCols, CollationContext indexCollationContext, List<LogicalExpression> nonIndexCols, List<LogicalExpression> rowKeyColumns, String indexName, String tableName, IndexDefinition.IndexType type, org.apache.calcite.rel.RelFieldCollation.NullDirection nullsDirection) PathInExpr
(Map<LogicalExpression, Set<SchemaPath>> pathsInExpr) RexSeparator
(List<LogicalExpression> relatedPaths, org.apache.calcite.rel.RelNode inputRel, org.apache.calcite.rex.RexBuilder builder) -
Uses of LogicalExpression in org.apache.drill.exec.planner.logical
Modifier and TypeMethodDescriptionstatic LogicalExpression
DrillAggregateRel.toDrill
(org.apache.calcite.rel.core.AggregateCall call, List<String> fn, DrillImplementor implementor) static LogicalExpression
DrillOptiq.toDrill
(DrillParseContext context, List<org.apache.calcite.rel.RelNode> inputs, org.apache.calcite.rex.RexNode expr) Converts a tree ofRexNode
operators into a scalar expression in Drill syntax using multiple inputs.static LogicalExpression
DrillOptiq.toDrill
(DrillParseContext context, org.apache.calcite.rel.RelNode input, org.apache.calcite.rex.RexNode expr) Converts a tree ofRexNode
operators into a scalar expression in Drill syntax using one input.static LogicalExpression
DrillOptiq.toDrill
(DrillParseContext context, org.apache.calcite.rel.type.RelDataType type, org.apache.calcite.rex.RexBuilder builder, org.apache.calcite.rex.RexNode expr) protected LogicalExpression
DrillOptiq.RexToDrill.visitCall
(org.apache.calcite.rex.RexCall call) DrillOptiq.RexToDrill.visitCorrelVariable
(org.apache.calcite.rex.RexCorrelVariable correlVariable) DrillOptiq.RexToDrill.visitDynamicParam
(org.apache.calcite.rex.RexDynamicParam dynamicParam) DrillOptiq.RexToDrill.visitFieldAccess
(org.apache.calcite.rex.RexFieldAccess fieldAccess) DrillOptiq.RexToDrill.visitInputRef
(org.apache.calcite.rex.RexInputRef inputRef) DrillOptiq.RexToDrill.visitLiteral
(org.apache.calcite.rex.RexLiteral literal) DrillOptiq.RexToDrill.visitLocalRef
(org.apache.calcite.rex.RexLocalRef localRef) DrillOptiq.RexToDrill.visitOver
(org.apache.calcite.rex.RexOver over) DrillOptiq.RexToDrill.visitRangeRef
(org.apache.calcite.rex.RexRangeRef rangeRef) -
Uses of LogicalExpression in org.apache.drill.exec.planner.logical.partition
Modifier and TypeMethodDescriptionprotected LogicalExpression
PruneScanRule.materializePruneExpr
(org.apache.calcite.rex.RexNode pruneCondition, PlannerSettings settings, org.apache.calcite.rel.RelNode scanRel, VectorContainer container) -
Uses of LogicalExpression in org.apache.drill.exec.planner.physical
Modifier and TypeFieldDescriptionHashPrelUtil.HASH_HELPER_LOGICAL_EXPRESSION
Implementation ofHashPrelUtil.HashExpressionCreatorHelper
forLogicalExpression
type.Modifier and TypeMethodDescriptionprotected LogicalExpression
FlattenPrel.getFlattenExpression
(DrillParseContext context) static LogicalExpression
HashPrelUtil.getHash64Expression
(LogicalExpression field, LogicalExpression seed, boolean hashAsDouble) Creates hash expression for input field and seed.static LogicalExpression
HashPrelUtil.getHashExpression
(List<DrillDistributionTrait.DistributionField> fields, org.apache.calcite.rel.type.RelDataType rowType) Create a distribution hash expression.static LogicalExpression
HashPrelUtil.getHashExpression
(LogicalExpression field, LogicalExpression seed, boolean hashAsDouble) Creates hash expression for input field and seed.protected LogicalExpression
protected LogicalExpression
Modifier and TypeMethodDescriptionstatic LogicalExpression
HashPrelUtil.getHash64Expression
(LogicalExpression field, LogicalExpression seed, boolean hashAsDouble) Creates hash expression for input field and seed.static LogicalExpression
HashPrelUtil.getHashExpression
(LogicalExpression field, LogicalExpression seed, boolean hashAsDouble) Creates hash expression for input field and seed. -
Uses of LogicalExpression in org.apache.drill.exec.planner.torel
Modifier and TypeMethodDescriptionorg.apache.calcite.rex.RexNode
ConversionContext.toRex
(LogicalExpression e) -
Uses of LogicalExpression in org.apache.drill.exec.store.delta
Modifier and TypeMethodDescriptionDeltaGroupScan.DeltaGroupScanBuilder.condition
(LogicalExpression condition) ModifierConstructorDescriptionDeltaGroupScan
(String userName, List<ReadEntryWithPath> entries, StoragePluginConfig storageConfig, FormatPluginConfig formatConfig, List<SchemaPath> columns, TupleMetadata schema, String path, ParquetReaderConfig readerConfig, LogicalExpression condition, Integer limit, Map<org.apache.hadoop.fs.Path, Map<String, String>> partitionHolder, StoragePluginRegistry pluginRegistry) DeltaRowGroupScan
(String userName, DeltaFormatPlugin formatPlugin, List<RowGroupReadEntry> rowGroupReadEntries, List<SchemaPath> columns, Map<org.apache.hadoop.fs.Path, Map<String, String>> partitions, ParquetReaderConfig readerConfig, LogicalExpression filter, TupleMetadata schema) DeltaRowGroupScan
(StoragePluginRegistry registry, String userName, StoragePluginConfig storageConfig, FormatPluginConfig formatPluginConfig, List<RowGroupReadEntry> rowGroupReadEntries, List<SchemaPath> columns, Map<org.apache.hadoop.fs.Path, Map<String, String>> partitions, ParquetReaderConfig readerConfig, LogicalExpression filter, TupleMetadata schema) -
Uses of LogicalExpression in org.apache.drill.exec.store.delta.plan
Modifier and TypeMethodDescriptionio.delta.standalone.expressions.Expression
DrillExprToDeltaTranslator.visitUnknown
(LogicalExpression e, Void value) -
Uses of LogicalExpression in org.apache.drill.exec.store.druid
Modifier and TypeMethodDescriptionDruidCompareFunctionProcessor.visitCastExpression
(CastExpression e, LogicalExpression valueArg) DruidCompareFunctionProcessor.visitConvertExpression
(ConvertExpression e, LogicalExpression valueArg) DruidCompareFunctionProcessor.visitSchemaPath
(SchemaPath path, LogicalExpression valueArg) DruidCompareFunctionProcessor.visitUnknown
(LogicalExpression e, LogicalExpression valueArg) DruidFilterBuilder.visitUnknown
(LogicalExpression e, Void value) ModifierConstructorDescriptionDruidFilterBuilder
(DruidGroupScan groupScan, LogicalExpression conditionExp) -
Uses of LogicalExpression in org.apache.drill.exec.store.hbase
Modifier and TypeMethodDescriptionprotected io.netty.buffer.ByteBuf
CompareFunctionsProcessor.getByteBuf
(LogicalExpression valueArg, String encodingType) CompareFunctionsProcessor.visitCastExpression
(CastExpression e, LogicalExpression valueArg) CompareFunctionsProcessor.visitConvertExpression
(ConvertExpression e, LogicalExpression valueArg) CompareFunctionsProcessor.visitFunctionCall
(FunctionCall call, LogicalExpression valueArg) CompareFunctionsProcessor.visitSchemaPath
(SchemaPath path, LogicalExpression valueArg) CompareFunctionsProcessor.visitUnknown
(LogicalExpression e, LogicalExpression valueArg) HBaseFilterBuilder.visitUnknown
(LogicalExpression e, Void value) -
Uses of LogicalExpression in org.apache.drill.exec.store.hive
ModifierConstructorDescriptionHiveDrillNativeParquetRowGroupScan
(String userName, HiveStoragePlugin hiveStoragePlugin, List<RowGroupReadEntry> rowGroupReadEntries, List<SchemaPath> columns, HivePartitionHolder hivePartitionHolder, Map<String, String> confProperties, ParquetReaderConfig readerConfig, LogicalExpression filter, TupleMetadata schema) HiveDrillNativeParquetRowGroupScan
(StoragePluginRegistry registry, String userName, HiveStoragePluginConfig hiveStoragePluginConfig, List<RowGroupReadEntry> rowGroupReadEntries, List<SchemaPath> columns, HivePartitionHolder hivePartitionHolder, Map<String, String> confProperties, ParquetReaderConfig readerConfig, LogicalExpression filter, TupleMetadata schema) HiveDrillNativeParquetScan
(String userName, List<SchemaPath> columns, HiveStoragePlugin hiveStoragePlugin, List<HiveMetadataProvider.LogicalInputSplit> logicalInputSplits, Map<String, String> confProperties, ParquetReaderConfig readerConfig, LogicalExpression filter) HiveDrillNativeParquetScan
(StoragePluginRegistry engineRegistry, String userName, HiveStoragePluginConfig hiveStoragePluginConfig, List<SchemaPath> columns, List<ReadEntryWithPath> entries, HivePartitionHolder hivePartitionHolder, Map<String, String> confProperties, ParquetReaderConfig readerConfig, LogicalExpression filter, TupleMetadata schema) -
Uses of LogicalExpression in org.apache.drill.exec.store.iceberg
Modifier and TypeMethodDescriptionIcebergGroupScan.IcebergGroupScanBuilder.condition
(LogicalExpression condition) IcebergSubScan.IcebergSubScanBuilder.condition
(LogicalExpression condition) static org.apache.iceberg.TableScan
IcebergGroupScan.initTableScan
(IcebergFormatPlugin formatPlugin, String path, LogicalExpression condition) ModifierConstructorDescriptionIcebergGroupScan
(String userName, StoragePluginConfig storageConfig, FormatPluginConfig formatConfig, List<SchemaPath> columns, TupleMetadata schema, String path, LogicalExpression condition, Integer maxRecords, StoragePluginRegistry pluginRegistry) IcebergSubScan
(String userName, StoragePluginConfig storageConfig, FormatPluginConfig formatConfig, List<SchemaPath> columns, String path, List<IcebergWork> workList, TupleMetadata schema, LogicalExpression condition, Integer maxRecords, StoragePluginRegistry pluginRegistry) -
Uses of LogicalExpression in org.apache.drill.exec.store.iceberg.plan
Modifier and TypeMethodDescriptionorg.apache.iceberg.expressions.Expression
DrillExprToIcebergTranslator.visitUnknown
(LogicalExpression e, Void value) -
Uses of LogicalExpression in org.apache.drill.exec.store.ischema
Modifier and TypeMethodDescriptionInfoSchemaFilterBuilder.visitUnknown
(LogicalExpression e, Void value) -
Uses of LogicalExpression in org.apache.drill.exec.store.kafka
Modifier and TypeMethodDescriptionKafkaPartitionScanSpecBuilder.visitUnknown
(LogicalExpression e, Void value) ModifierConstructorDescriptionKafkaPartitionScanSpecBuilder
(KafkaGroupScan groupScan, LogicalExpression conditionExp) -
Uses of LogicalExpression in org.apache.drill.exec.store.mongo
Modifier and TypeMethodDescriptionMongoCompareFunctionProcessor.visitCastExpression
(CastExpression e, LogicalExpression valueArg) MongoCompareFunctionProcessor.visitConvertExpression
(ConvertExpression e, LogicalExpression valueArg) MongoCompareFunctionProcessor.visitSchemaPath
(SchemaPath path, LogicalExpression valueArg) MongoCompareFunctionProcessor.visitUnknown
(LogicalExpression e, LogicalExpression valueArg) org.bson.Document
MongoFilterBuilder.visitUnknown
(LogicalExpression e, Void value) -
Uses of LogicalExpression in org.apache.drill.exec.store.parquet
Modifier and TypeFieldDescriptionprotected final LogicalExpression
AbstractParquetRowGroupScan.filter
Modifier and TypeMethodDescriptionAbstractParquetGroupScan.applyFilter
(LogicalExpression filterExpr, UdfUtilities udfUtilities, FunctionImplementationRegistry functionImplementationRegistry, OptionManager optionManager) Applies specified filterfilterExpr
to current group scan and produces filtering at: table level: if filter matches all the the data or prunes all the data, sets corresponding value toAbstractGroupScanWithMetadata.isMatchAllMetadata()
and returns null segment level: if filter matches all the the data or prunes all the data, sets corresponding value toAbstractGroupScanWithMetadata.isMatchAllMetadata()
and returns null if segment metadata was pruned, prunes underlying metadata partition level: if filter matches all the the data or prunes all the data, sets corresponding value toAbstractGroupScanWithMetadata.isMatchAllMetadata()
and returns null if partition metadata was pruned, prunes underlying metadata file level: if filter matches all the the data or prunes all the data, sets corresponding value toAbstractGroupScanWithMetadata.isMatchAllMetadata()
and returns nullstatic RowsMatch
FilterEvaluatorUtils.evalFilter
(LogicalExpression expr, MetadataBase.ParquetTableMetadataBase footer, int rowGroupIndex, OptionManager options, FragmentContext fragmentContext) static RowsMatch
FilterEvaluatorUtils.matches
(LogicalExpression expr, Map<SchemaPath, ColumnStatistics<?>> columnsStatistics, TupleMetadata schema, long rowCount, UdfUtilities udfUtilities, FunctionLookupContext functionImplementationRegistry, Set<SchemaPath> schemaPathsInExpr) FilterEvaluatorUtils.FieldReferenceFinder.visitUnknown
(LogicalExpression e, Void value) ModifierConstructorDescriptionprotected
AbstractParquetGroupScan
(String userName, List<SchemaPath> columns, List<ReadEntryWithPath> entries, ParquetReaderConfig readerConfig, LogicalExpression filter) protected
AbstractParquetRowGroupScan
(String userName, List<RowGroupReadEntry> rowGroupReadEntries, List<SchemaPath> columns, ParquetReaderConfig readerConfig, LogicalExpression filter, org.apache.hadoop.fs.Path selectionRoot, TupleMetadata schema) ParquetGroupScan
(String userName, FileSelection selection, ParquetFormatPlugin formatPlugin, List<SchemaPath> columns, ParquetReaderConfig readerConfig, LogicalExpression filter, MetadataProviderManager metadataProviderManager) ParquetGroupScan
(StoragePluginRegistry engineRegistry, String userName, List<ReadEntryWithPath> entries, StoragePluginConfig storageConfig, FormatPluginConfig formatConfig, List<SchemaPath> columns, org.apache.hadoop.fs.Path selectionRoot, org.apache.hadoop.fs.Path cacheFileRoot, ParquetReaderConfig readerConfig, LogicalExpression filter, TupleMetadata schema) ParquetRowGroupScan
(String userName, ParquetFormatPlugin formatPlugin, List<RowGroupReadEntry> rowGroupReadEntries, List<SchemaPath> columns, ParquetReaderConfig readerConfig, org.apache.hadoop.fs.Path selectionRoot, LogicalExpression filter, TupleMetadata schema) ParquetRowGroupScan
(StoragePluginRegistry registry, String userName, StoragePluginConfig storageConfig, FormatPluginConfig formatConfig, LinkedList<RowGroupReadEntry> rowGroupReadEntries, List<SchemaPath> columns, ParquetReaderConfig readerConfig, org.apache.hadoop.fs.Path selectionRoot, LogicalExpression filter, TupleMetadata schema)