public class Aggregate extends PlanNode implements scala.Product, scala.Serializable
Aggregate
and a simple Select
.Constructor and Description |
---|
Aggregate(PlanNode input,
scala.collection.Seq<scala.Tuple2<String,Aggregations>> aggregations) |
Modifier and Type | Method and Description |
---|---|
scala.collection.Seq<scala.Tuple2<String,Aggregations>> |
aggregations() |
scala.collection.Seq<PlanNode> |
children()
List of child nodes that should be considered when doing transformations.
|
PlanNode |
input() |
scala.collection.Seq<scala.Tuple2<String,TypeInformation<?>>> |
outputFields() |
String |
toString() |
exists, fastEquals, makeCopy, transformChildrenPost, transformChildrenPre, transformPost, transformPre
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
public Aggregate(PlanNode input, scala.collection.Seq<scala.Tuple2<String,Aggregations>> aggregations)
public PlanNode input()
public scala.collection.Seq<scala.Tuple2<String,Aggregations>> aggregations()
public scala.collection.Seq<PlanNode> children()
TreeNode
public scala.collection.Seq<scala.Tuple2<String,TypeInformation<?>>> outputFields()
outputFields
in class PlanNode
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.