Uses of Interface
org.apache.calcite.adapter.enumerable.PhysType
-
Packages that use PhysType Package Description org.apache.calcite.adapter.enumerable Query optimizer rules for Java calling convention.org.apache.calcite.adapter.enumerable.impl Calcite-specific classes for implementation of regular and window aggregates.org.apache.calcite.adapter.jdbc Query provider based on a JDBC data source.org.apache.calcite.adapter.spark Adapter based on the Apache Spark data management system. -
-
Uses of PhysType in org.apache.calcite.adapter.enumerable
Classes in org.apache.calcite.adapter.enumerable that implement PhysType Modifier and Type Class Description class
PhysTypeImpl
Implementation ofPhysType
.Fields in org.apache.calcite.adapter.enumerable declared as PhysType Modifier and Type Field Description PhysType
EnumerableRel.Result. physType
Describes the Java type returned by this relational expression, and the mapping between it and the fields of the logical row type.private PhysType
EnumerableWindow.WindowRelInputGetter. rowPhysType
Fields in org.apache.calcite.adapter.enumerable with type parameters of type PhysType Modifier and Type Field Description private java.util.List<Pair<Expression,PhysType>>
RexToLixTranslator.InputGetterImpl. inputs
Methods in org.apache.calcite.adapter.enumerable that return PhysType Modifier and Type Method Description PhysType
PhysType. component(int field)
Returns the physical type of a given field's component type.PhysType
PhysTypeImpl. component(int fieldOrdinal)
PhysType
PhysType. field(int ordinal)
Returns the physical type of a field.PhysType
PhysTypeImpl. field(int ordinal)
PhysType
PhysType. makeNullable(boolean nullable)
Returns a copy of this type that allows nulls ifnullable
is true.PhysType
PhysTypeImpl. makeNullable(boolean nullable)
(package private) static PhysType
PhysTypeImpl. of(JavaTypeFactory typeFactory, java.lang.reflect.Type javaRowClass)
static PhysType
PhysTypeImpl. of(JavaTypeFactory typeFactory, RelDataType rowType, JavaRowFormat format)
static PhysType
PhysTypeImpl. of(JavaTypeFactory typeFactory, RelDataType rowType, JavaRowFormat format, boolean optimize)
PhysType
PhysType. project(java.util.List<java.lang.Integer> integers, boolean indicator, JavaRowFormat format)
Projects a given collection of fields from this input record, optionally with indicator fields, into a particular preferred output format.PhysType
PhysType. project(java.util.List<java.lang.Integer> integers, JavaRowFormat format)
Projects a given collection of fields from this input record, into a particular preferred output format.PhysType
PhysTypeImpl. project(java.util.List<java.lang.Integer> integers, boolean indicator, JavaRowFormat format)
PhysType
PhysTypeImpl. project(java.util.List<java.lang.Integer> integers, JavaRowFormat format)
Methods in org.apache.calcite.adapter.enumerable with parameters of type PhysType Modifier and Type Method Description Expression
PhysType. convertTo(Expression expression, PhysType targetPhysType)
Converts an enumerable of this physical type to an enumerable that uses a given physical type for its rows.Expression
PhysTypeImpl. convertTo(Expression exp, PhysType targetPhysType)
private void
EnumerableWindow. declareAndResetState(JavaTypeFactory typeFactory, BlockBuilder builder, EnumerableRel.Result result, int windowIdx, java.util.List<AggImpState> aggs, PhysType outputPhysType, java.util.List<Expression> outputRow)
private void
EnumerableAggregate. declareParentAccumulator(java.util.List<Expression> initExpressions, BlockBuilder initBlock, PhysType accPhysType)
private Expression
EnumerableTableScan. fieldExpression(ParameterExpression row_, int i, PhysType physType, JavaRowFormat format)
private java.util.function.Function<BlockBuilder,WinAggFrameResultContext>
EnumerableWindow. getBlockBuilderWinAggFrameResultContextFunction(JavaTypeFactory typeFactory, SqlConformance conformance, EnumerableRel.Result result, java.util.List<Expression> translatedConstants, Expression comparator_, Expression rows_, ParameterExpression i_, Expression startX, Expression endX, Expression minX, Expression maxX, Expression hasRows, Expression frameRowCount, Expression partitionRowCount, DeclarationStatement jDecl, PhysType inputPhysType)
private Expression
EnumerableTableScan. getExpression(PhysType physType)
private Pair<Expression,Expression>
EnumerableWindow. getPartitionIterator(BlockBuilder builder, Expression source_, PhysType inputPhysType, Window.Group group, Expression comparator_)
private Pair<Expression,Expression>
EnumerableWindow. getRowCollationKey(BlockBuilder builder, PhysType inputPhysType, Window.Group group, int windowIdx)
private void
EnumerableAggregate. implementLambdaFactory(BlockBuilder builder, PhysType inputPhysType, java.util.List<AggImpState> aggs, Expression accumulatorInitializer, boolean hasOrderedCall, ParameterExpression lambdaFactory)
Implements theAggregateLambdaFactory
.(package private) static Expression
EnumUtils. joinSelector(JoinRelType joinType, PhysType physType, java.util.List<PhysType> inputPhysTypes)
(package private) static Expression
EnumUtils. joinSelector(SemiJoinType semiJoinType, PhysType physType, java.util.List<PhysType> inputPhysTypes)
(package private) Expression
EnumerableThetaJoin. predicate(EnumerableRelImplementor implementor, BlockBuilder builder, PhysType leftPhysType, PhysType rightPhysType, RexNode condition)
void
EnumerableRelImplementor. registerCorrelVariable(java.lang.String name, ParameterExpression pe, BlockBuilder corrBlock, PhysType physType)
EnumerableRel.Result
EnumerableRelImplementor. result(PhysType physType, BlockStatement block)
private Expression
EnumerableTableScan. toRows(PhysType physType, Expression expression)
private Expression
EnumerableWindow. translateBound(RexToLixTranslator translator, ParameterExpression i_, Expression row_, Expression min_, Expression max_, Expression rows_, Window.Group group, boolean lower, PhysType physType, Expression rowComparator, Expression keySelector, Expression keyComparator)
static java.util.List<Expression>
RexToLixTranslator. translateProjects(RexProgram program, JavaTypeFactory typeFactory, SqlConformance conformance, BlockBuilder list, PhysType outputPhysType, Expression root, RexToLixTranslator.InputGetter inputGetter, Function1<java.lang.String,RexToLixTranslator.InputGetter> correlates)
Translates aRexProgram
to a sequence of expressions and declarations.Method parameters in org.apache.calcite.adapter.enumerable with type arguments of type PhysType Modifier and Type Method Description (package private) static Expression
EnumUtils. joinSelector(JoinRelType joinType, PhysType physType, java.util.List<PhysType> inputPhysTypes)
(package private) static Expression
EnumUtils. joinSelector(SemiJoinType semiJoinType, PhysType physType, java.util.List<PhysType> inputPhysTypes)
Constructors in org.apache.calcite.adapter.enumerable with parameters of type PhysType Constructor Description Result(BlockStatement block, PhysType physType, JavaRowFormat format)
WindowRelInputGetter(Expression row, PhysType rowPhysType, int actualInputFieldCount, java.util.List<Expression> constants)
Constructor parameters in org.apache.calcite.adapter.enumerable with type arguments of type PhysType Constructor Description InputGetterImpl(java.util.List<Pair<Expression,PhysType>> inputs)
-
Uses of PhysType in org.apache.calcite.adapter.enumerable.impl
Fields in org.apache.calcite.adapter.enumerable.impl declared as PhysType Modifier and Type Field Description private PhysType
AggResultContextImpl. keyPhysType
Constructors in org.apache.calcite.adapter.enumerable.impl with parameters of type PhysType Constructor Description AggResultContextImpl(BlockBuilder block, AggregateCall call, java.util.List<Expression> accumulator, ParameterExpression key, PhysType keyPhysType)
Creates aggregate result context. -
Uses of PhysType in org.apache.calcite.adapter.jdbc
Methods in org.apache.calcite.adapter.jdbc with parameters of type PhysType Modifier and Type Method Description private void
JdbcToEnumerableConverter. generateGet(EnumerableRelImplementor implementor, PhysType physType, BlockBuilder builder, ParameterExpression resultSet_, int i, Expression target, Expression calendar_, SqlDialect.CalendarPolicy calendarPolicy)
-
Uses of PhysType in org.apache.calcite.adapter.spark
Fields in org.apache.calcite.adapter.spark declared as PhysType Modifier and Type Field Description PhysType
SparkRel.Result. physType
Methods in org.apache.calcite.adapter.spark with parameters of type PhysType Modifier and Type Method Description (package private) abstract SparkRel.Result
SparkRel.Implementor. result(PhysType physType, BlockStatement blockStatement)
SparkRel.Result
SparkToEnumerableConverter.SparkImplementorImpl. result(PhysType physType, BlockStatement blockStatement)
Constructors in org.apache.calcite.adapter.spark with parameters of type PhysType Constructor Description Result(PhysType physType, BlockStatement block)
-