Hierarchy For Package org.apache.nemo.runtime.executor.datatransfer

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • org.apache.nemo.runtime.executor.datatransfer.BlockInputReader (implements org.apache.nemo.runtime.executor.datatransfer.InputReader)
  • org.apache.nemo.runtime.executor.datatransfer.BlockOutputWriter (implements org.apache.nemo.runtime.executor.datatransfer.OutputWriter)
  • org.apache.nemo.runtime.executor.datatransfer.DataFetcherOutputCollector<O> (implements org.apache.nemo.common.ir.OutputCollector<O>)
  • org.apache.nemo.runtime.executor.datatransfer.IntermediateDataIOFactory
  • org.apache.nemo.runtime.executor.datatransfer.MultiInputWatermarkManager (implements org.apache.nemo.runtime.executor.datatransfer.InputWatermarkManager)
  • org.apache.nemo.runtime.executor.datatransfer.NemoEventDecoderFactory (implements org.apache.nemo.common.coder.DecoderFactory<T>)
  • org.apache.nemo.runtime.executor.datatransfer.NemoEventEncoderFactory (implements org.apache.nemo.common.coder.EncoderFactory<T>)
  • org.apache.nemo.runtime.executor.datatransfer.NextIntraTaskOperatorInfo
  • org.apache.nemo.runtime.executor.datatransfer.OperatorVertexOutputCollector<O> (implements org.apache.nemo.common.ir.OutputCollector<O>)
  • org.apache.nemo.runtime.executor.datatransfer.OperatorWatermarkCollector (implements org.apache.nemo.common.ir.OutputCollector<O>)
  • org.apache.nemo.runtime.executor.datatransfer.PipeInputReader (implements org.apache.nemo.runtime.executor.datatransfer.InputReader)
  • org.apache.nemo.runtime.executor.datatransfer.PipeOutputWriter (implements org.apache.nemo.runtime.executor.datatransfer.OutputWriter)
  • org.apache.nemo.runtime.executor.datatransfer.RunTimeMessageOutputCollector<O> (implements org.apache.nemo.common.ir.OutputCollector<O>)
  • org.apache.nemo.runtime.executor.datatransfer.SingleInputWatermarkManager (implements org.apache.nemo.runtime.executor.datatransfer.InputWatermarkManager)
  • org.apache.nemo.runtime.executor.datatransfer.WatermarkWithIndex (implements java.io.Serializable)

Interface Hierarchy

• org.apache.nemo.runtime.executor.datatransfer.InputReader
• org.apache.nemo.runtime.executor.datatransfer.InputWatermarkManager
• org.apache.nemo.runtime.executor.datatransfer.OutputWriter