Class Hierarchy
- java.lang.Object
- org.apache.flink.api.common.functions.AbstractRichFunction (implements org.apache.flink.api.common.functions.RichFunction, java.io.Serializable)
- org.apache.flink.streaming.api.functions.windowing.RichAllWindowFunction<IN,OUT,W> (implements org.apache.flink.streaming.api.functions.windowing.AllWindowFunction<IN,OUT,W>)
- org.apache.flink.api.common.functions.RichGroupReduceFunction<IN,OUT> (implements org.apache.flink.api.common.functions.GroupReduceFunction<T,O>)
- org.apache.flink.api.common.functions.RichMapFunction<IN,OUT> (implements org.apache.flink.api.common.functions.MapFunction<T,O>)
- org.apache.flink.streaming.api.functions.windowing.RichWindowFunction<IN,OUT,KEY,W> (implements org.apache.flink.streaming.api.functions.windowing.WindowFunction<IN,OUT,KEY,W>)
- org.apache.flink.table.runtime.aggregate.AggregateUtil
- org.apache.flink.table.runtime.aggregate.AggregateUtil$
- org.apache.flink.table.runtime.aggregate.AvgAggregate<T> (implements org.apache.flink.table.runtime.aggregate.Aggregate<T>)
- org.apache.flink.table.runtime.aggregate.CountAggregate (implements org.apache.flink.table.runtime.aggregate.Aggregate<T>)
- org.apache.flink.table.runtime.aggregate.DecimalMaxAggregate (implements org.apache.flink.table.runtime.aggregate.Aggregate<T>)
- org.apache.flink.table.runtime.aggregate.DecimalMinAggregate (implements org.apache.flink.table.runtime.aggregate.Aggregate<T>)
- org.apache.flink.table.runtime.aggregate.DecimalSumAggregate (implements org.apache.flink.table.runtime.aggregate.Aggregate<T>)
- org.apache.flink.table.runtime.aggregate.IncrementalAggregateReduceFunction (implements org.apache.flink.api.common.functions.ReduceFunction<T>)
- org.apache.flink.table.runtime.aggregate.MaxAggregate<T> (implements org.apache.flink.table.runtime.aggregate.Aggregate<T>)
- org.apache.flink.table.runtime.aggregate.MinAggregate<T> (implements org.apache.flink.table.runtime.aggregate.Aggregate<T>)
- org.apache.flink.table.runtime.aggregate.SumAggregate<T> (implements org.apache.flink.table.runtime.aggregate.Aggregate<T>)
- org.apache.flink.table.runtime.aggregate.TimeWindowPropertyCollector (implements org.apache.flink.util.Collector<T>)
Interface Hierarchy
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.