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.table.runtime.aggregate.DataSetPreAggFunction (implements org.apache.flink.table.codegen.Compiler<T>, org.apache.flink.api.common.functions.GroupCombineFunction<IN,OUT>, org.apache.flink.table.util.Logging, org.apache.flink.api.common.functions.MapPartitionFunction<T,O>)
- org.apache.flink.table.runtime.aggregate.DataSetSessionWindowAggregatePreProcessor (implements org.apache.flink.table.codegen.Compiler<T>, org.apache.flink.api.common.functions.GroupCombineFunction<IN,OUT>, org.apache.flink.table.util.Logging, org.apache.flink.api.common.functions.MapPartitionFunction<T,O>, org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>)
- org.apache.flink.streaming.api.functions.ProcessFunction<I,O>
- 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.RichFlatMapFunction<IN,OUT> (implements org.apache.flink.api.common.functions.FlatMapFunction<T,O>)
- org.apache.flink.api.common.functions.RichGroupReduceFunction<IN,OUT> (implements org.apache.flink.api.common.functions.GroupReduceFunction<T,O>)
- org.apache.flink.table.runtime.aggregate.DataSetAggFunction (implements org.apache.flink.table.codegen.Compiler<T>, org.apache.flink.table.util.Logging)
- org.apache.flink.table.runtime.aggregate.DataSetFinalAggFunction (implements org.apache.flink.table.codegen.Compiler<T>, org.apache.flink.table.util.Logging)
- org.apache.flink.table.runtime.aggregate.DataSetSessionWindowAggReduceGroupFunction (implements org.apache.flink.table.codegen.Compiler<T>, org.apache.flink.table.util.Logging)
- org.apache.flink.table.runtime.aggregate.DataSetSlideTimeWindowAggReduceGroupFunction (implements org.apache.flink.api.common.functions.CombineFunction<IN,OUT>, org.apache.flink.table.codegen.Compiler<T>, org.apache.flink.table.util.Logging, org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>)
- org.apache.flink.table.runtime.aggregate.DataSetSlideWindowAggReduceGroupFunction (implements org.apache.flink.table.codegen.Compiler<T>, org.apache.flink.table.util.Logging)
- org.apache.flink.table.runtime.aggregate.DataSetTumbleCountWindowAggReduceGroupFunction (implements org.apache.flink.table.codegen.Compiler<T>, org.apache.flink.table.util.Logging)
- org.apache.flink.table.runtime.aggregate.DataSetTumbleTimeWindowAggReduceGroupFunction (implements org.apache.flink.table.codegen.Compiler<T>, org.apache.flink.table.util.Logging)
- 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.AggregateAggFunction (implements org.apache.flink.api.common.functions.AggregateFunction<IN,ACC,OUT>, org.apache.flink.table.codegen.Compiler<T>, org.apache.flink.table.util.Logging)
- org.apache.flink.table.runtime.aggregate.AggregateUtil
- org.apache.flink.table.runtime.aggregate.AggregateUtil$
- org.apache.flink.table.runtime.aggregate.DistinctReduce (implements org.apache.flink.api.common.functions.ReduceFunction<T>)
- org.apache.flink.table.runtime.aggregate.GeneratedAggregations (implements org.apache.flink.api.common.functions.Function)
- org.apache.flink.table.runtime.aggregate.SingleElementIterable<T> (implements java.lang.Iterable<T>)
- org.apache.flink.table.runtime.aggregate.SingleElementIterable.SingleElementIterator (implements java.util.Iterator<E>)
- org.apache.flink.table.runtime.aggregate.TimeWindowPropertyCollector<T> (implements org.apache.flink.util.Collector<T>)
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.