Hierarchy For Package org.apache.beam.runners.gearpump.translators

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • org.apache.beam.runners.gearpump.translators.CreateGearpumpPCollectionViewTranslator<ElemT,ViewT> (implements org.apache.beam.runners.gearpump.translators.TransformTranslator<T>)
  • org.apache.beam.runners.gearpump.translators.FlattenPCollectionsTranslator<T> (implements org.apache.beam.runners.gearpump.translators.TransformTranslator<T>)
  • org.apache.beam.runners.gearpump.translators.GroupByKeyTranslator<K,V> (implements org.apache.beam.runners.gearpump.translators.TransformTranslator<T>)
  • org.apache.beam.runners.gearpump.translators.GroupByKeyTranslator.GearpumpWindowFn<T,W> (implements java.io.Serializable, io.gearpump.streaming.dsl.window.api.WindowFunction)
  • org.apache.beam.runners.gearpump.translators.ParDoMultiOutputTranslator<InputT,OutputT> (implements org.apache.beam.runners.gearpump.translators.TransformTranslator<T>)
  • org.apache.beam.sdk.Pipeline.PipelineVisitor.Defaults (implements org.apache.beam.sdk.Pipeline.PipelineVisitor)
    • org.apache.beam.runners.gearpump.translators.GearpumpPipelineTranslator
  • org.apache.beam.runners.gearpump.translators.ReadBoundedTranslator<T> (implements org.apache.beam.runners.gearpump.translators.TransformTranslator<T>)
  • org.apache.beam.runners.gearpump.translators.ReadUnboundedTranslator<T> (implements org.apache.beam.runners.gearpump.translators.TransformTranslator<T>)
  • io.gearpump.streaming.dsl.api.functions.SerializableFunction (implements java.io.Serializable)
    • io.gearpump.streaming.dsl.javaapi.functions.FlatMapFunction<T,R>
      • org.apache.beam.runners.gearpump.translators.WindowAssignTranslator.AssignWindows<T>
    • io.gearpump.streaming.dsl.api.functions.FoldFunction<T,A>
      • org.apache.beam.runners.gearpump.translators.GroupByKeyTranslator.Merge<K,V>
    • io.gearpump.streaming.dsl.api.functions.MapFunction<T,R>
      • io.gearpump.streaming.dsl.javaapi.functions.GroupByFunction<T,GROUP>
        • org.apache.beam.runners.gearpump.translators.GroupByKeyTranslator.GroupByFn<K,V>
      • org.apache.beam.runners.gearpump.translators.GroupByKeyTranslator.KeyedByTimestamp<K,V>
  • org.apache.beam.runners.gearpump.translators.TranslationContext
  • org.apache.beam.runners.gearpump.translators.WindowAssignTranslator<T> (implements org.apache.beam.runners.gearpump.translators.TransformTranslator<T>)

Interface Hierarchy

• java.io.Serializable
  • org.apache.beam.runners.gearpump.translators.TransformTranslator<T>