Hierarchy For Package org.apache.nemo.compiler.frontend.beam.transform

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • org.apache.nemo.compiler.frontend.beam.transform.AbstractDoFnTransform<InputT,InterT,OutputT> (implements org.apache.nemo.common.ir.vertex.transform.Transform<I,O>)
    • org.apache.nemo.compiler.frontend.beam.transform.DoFnTransform<InputT,OutputT>
    • org.apache.nemo.compiler.frontend.beam.transform.GBKTransform<K,InputT,OutputT>
    • org.apache.nemo.compiler.frontend.beam.transform.PushBackDoFnTransform<InputT,OutputT>
  • org.apache.beam.sdk.transforms.Combine.CombineFn<InputT,AccumT,OutputT>
    • org.apache.nemo.compiler.frontend.beam.transform.FinalCombineFn<AccumT,Output>
    • org.apache.nemo.compiler.frontend.beam.transform.PartialCombineFn<InputT,AccumT>
  • org.apache.nemo.compiler.frontend.beam.transform.CreateViewTransform.MultiView<T> (implements org.apache.beam.sdk.transforms.Materializations.MultimapView<K,V>, java.io.Serializable)
  • org.apache.nemo.compiler.frontend.beam.transform.DefaultOutputManager<OutputT> (implements org.apache.beam.runners.core.DoFnRunners.OutputManager)
  • org.apache.nemo.compiler.frontend.beam.transform.GBKTransform.GBKOutputCollector (implements org.apache.nemo.common.ir.OutputCollector<O>)
  • org.apache.nemo.compiler.frontend.beam.transform.InMemoryStateInternalsFactory<K> (implements org.apache.beam.runners.core.StateInternalsFactory<K>)
  • org.apache.nemo.compiler.frontend.beam.transform.InMemoryTimerInternalsFactory<K> (implements org.apache.beam.runners.core.TimerInternalsFactory<K>)
  • org.apache.nemo.common.ir.vertex.transform.LatencymarkEmitTransform<I,O> (implements org.apache.nemo.common.ir.vertex.transform.Transform<I,O>)
    • org.apache.nemo.compiler.frontend.beam.transform.CreateViewTransform<I,O>
    • org.apache.nemo.compiler.frontend.beam.transform.FlattenTransform<T>
    • org.apache.nemo.compiler.frontend.beam.transform.SideInputTransform<T>
    • org.apache.nemo.compiler.frontend.beam.transform.WindowFnTransform<T,W>
  • org.apache.nemo.common.ir.vertex.transform.NoWatermarkEmitTransform<I,O> (implements org.apache.nemo.common.ir.vertex.transform.Transform<I,O>)
    • org.apache.nemo.compiler.frontend.beam.transform.CombineFnFinalTransform<K,A,O>
    • org.apache.nemo.compiler.frontend.beam.transform.CombineFnPartialTransform<K,I,A>
    • org.apache.nemo.compiler.frontend.beam.transform.GroupByKeyTransform<I>
  • org.apache.beam.sdk.transforms.PTransform<InputT,OutputT> (implements org.apache.beam.sdk.transforms.display.HasDisplayData, java.io.Serializable)
    • org.apache.nemo.compiler.frontend.beam.transform.LoopCompositeTransform<inputT,outputT> (implements java.io.Serializable)