Modifier and Type | Method and Description |
---|---|
GeneratedAggregationsFunction |
CodeGenerator.generateAggregations(String name,
CodeGenerator generator,
scala.collection.Seq<TypeInformation<?>> physicalInputTypes,
AggregateFunction<?,?>[] aggregates,
int[][] aggFields,
int[] aggMapping,
boolean partialResults,
int[] fwdMapping,
scala.Option<int[]> mergeMapping,
scala.Option<scala.Tuple2<Object,Object>[]> constantFlags,
int outputArity,
boolean needRetract,
boolean needMerge,
boolean needReset)
Generates a
GeneratedAggregations that can be
passed to a Java compiler. |
Modifier and Type | Method and Description |
---|---|
<T extends Function> |
CommonCalc.generateFunction(CodeGenerator generator,
String ruleDescription,
RowSchema inputSchema,
RowSchema returnSchema,
org.apache.calcite.rex.RexProgram calcProgram,
TableConfig config,
Class<T> functionClass) |
Modifier and Type | Method and Description |
---|---|
DataStream<CRow> |
DataStreamOverAggregate.createBoundedAndCurrentRowOverWindow(StreamQueryConfig queryConfig,
CodeGenerator generator,
DataStream<CRow> inputDS,
boolean isRowTimeType,
boolean isRowsClause) |
DataStream<CRow> |
DataStreamOverAggregate.createUnboundedAndCurrentRowOverWindow(StreamQueryConfig queryConfig,
CodeGenerator generator,
DataStream<CRow> inputDS,
boolean isRowTimeType,
boolean isRowsClause) |
Modifier and Type | Method and Description |
---|---|
static <T extends Function> |
FlinkLogicalCalc.generateFunction(CodeGenerator generator,
String ruleDescription,
RowSchema inputSchema,
RowSchema returnSchema,
org.apache.calcite.rex.RexProgram calcProgram,
TableConfig config,
Class<T> functionClass) |
Modifier and Type | Method and Description |
---|---|
static ProcessFunction<CRow,CRow> |
AggregateUtil.createBoundedOverProcessFunction(CodeGenerator generator,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputType,
TypeInformation<Row> inputTypeInfo,
scala.collection.Seq<TypeInformation<?>> inputFieldTypeInfo,
long precedingOffset,
StreamQueryConfig queryConfig,
boolean isRowsClause,
boolean isRowTimeType)
Create an
ProcessFunction for ROWS clause
bounded OVER window to evaluate final aggregate value. |
ProcessFunction<CRow,CRow> |
AggregateUtil$.createBoundedOverProcessFunction(CodeGenerator generator,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputType,
TypeInformation<Row> inputTypeInfo,
scala.collection.Seq<TypeInformation<?>> inputFieldTypeInfo,
long precedingOffset,
StreamQueryConfig queryConfig,
boolean isRowsClause,
boolean isRowTimeType)
Create an
ProcessFunction for ROWS clause
bounded OVER window to evaluate final aggregate value. |
static scala.Tuple3<scala.Option<DataSetPreAggFunction>,scala.Option<TypeInformation<Row>>,RichGroupReduceFunction<Row,Row>> |
AggregateUtil.createDataSetAggregateFunctions(CodeGenerator generator,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputType,
scala.collection.Seq<TypeInformation<?>> inputFieldTypeInfo,
org.apache.calcite.rel.type.RelDataType outputType,
int[] groupings,
boolean inGroupingSet)
Create functions to compute a
DataSetAggregate . |
scala.Tuple3<scala.Option<DataSetPreAggFunction>,scala.Option<TypeInformation<Row>>,RichGroupReduceFunction<Row,Row>> |
AggregateUtil$.createDataSetAggregateFunctions(CodeGenerator generator,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputType,
scala.collection.Seq<TypeInformation<?>> inputFieldTypeInfo,
org.apache.calcite.rel.type.RelDataType outputType,
int[] groupings,
boolean inGroupingSet)
Create functions to compute a
DataSetAggregate . |
static RichGroupReduceFunction<Row,Row> |
AggregateUtil.createDataSetSlideWindowPrepareGroupReduceFunction(CodeGenerator generator,
LogicalWindow window,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
int[] groupings,
org.apache.calcite.rel.type.RelDataType physicalInputRowType,
scala.collection.Seq<TypeInformation<?>> physicalInputTypes,
boolean isParserCaseSensitive)
Create a
GroupReduceFunction that prepares for
partial aggregates of sliding windows (time and count-windows). |
RichGroupReduceFunction<Row,Row> |
AggregateUtil$.createDataSetSlideWindowPrepareGroupReduceFunction(CodeGenerator generator,
LogicalWindow window,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
int[] groupings,
org.apache.calcite.rel.type.RelDataType physicalInputRowType,
scala.collection.Seq<TypeInformation<?>> physicalInputTypes,
boolean isParserCaseSensitive)
Create a
GroupReduceFunction that prepares for
partial aggregates of sliding windows (time and count-windows). |
static GroupCombineFunction<Row,Row> |
AggregateUtil.createDataSetWindowAggregationCombineFunction(CodeGenerator generator,
LogicalWindow window,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType physicalInputRowType,
scala.collection.Seq<TypeInformation<?>> physicalInputTypes,
int[] groupings)
Create a
GroupCombineFunction that pre-aggregation
for aggregates. |
GroupCombineFunction<Row,Row> |
AggregateUtil$.createDataSetWindowAggregationCombineFunction(CodeGenerator generator,
LogicalWindow window,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType physicalInputRowType,
scala.collection.Seq<TypeInformation<?>> physicalInputTypes,
int[] groupings)
Create a
GroupCombineFunction that pre-aggregation
for aggregates. |
static RichGroupReduceFunction<Row,Row> |
AggregateUtil.createDataSetWindowAggregationGroupReduceFunction(CodeGenerator generator,
LogicalWindow window,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType physicalInputRowType,
scala.collection.Seq<TypeInformation<?>> physicalInputTypes,
org.apache.calcite.rel.type.RelDataType outputType,
int[] groupings,
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> properties,
boolean isInputCombined)
Create a
GroupReduceFunction to compute window
aggregates on batch tables. |
RichGroupReduceFunction<Row,Row> |
AggregateUtil$.createDataSetWindowAggregationGroupReduceFunction(CodeGenerator generator,
LogicalWindow window,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType physicalInputRowType,
scala.collection.Seq<TypeInformation<?>> physicalInputTypes,
org.apache.calcite.rel.type.RelDataType outputType,
int[] groupings,
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> properties,
boolean isInputCombined)
Create a
GroupReduceFunction to compute window
aggregates on batch tables. |
static MapPartitionFunction<Row,Row> |
AggregateUtil.createDataSetWindowAggregationMapPartitionFunction(CodeGenerator generator,
LogicalWindow window,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType physicalInputRowType,
scala.collection.Seq<TypeInformation<?>> physicalInputTypes,
int[] groupings)
Create a
MapPartitionFunction that aggregation
for aggregates. |
MapPartitionFunction<Row,Row> |
AggregateUtil$.createDataSetWindowAggregationMapPartitionFunction(CodeGenerator generator,
LogicalWindow window,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType physicalInputRowType,
scala.collection.Seq<TypeInformation<?>> physicalInputTypes,
int[] groupings)
Create a
MapPartitionFunction that aggregation
for aggregates. |
static MapFunction<Row,Row> |
AggregateUtil.createDataSetWindowPrepareMapFunction(CodeGenerator generator,
LogicalWindow window,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
int[] groupings,
org.apache.calcite.rel.type.RelDataType inputType,
scala.collection.Seq<TypeInformation<?>> inputFieldTypeInfo,
boolean isParserCaseSensitive)
Create a
MapFunction that prepares for aggregates. |
MapFunction<Row,Row> |
AggregateUtil$.createDataSetWindowPrepareMapFunction(CodeGenerator generator,
LogicalWindow window,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
int[] groupings,
org.apache.calcite.rel.type.RelDataType inputType,
scala.collection.Seq<TypeInformation<?>> inputFieldTypeInfo,
boolean isParserCaseSensitive)
Create a
MapFunction that prepares for aggregates. |
static scala.Tuple3<AggregateFunction<CRow,Row,Row>,RowTypeInfo,RowTypeInfo> |
AggregateUtil.createDataStreamAggregateFunction(CodeGenerator generator,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputType,
scala.collection.Seq<TypeInformation<?>> inputFieldTypeInfo,
org.apache.calcite.rel.type.RelDataType outputType,
int[] groupingKeys,
boolean needMerge) |
scala.Tuple3<AggregateFunction<CRow,Row,Row>,RowTypeInfo,RowTypeInfo> |
AggregateUtil$.createDataStreamAggregateFunction(CodeGenerator generator,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputType,
scala.collection.Seq<TypeInformation<?>> inputFieldTypeInfo,
org.apache.calcite.rel.type.RelDataType outputType,
int[] groupingKeys,
boolean needMerge) |
static ProcessFunction<CRow,CRow> |
AggregateUtil.createGroupAggregateFunction(CodeGenerator generator,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputRowType,
scala.collection.Seq<TypeInformation<?>> inputFieldTypes,
int[] groupings,
StreamQueryConfig queryConfig,
boolean generateRetraction,
boolean consumeRetraction)
Create an
ProcessFunction for group (without
window) aggregate to evaluate final aggregate value. |
ProcessFunction<CRow,CRow> |
AggregateUtil$.createGroupAggregateFunction(CodeGenerator generator,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputRowType,
scala.collection.Seq<TypeInformation<?>> inputFieldTypes,
int[] groupings,
StreamQueryConfig queryConfig,
boolean generateRetraction,
boolean consumeRetraction)
Create an
ProcessFunction for group (without
window) aggregate to evaluate final aggregate value. |
static ProcessFunction<CRow,CRow> |
AggregateUtil.createUnboundedOverProcessFunction(CodeGenerator generator,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputType,
TypeInformation<Row> inputTypeInfo,
scala.collection.Seq<TypeInformation<?>> inputFieldTypeInfo,
StreamQueryConfig queryConfig,
boolean isRowTimeType,
boolean isPartitioned,
boolean isRowsClause)
Create an
ProcessFunction for unbounded OVER
window to evaluate final aggregate value. |
ProcessFunction<CRow,CRow> |
AggregateUtil$.createUnboundedOverProcessFunction(CodeGenerator generator,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputType,
TypeInformation<Row> inputTypeInfo,
scala.collection.Seq<TypeInformation<?>> inputFieldTypeInfo,
StreamQueryConfig queryConfig,
boolean isRowTimeType,
boolean isPartitioned,
boolean isRowsClause)
Create an
ProcessFunction for unbounded OVER
window to evaluate final aggregate value. |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.