Hierarchy For All Packages

Package Hierarchies:

• org.apache.flink.api.java.hadoop.common,
• org.apache.flink.api.java.hadoop.mapred,
• org.apache.flink.api.java.hadoop.mapred.utils,
• org.apache.flink.api.java.hadoop.mapred.wrapper,
• org.apache.flink.api.java.hadoop.mapreduce,
• org.apache.flink.api.java.hadoop.mapreduce.utils,
• org.apache.flink.api.java.hadoop.mapreduce.wrapper,
• org.apache.flink.api.java.typeutils,
• org.apache.flink.api.java.typeutils.runtime,
• org.apache.flink.hadoopcompatibility,
• org.apache.flink.hadoopcompatibility.mapred,
• org.apache.flink.hadoopcompatibility.mapred.wrapper

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.api.common.functions.RichFlatMapFunction<IN,OUT> (implements org.apache.flink.api.common.functions.FlatMapFunction<T,O>)
      • org.apache.flink.hadoopcompatibility.mapred.HadoopMapFunction<KEYIN,VALUEIN,KEYOUT,VALUEOUT> (implements org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>, java.io.Serializable)
    • 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.hadoopcompatibility.mapred.HadoopReducerWrappedFunction<KEYIN,VALUEIN,KEYOUT,VALUEOUT> (implements org.apache.flink.streaming.api.functions.windowing.AllWindowFunction<IN,OUT,W>, org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>, java.io.Serializable)
  • org.apache.flink.api.common.typeutils.GenericTypeSerializerSnapshot<T,S> (implements org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<T>)
    • org.apache.flink.api.java.typeutils.runtime.WritableSerializer.WritableSerializerSnapshot<T>
  • org.apache.flink.api.java.hadoop.mapred.wrapper.HadoopDummyProgressable (implements org.apache.hadoop.util.Progressable)
  • org.apache.flink.api.java.hadoop.mapred.wrapper.HadoopDummyReporter (implements org.apache.hadoop.mapred.Reporter)
  • org.apache.flink.hadoopcompatibility.HadoopInputs
  • org.apache.flink.hadoopcompatibility.mapred.wrapper.HadoopOutputCollector<KEY,VALUE> (implements org.apache.hadoop.mapred.OutputCollector<K,V>)
  • org.apache.flink.api.java.hadoop.mapred.utils.HadoopUtils
  • org.apache.flink.api.java.hadoop.mapreduce.utils.HadoopUtils
  • org.apache.flink.hadoopcompatibility.HadoopUtils
  • org.apache.flink.core.io.LocatableInputSplit (implements org.apache.flink.core.io.InputSplit, java.io.Serializable)
    • org.apache.flink.api.java.hadoop.mapred.wrapper.HadoopInputSplit
    • org.apache.flink.api.java.hadoop.mapreduce.wrapper.HadoopInputSplit
  • org.apache.flink.api.common.io.RichInputFormat<OT,T> (implements org.apache.flink.api.common.io.InputFormat<OT,T>)
    • org.apache.flink.api.java.hadoop.common.HadoopInputFormatCommonBase<T,SPITTYPE>
      • org.apache.flink.api.java.hadoop.mapred.HadoopInputFormatBase<K,V,T>
        • org.apache.flink.api.java.hadoop.mapred.HadoopInputFormat<K,V> (implements org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>)
      • org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormatBase<K,V,T>
        • org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormat<K,V> (implements org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>)
  • org.apache.flink.api.common.io.RichOutputFormat<IT> (implements org.apache.flink.api.common.io.OutputFormat<IT>)
    • org.apache.flink.api.java.hadoop.common.HadoopOutputFormatCommonBase<T>
      • org.apache.flink.api.java.hadoop.mapred.HadoopOutputFormatBase<K,V,T> (implements org.apache.flink.api.common.io.FinalizeOnMaster)
        • org.apache.flink.api.java.hadoop.mapred.HadoopOutputFormat<K,V>
      • org.apache.flink.api.java.hadoop.mapreduce.HadoopOutputFormatBase<K,V,T> (implements org.apache.flink.api.common.io.FinalizeOnMaster)
        • org.apache.flink.api.java.hadoop.mapreduce.HadoopOutputFormat<K,V>
  • org.apache.flink.api.common.operators.util.TupleUnwrappingIterator<T,K> (implements java.lang.Iterable<T>, java.util.Iterator<E>, java.io.Serializable)
    • org.apache.flink.hadoopcompatibility.mapred.wrapper.HadoopTupleUnwrappingIterator<KEY,VALUE> (implements java.io.Serializable)
  • org.apache.flink.api.common.typeutils.TypeComparator<T> (implements java.io.Serializable)
    • org.apache.flink.api.java.typeutils.runtime.WritableComparator<T>
  • org.apache.flink.api.common.typeinfo.TypeInformation<T> (implements java.io.Serializable)
    • org.apache.flink.api.java.typeutils.WritableTypeInfo<T> (implements org.apache.flink.api.common.typeinfo.AtomicType<T>)
  • org.apache.flink.api.common.typeutils.TypeSerializer<T> (implements java.io.Serializable)
    • org.apache.flink.api.java.typeutils.runtime.WritableSerializer<T>