public interface FlinkAggregate
Modifier and Type | Method and Description |
---|---|
String |
aggregationToString(org.apache.calcite.rel.type.RelDataType inputType,
int[] grouping,
org.apache.calcite.rel.type.RelDataType rowType,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> namedProperties) |
String |
groupingToString(org.apache.calcite.rel.type.RelDataType inputType,
int[] grouping) |
String groupingToString(org.apache.calcite.rel.type.RelDataType inputType, int[] grouping)
String aggregationToString(org.apache.calcite.rel.type.RelDataType inputType, int[] grouping, org.apache.calcite.rel.type.RelDataType rowType, scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates, scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> namedProperties)
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.