Package org.apache.calcite.adapter.enumerable
package org.apache.calcite.adapter.enumerable
Query optimizer rules for Java calling convention.
-
ClassDescriptionInformation for a call to
AggImplementor.implementAdd(AggContext, AggAddContext)
.Information on the aggregate calculation context.Implements an aggregate function by generating expressions to initialize, add to, and get a result from, an accumulator.Represents internal state when implementing aggregate functions.AggregateLambdaFactory<TSource,TOrigAccumulate, TAccumulate, TResult, TKey> Generates lambda functions used inEnumerableAggregate
.Information for a call toAggImplementor.implementReset(AggContext, AggResetContext)
.Information for a call toAggImplementor.implementResult(AggContext, AggResultContext)
BasicAggregateLambdaFactory<TSource,TAccumulate, TResult, TKey> Implementation ofAggregateLambdaFactory
that applies a sequence of accumulator adders to input source.BasicLazyAccumulator<TAccumulate,TSource> Performs accumulation against a pre-collected list of input sources, used withLazyAggregateLambdaFactory
.Implements a call via given translator.Implementation ofAggregate
inenumerable calling convention
.Base class for EnumerableAggregate and EnumerableSortedAggregate.Implementation ofLogicalAsofJoin
inenumerable calling convention
.Implementation of batch nested loop join inenumerable calling convention
.Rule to convert aLogicalJoin
to anEnumerableBatchNestedLoopJoin
.Rule configuration.Relational expression that converts an enumerable input to interpretable calling convention.Rule that converts any enumerable relational expression to bindable.Implementation ofCalc
inenumerable calling convention
.Implementation ofCollect
inenumerable calling convention
.Family of calling conventions that return results as anEnumerable
.Implementation ofCorrelate
inenumerable calling convention
.Implementation of nested loops over enumerable inputs.Implementation ofFilter
inenumerable calling convention
.Variant ofFilterToCalcRule
forenumerable calling convention
.Rule configuration.Implementation ofJoin
inenumerable calling convention
.Relational expression that converts an enumerable input to interpretable calling convention.Relational expression that executes its children using an interpreter.Implementation ofIntersect
inenumerable calling convention
.Relational expression that applies a limit and/or offset to its input.Rule to convert anSort
that hasoffset
orfetch
set to anEnumerableLimit
on top of a "pure"Sort
that has no offset or fetch.Rule configuration.Implementation ofSort
inenumerable calling convention
.Rule configuration.Implementation ofMatch
inenumerable calling convention
.Rule to convert aLogicalMatch
to anEnumerableMatch
.Implementation ofJoin
inenumerable calling convention
using a merge algorithm.Implementation ofUnion
inenumerable calling convention
.Rule configuration.Implementation ofMinus
inenumerable calling convention
.Implementation ofJoin
inenumerable calling convention
that allows conditions that are not just=
(equals).Implementation ofProject
inenumerable calling convention
.Variant ofProjectToCalcRule
forenumerable calling convention
.Rule configuration.A relational expression of one of theEnumerableConvention
calling conventions.Preferred physical type.Result of implementing an enumerable relational expression by generating Java code.Contains factory interface and default implementation for creating various rel nodes.Subclass ofRelImplementor
for relational operators ofEnumerableConvention
calling convention.Implementation ofRepeatUnion
inenumerable calling convention
.Rule to convert aLogicalRepeatUnion
into anEnumerableRepeatUnion
.Rules and relational operators for theenumerable calling convention
.Implementation ofSort
inenumerable calling convention
.Sort based physical implementation ofAggregate
inenumerable calling convention
.Implementation ofTableFunctionScan
inenumerable calling convention
.Rule to convert aLogicalTableFunctionScan
to anEnumerableTableFunctionScan
.Implementation ofTableModify
inenumerable calling convention
.Planner rule that converts aLogicalTableModify
to anEnumerableTableModify
.Implementation ofTableScan
inenumerable calling convention
.Planner rule that converts aLogicalTableScan
to anEnumerableTableScan
.Implementation ofTableSpool
inenumerable calling convention
that writes into aModifiableTable
(which must exist in the current schema).Rule to convert aLogicalTableSpool
into anEnumerableTableSpool
.Implementation ofUncollect
inenumerable calling convention
.Implementation ofUnion
inenumerable calling convention
.Implementation ofValues
inenumerable calling convention
.Planner rule that converts aLogicalValues
to anEnumerableValues
.Implementation ofWindow
inenumerable calling convention
.Utilities for generating programs in the Enumerable (functional) style.Abstract base class for implementations ofRelImplementor
that generate java code.How a row is represented as a Java value.LazyAggregateLambdaFactory<TSource,TKey, TOrigAccumulate, TResult> Generate aggregate lambdas that preserve the input source before calling each aggregate adder, this implementation is generally used when we need to sort the input before performing aggregation.LazyAggregateLambdaFactory.LazyAccumulator<TOrigAccumulate,TSource> Accumulate on the cached input sources.Cache the input sources.Implementor of Functions used in MATCH_RECOGNIZE Context.Class with static Helpers for MATCH_RECOGNIZE.Allows to build nested code blocks with tracking of current context.Allows to build nested code blocks with tracking of current context.Simplified version ofCallImplementor
that does not know about null semantics.Describes when a function/operator will return null.Physical type of a row.Implementation ofPhysType
.Implementation ofNotNullImplementor
that calls a givenMethod
.Contains implementations of Rex operators as Java code.Implementor for theLAG
windowed aggregate function.Implementor for theLEAD
windowed aggregate function.Strategy what an operator should return if one of its arguments is null.Null-safe implementor ofRexCall
s.Implementor for user-defined aggregate functions.TranslatesREX expressions
tolinq4j expressions
.Translates a field of an input to an expression.Implementation ofRexToLixTranslator.InputGetter
that callsPhysType.fieldReference(org.apache.calcite.linq4j.tree.Expression, int)
.Result of translating aRexNode
.SourceSorter<TAccumulate,TSource, TSortKey> Helper that combines the sorting process and accumulating process against the aggregate execution, used withLazyAggregateLambdaFactory
.The base implementation of strict aggregate function.The base implementation of strict window aggregate function.Implements a table-valued function call.Information for a call toAggImplementor.implementAdd(AggContext, AggAddContext)
.Marker interface to allowAggImplementor
to tell if it is used in regular or windowed context.Provides information on the current window.Provides information on the current window when computing the result of the aggregation.Implements a windowed aggregate function by generating expressions to initialize, add to, and get a result from, an accumulator.Allows to access rows in window partition relative to first/last and current row.Information for a call toAggImplementor.implementReset(AggContext, AggResetContext)
.Information for a call toAggImplementor.implementResult(AggContext, AggResultContext)
.