public class DataSetLogicalWindowAggregateRule extends LogicalWindowAggregateRule
Constructor and Description |
---|
DataSetLogicalWindowAggregateRule() |
Modifier and Type | Method and Description |
---|---|
static boolean |
equals(Object x$1) |
protected static boolean |
equals(org.apache.calcite.plan.RelOptRule x$1) |
org.apache.calcite.rex.RexNode |
getInAggregateGroupExpression(org.apache.calcite.rex.RexBuilder rexBuilder,
org.apache.calcite.rex.RexCall windowExpression)
Returns the operand of the group window function.
|
static org.apache.calcite.plan.RelOptRuleOperand |
getOperand() |
static List<org.apache.calcite.plan.RelOptRuleOperand> |
getOperands() |
org.apache.calcite.rex.RexNode |
getOutAggregateGroupExpression(org.apache.calcite.rex.RexBuilder rexBuilder,
org.apache.calcite.rex.RexCall windowExpression)
Returns a zero literal of the correct type.
|
static org.apache.calcite.plan.Convention |
getOutConvention() |
static org.apache.calcite.plan.RelTrait |
getOutTrait() |
static scala.collection.Seq<scala.Tuple2<org.apache.calcite.rex.RexCall,Object>> |
getWindowExpressions(org.apache.calcite.rel.logical.LogicalAggregate agg) |
static int |
hashCode() |
static DataSetLogicalWindowAggregateRule |
INSTANCE() |
static boolean |
matches(org.apache.calcite.plan.RelOptRuleCall call) |
static void |
onMatch(org.apache.calcite.plan.RelOptRuleCall call) |
static String |
toString() |
Window |
translateWindowExpression(org.apache.calcite.rex.RexCall windowExpr,
org.apache.calcite.rel.type.RelDataType rowType)
translate the group window expression in to a Flink Table window.
|
getWindowExpressions, matches, onMatch
public static DataSetLogicalWindowAggregateRule INSTANCE()
public static org.apache.calcite.plan.RelOptRuleOperand getOperand()
public static List<org.apache.calcite.plan.RelOptRuleOperand> getOperands()
public static int hashCode()
public static boolean equals(Object x$1)
protected static boolean equals(org.apache.calcite.plan.RelOptRule x$1)
public static org.apache.calcite.plan.Convention getOutConvention()
public static org.apache.calcite.plan.RelTrait getOutTrait()
public static final String toString()
public static boolean matches(org.apache.calcite.plan.RelOptRuleCall call)
public static void onMatch(org.apache.calcite.plan.RelOptRuleCall call)
public static scala.collection.Seq<scala.Tuple2<org.apache.calcite.rex.RexCall,Object>> getWindowExpressions(org.apache.calcite.rel.logical.LogicalAggregate agg)
public org.apache.calcite.rex.RexNode getInAggregateGroupExpression(org.apache.calcite.rex.RexBuilder rexBuilder, org.apache.calcite.rex.RexCall windowExpression)
getInAggregateGroupExpression
in class LogicalWindowAggregateRule
public org.apache.calcite.rex.RexNode getOutAggregateGroupExpression(org.apache.calcite.rex.RexBuilder rexBuilder, org.apache.calcite.rex.RexCall windowExpression)
getOutAggregateGroupExpression
in class LogicalWindowAggregateRule
public Window translateWindowExpression(org.apache.calcite.rex.RexCall windowExpr, org.apache.calcite.rel.type.RelDataType rowType)
LogicalWindowAggregateRule
translateWindowExpression
in class LogicalWindowAggregateRule
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.