Package | Description |
---|---|
org.apache.flink.table.runtime.aggregate |
Modifier and Type | Method and Description |
---|---|
static IncrementalAggregateReduceFunction |
AggregateUtil.createIncrementalAggregateReduceFunction(scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputType,
org.apache.calcite.rel.type.RelDataType outputType,
int[] groupings)
Create a
ReduceFunction for incremental window
aggregation. |
IncrementalAggregateReduceFunction |
AggregateUtil$.createIncrementalAggregateReduceFunction(scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputType,
org.apache.calcite.rel.type.RelDataType outputType,
int[] groupings)
Create a
ReduceFunction for incremental window
aggregation. |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.