Hierarchy For All Packages

Package Hierarchies:

• org.apache.nemo.client,
• org.apache.nemo.client.beam,
• org.apache.nemo.common,
• org.apache.nemo.common.coder,
• org.apache.nemo.common.dag,
• org.apache.nemo.common.eventhandler,
• org.apache.nemo.common.exception,
• org.apache.nemo.common.ir,
• org.apache.nemo.common.ir.edge,
• org.apache.nemo.common.ir.edge.executionproperty,
• org.apache.nemo.common.ir.executionproperty,
• org.apache.nemo.common.ir.vertex,
• org.apache.nemo.common.ir.vertex.executionproperty,
• org.apache.nemo.common.ir.vertex.transform,
• org.apache.nemo.common.ir.vertex.utility,
• org.apache.nemo.common.ir.vertex.utility.runtimepass,
• org.apache.nemo.common.partitioner,
• org.apache.nemo.common.pass,
• org.apache.nemo.common.punctuation,
• org.apache.nemo.common.test,
• org.apache.nemo.compiler,
• org.apache.nemo.compiler.backend,
• org.apache.nemo.compiler.backend.nemo,
• org.apache.nemo.compiler.backend.nemo.prophet,
• org.apache.nemo.compiler.frontend.beam,
• org.apache.nemo.compiler.frontend.beam.coder,
• org.apache.nemo.compiler.frontend.beam.source,
• org.apache.nemo.compiler.frontend.beam.transform,
• org.apache.nemo.compiler.frontend.spark,
• org.apache.nemo.compiler.optimizer,
• org.apache.nemo.compiler.optimizer.examples,
• org.apache.nemo.compiler.optimizer.pass.compiletime,
• org.apache.nemo.compiler.optimizer.pass.compiletime.annotating,
• org.apache.nemo.compiler.optimizer.pass.compiletime.composite,
• org.apache.nemo.compiler.optimizer.pass.compiletime.reshaping,
• org.apache.nemo.compiler.optimizer.pass.runtime,
• org.apache.nemo.compiler.optimizer.policy,
• org.apache.nemo.conf,
• org.apache.nemo.driver,
• org.apache.nemo.examples.beam,
• org.apache.nemo.examples.spark,
• org.apache.nemo.examples.spark.sql,
• org.apache.nemo.runtime.common,
• org.apache.nemo.runtime.common.comm,
• org.apache.nemo.runtime.common.exception,
• org.apache.nemo.runtime.common.message,
• org.apache.nemo.runtime.common.message.grpc,
• org.apache.nemo.runtime.common.message.local,
• org.apache.nemo.runtime.common.message.ncs,
• org.apache.nemo.runtime.common.metric,
• org.apache.nemo.runtime.common.plan,
• org.apache.nemo.runtime.common.state,
• org.apache.nemo.runtime.executor,
• org.apache.nemo.runtime.executor.data,
• org.apache.nemo.runtime.executor.data.block,
• org.apache.nemo.runtime.executor.data.metadata,
• org.apache.nemo.runtime.executor.data.partition,
• org.apache.nemo.runtime.executor.data.stores,
• org.apache.nemo.runtime.executor.data.streamchainer,
• org.apache.nemo.runtime.executor.datatransfer,
• org.apache.nemo.runtime.executor.task,
• org.apache.nemo.runtime.executor.transfer,
• org.apache.nemo.runtime.master,
• org.apache.nemo.runtime.master.metric,
• org.apache.nemo.runtime.master.resource,
• org.apache.nemo.runtime.master.scheduler,
• org.apache.nemo.runtime.master.servlet,
• org.apache.reef.runtime.yarn

Class Hierarchy

• java.lang.Object
  • org.apache.nemo.runtime.executor.data.stores.AbstractBlockStore (implements org.apache.nemo.runtime.executor.data.stores.BlockStore)
    • org.apache.nemo.runtime.executor.data.stores.GlusterFileStore (implements org.apache.nemo.runtime.executor.data.stores.RemoteFileStore)
    • org.apache.nemo.runtime.executor.data.stores.LocalBlockStore
      • org.apache.nemo.runtime.executor.data.stores.LocalFileStore
      • org.apache.nemo.runtime.executor.data.stores.MemoryStore
      • org.apache.nemo.runtime.executor.data.stores.SerializedMemoryStore
  • 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>
  • com.google.protobuf.AbstractMessageLite<MessageType,BuilderType> (implements com.google.protobuf.MessageLite)
    • com.google.protobuf.AbstractMessage (implements com.google.protobuf.Message)
      • com.google.protobuf.GeneratedMessageV3 (implements java.io.Serializable)
        • org.apache.nemo.runtime.common.comm.ControlMessage.BlockLocationInfoMsg (implements org.apache.nemo.runtime.common.comm.ControlMessage.BlockLocationInfoMsgOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.BlockStateChangedMsg (implements org.apache.nemo.runtime.common.comm.ControlMessage.BlockStateChangedMsgOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.BlockTransferContextDescriptor (implements org.apache.nemo.runtime.common.comm.ControlMessage.BlockTransferContextDescriptorOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.ByteTransferContextSetupMessage (implements org.apache.nemo.runtime.common.comm.ControlMessage.ByteTransferContextSetupMessageOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.ClientToDriverMessage (implements org.apache.nemo.runtime.common.comm.ControlMessage.ClientToDriverMessageOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.ContainerFailedMsg (implements org.apache.nemo.runtime.common.comm.ControlMessage.ContainerFailedMsgOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.DataCollectMessage (implements org.apache.nemo.runtime.common.comm.ControlMessage.DataCollectMessageOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.DriverToClientMessage (implements org.apache.nemo.runtime.common.comm.ControlMessage.DriverToClientMessageOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.ExecutorFailedMsg (implements org.apache.nemo.runtime.common.comm.ControlMessage.ExecutorFailedMsgOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.InMasterBroadcastVariableMessage (implements org.apache.nemo.runtime.common.comm.ControlMessage.InMasterBroadcastVariableMessageOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.LaunchDAGMessage (implements org.apache.nemo.runtime.common.comm.ControlMessage.LaunchDAGMessageOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.Message (implements org.apache.nemo.runtime.common.comm.ControlMessage.MessageOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.Metric (implements org.apache.nemo.runtime.common.comm.ControlMessage.MetricOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.MetricMsg (implements org.apache.nemo.runtime.common.comm.ControlMessage.MetricMsgOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.NotificationMessage (implements org.apache.nemo.runtime.common.comm.ControlMessage.NotificationMessageOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.PipeInitMessage (implements org.apache.nemo.runtime.common.comm.ControlMessage.PipeInitMessageOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.PipeLocationInfoMessage (implements org.apache.nemo.runtime.common.comm.ControlMessage.PipeLocationInfoMessageOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.PipeTransferContextDescriptor (implements org.apache.nemo.runtime.common.comm.ControlMessage.PipeTransferContextDescriptorOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.RequestBlockLocationMsg (implements org.apache.nemo.runtime.common.comm.ControlMessage.RequestBlockLocationMsgOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.RequestBroadcastVariableMessage (implements org.apache.nemo.runtime.common.comm.ControlMessage.RequestBroadcastVariableMessageOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.RequestPipeLocationMessage (implements org.apache.nemo.runtime.common.comm.ControlMessage.RequestPipeLocationMessageOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.RunTimePassMessageEntry (implements org.apache.nemo.runtime.common.comm.ControlMessage.RunTimePassMessageEntryOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.RunTimePassMessageMsg (implements org.apache.nemo.runtime.common.comm.ControlMessage.RunTimePassMessageMsgOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.ScheduleTaskMsg (implements org.apache.nemo.runtime.common.comm.ControlMessage.ScheduleTaskMsgOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.TaskStateChangedMsg (implements org.apache.nemo.runtime.common.comm.ControlMessage.TaskStateChangedMsgOrBuilder)
        • org.apache.nemo.runtime.common.comm.GrpcMessageService.Void (implements org.apache.nemo.runtime.common.comm.GrpcMessageService.VoidOrBuilder)
  • com.google.protobuf.AbstractMessageLite.Builder<MessageType,BuilderType> (implements com.google.protobuf.MessageLite.Builder)
    • com.google.protobuf.AbstractMessage.Builder<BuilderType> (implements com.google.protobuf.Message.Builder)
      • com.google.protobuf.GeneratedMessageV3.Builder<BuilderType>
        • org.apache.nemo.runtime.common.comm.ControlMessage.BlockLocationInfoMsg.Builder (implements org.apache.nemo.runtime.common.comm.ControlMessage.BlockLocationInfoMsgOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.BlockStateChangedMsg.Builder (implements org.apache.nemo.runtime.common.comm.ControlMessage.BlockStateChangedMsgOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.BlockTransferContextDescriptor.Builder (implements org.apache.nemo.runtime.common.comm.ControlMessage.BlockTransferContextDescriptorOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.ByteTransferContextSetupMessage.Builder (implements org.apache.nemo.runtime.common.comm.ControlMessage.ByteTransferContextSetupMessageOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.ClientToDriverMessage.Builder (implements org.apache.nemo.runtime.common.comm.ControlMessage.ClientToDriverMessageOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.ContainerFailedMsg.Builder (implements org.apache.nemo.runtime.common.comm.ControlMessage.ContainerFailedMsgOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.DataCollectMessage.Builder (implements org.apache.nemo.runtime.common.comm.ControlMessage.DataCollectMessageOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.DriverToClientMessage.Builder (implements org.apache.nemo.runtime.common.comm.ControlMessage.DriverToClientMessageOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.ExecutorFailedMsg.Builder (implements org.apache.nemo.runtime.common.comm.ControlMessage.ExecutorFailedMsgOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.InMasterBroadcastVariableMessage.Builder (implements org.apache.nemo.runtime.common.comm.ControlMessage.InMasterBroadcastVariableMessageOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.LaunchDAGMessage.Builder (implements org.apache.nemo.runtime.common.comm.ControlMessage.LaunchDAGMessageOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.Message.Builder (implements org.apache.nemo.runtime.common.comm.ControlMessage.MessageOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.Metric.Builder (implements org.apache.nemo.runtime.common.comm.ControlMessage.MetricOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.MetricMsg.Builder (implements org.apache.nemo.runtime.common.comm.ControlMessage.MetricMsgOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.NotificationMessage.Builder (implements org.apache.nemo.runtime.common.comm.ControlMessage.NotificationMessageOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.PipeInitMessage.Builder (implements org.apache.nemo.runtime.common.comm.ControlMessage.PipeInitMessageOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.PipeLocationInfoMessage.Builder (implements org.apache.nemo.runtime.common.comm.ControlMessage.PipeLocationInfoMessageOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.PipeTransferContextDescriptor.Builder (implements org.apache.nemo.runtime.common.comm.ControlMessage.PipeTransferContextDescriptorOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.RequestBlockLocationMsg.Builder (implements org.apache.nemo.runtime.common.comm.ControlMessage.RequestBlockLocationMsgOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.RequestBroadcastVariableMessage.Builder (implements org.apache.nemo.runtime.common.comm.ControlMessage.RequestBroadcastVariableMessageOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.RequestPipeLocationMessage.Builder (implements org.apache.nemo.runtime.common.comm.ControlMessage.RequestPipeLocationMessageOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.RunTimePassMessageEntry.Builder (implements org.apache.nemo.runtime.common.comm.ControlMessage.RunTimePassMessageEntryOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.RunTimePassMessageMsg.Builder (implements org.apache.nemo.runtime.common.comm.ControlMessage.RunTimePassMessageMsgOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.ScheduleTaskMsg.Builder (implements org.apache.nemo.runtime.common.comm.ControlMessage.ScheduleTaskMsgOrBuilder)
        • org.apache.nemo.runtime.common.comm.ControlMessage.TaskStateChangedMsg.Builder (implements org.apache.nemo.runtime.common.comm.ControlMessage.TaskStateChangedMsgOrBuilder)
        • org.apache.nemo.runtime.common.comm.GrpcMessageService.Void.Builder (implements org.apache.nemo.runtime.common.comm.GrpcMessageService.VoidOrBuilder)
  • io.grpc.stub.AbstractStub<S>
    • io.grpc.stub.AbstractAsyncStub<S>
      • org.apache.nemo.runtime.common.comm.MessageServiceGrpc.MessageServiceStub
    • io.grpc.stub.AbstractBlockingStub<S>
      • org.apache.nemo.runtime.common.comm.MessageServiceGrpc.MessageServiceBlockingStub
    • io.grpc.stub.AbstractFutureStub<S>
      • org.apache.nemo.runtime.common.comm.MessageServiceGrpc.MessageServiceFutureStub
  • org.apache.spark.sql.expressions.Aggregator<IN,BUF,OUT> (implements scala.Serializable)
    • org.apache.nemo.examples.spark.sql.JavaUserDefinedTypedAggregation.MyAverage
  • org.apache.nemo.examples.beam.AlternatingLeastSquare
  • org.apache.nemo.examples.beam.AlternatingLeastSquareInefficient
  • org.apache.nemo.runtime.master.scheduler.AntiAffinitySchedulingConstraint (implements org.apache.nemo.runtime.master.scheduler.SchedulingConstraint)
  • org.apache.nemo.common.test.ArgBuilder
  • org.apache.nemo.compiler.optimizer.policy.BasicPullPolicy (implements org.apache.nemo.compiler.optimizer.policy.Policy)
  • org.apache.nemo.compiler.optimizer.policy.BasicPushPolicy (implements org.apache.nemo.compiler.optimizer.policy.Policy)
  • org.apache.nemo.runtime.master.scheduler.BatchScheduler (implements org.apache.nemo.runtime.master.scheduler.Scheduler)
  • org.apache.nemo.runtime.master.scheduler.BatchSchedulerUtils
  • org.apache.nemo.compiler.frontend.beam.coder.BeamDecoderFactory<T> (implements org.apache.nemo.common.coder.DecoderFactory<T>)
  • org.apache.nemo.compiler.frontend.beam.coder.BeamEncoderFactory<T> (implements org.apache.nemo.common.coder.EncoderFactory<T>)
  • org.apache.nemo.client.beam.BeamStateTranslator (implements org.apache.nemo.client.StateTranslator)
  • org.apache.nemo.examples.beam.BeamWordCount
  • org.apache.nemo.runtime.executor.datatransfer.BlockInputReader (implements org.apache.nemo.runtime.executor.datatransfer.InputReader)
  • org.apache.nemo.runtime.master.BlockManagerMaster
  • org.apache.nemo.runtime.master.BlockManagerMaster.BlockManagerMasterControlMessageReceiver (implements org.apache.nemo.runtime.common.message.MessageListener<T>)
  • org.apache.nemo.runtime.master.BlockManagerMaster.BlockRequestHandler
  • org.apache.nemo.runtime.executor.data.BlockManagerWorker
  • org.apache.nemo.runtime.executor.datatransfer.BlockOutputWriter (implements org.apache.nemo.runtime.executor.datatransfer.OutputWriter)
  • org.apache.nemo.runtime.common.state.BlockState
  • org.apache.nemo.runtime.executor.data.BlockTransferThrottler
  • org.apache.nemo.common.ir.BoundedIteratorReadable<O> (implements org.apache.nemo.common.ir.Readable<O>)
  • org.apache.nemo.examples.beam.Broadcast
  • org.apache.nemo.runtime.master.BroadcastManagerMaster
  • org.apache.nemo.runtime.executor.data.BroadcastManagerWorker
  • org.apache.nemo.runtime.executor.transfer.ByteOutputContext.ByteOutputStream (implements org.apache.nemo.runtime.executor.transfer.TransferOutputStream)
  • org.apache.nemo.common.coder.BytesDecoderFactory (implements org.apache.nemo.common.coder.DecoderFactory<T>)
  • org.apache.nemo.common.coder.BytesEncoderFactory (implements org.apache.nemo.common.coder.EncoderFactory<T>)
  • org.apache.nemo.runtime.executor.transfer.ByteTransfer
  • org.apache.nemo.runtime.executor.transfer.ByteTransferContext
    • org.apache.nemo.runtime.executor.transfer.ByteInputContext
    • org.apache.nemo.runtime.executor.transfer.ByteOutputContext (implements org.apache.nemo.runtime.executor.transfer.OutputContext)
  • org.apache.nemo.client.ClientEndpoint
    • org.apache.nemo.client.beam.NemoPipelineResult (implements org.apache.beam.sdk.PipelineResult)
  • org.apache.nemo.runtime.common.message.ClientRPC
  • org.apache.nemo.client.ClientUtils
  • org.apache.nemo.common.ir.vertex.executionproperty.ClonedSchedulingProperty.CloneConf (implements java.io.Serializable)
  • org.apache.nemo.runtime.executor.transfer.ClosableBlockingQueue<T> (implements java.lang.AutoCloseable)
  • org.apache.beam.sdk.coders.Coder<T> (implements java.io.Serializable)
    • org.apache.beam.sdk.coders.StructuredCoder<T>
      • org.apache.beam.sdk.coders.AtomicCoder<T>
        • org.apache.nemo.examples.beam.FloatArrayCoder
        • org.apache.nemo.examples.beam.IntArrayCoder
        • org.apache.nemo.examples.beam.ObjectCoderForString
      • org.apache.nemo.compiler.frontend.beam.coder.SideInputCoder<T>
  • org.apache.beam.sdk.transforms.Combine.CombineFn<InputT,AccumT,OutputT>
    • org.apache.nemo.examples.beam.AlternatingLeastSquare.TrainingDataCombiner
    • org.apache.beam.sdk.transforms.Combine.BinaryCombineFn<V>
      • org.apache.nemo.examples.beam.MultinomialLogisticRegression.CombineFunction
    • org.apache.nemo.compiler.frontend.beam.transform.FinalCombineFn<AccumT,Output>
    • org.apache.nemo.compiler.frontend.beam.transform.PartialCombineFn<InputT,AccumT>
  • org.apache.nemo.compiler.CompilerTestUtil
  • org.apache.nemo.runtime.executor.data.streamchainer.CompressionStreamChainer (implements org.apache.nemo.runtime.executor.data.streamchainer.EncodeStreamChainer)
  • org.apache.nemo.compiler.optimizer.policy.ConditionalLargeShufflePolicy (implements org.apache.nemo.compiler.optimizer.policy.Policy)
  • org.apache.reef.tang.formats.ConfigurationModuleBuilder
    • org.apache.nemo.conf.JobConf
  • org.apache.nemo.runtime.master.resource.ContainerManager
  • org.apache.nemo.runtime.master.scheduler.ContainerTypeAwareSchedulingConstraint (implements org.apache.nemo.runtime.master.scheduler.SchedulingConstraint)
  • org.apache.nemo.runtime.common.comm.ControlMessage
  • 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.common.dag.DAG<V,E> (implements org.apache.nemo.common.dag.DAGInterface<V,E>)
  • org.apache.nemo.common.dag.DAGBuilder<V,E> (implements java.io.Serializable)
  • org.apache.nemo.runtime.executor.datatransfer.DataFetcherOutputCollector<O> (implements org.apache.nemo.common.ir.OutputCollector<O>)
  • org.apache.nemo.conf.DataPlaneConf
  • org.apache.nemo.compiler.optimizer.policy.DataSkewPolicy (implements org.apache.nemo.compiler.optimizer.policy.Policy)
  • org.apache.nemo.runtime.executor.data.DataUtil
  • org.apache.nemo.runtime.executor.data.DataUtil.InputStreamIterator<T> (implements org.apache.nemo.runtime.executor.data.DataUtil.IteratorWithNumBytes<T>)
  • org.apache.nemo.common.coder.DecoderFactory.DummyDecoderFactory (implements org.apache.nemo.common.coder.DecoderFactory<T>)
  • org.apache.nemo.runtime.executor.data.streamchainer.DecompressionStreamChainer (implements org.apache.nemo.runtime.executor.data.streamchainer.DecodeStreamChainer)
  • org.apache.nemo.common.partitioner.DedicatedKeyPerElementPartitioner (implements org.apache.nemo.common.partitioner.Partitioner<K>)
  • org.apache.nemo.runtime.master.resource.DefaultExecutorRepresenter (implements org.apache.nemo.runtime.master.resource.ExecutorRepresenter)
  • org.apache.nemo.compiler.frontend.beam.transform.DefaultOutputManager<OutputT> (implements org.apache.beam.runners.core.DoFnRunners.OutputManager)
  • org.apache.nemo.compiler.optimizer.policy.DefaultPolicy (implements org.apache.nemo.compiler.optimizer.policy.Policy)
  • org.apache.nemo.compiler.optimizer.policy.DefaultPolicyWithSeparatePass (implements org.apache.nemo.compiler.optimizer.policy.Policy)
  • org.apache.nemo.compiler.optimizer.policy.DisaggregationPolicy (implements org.apache.nemo.compiler.optimizer.policy.Policy)
  • org.apache.beam.sdk.transforms.DoFn<InputT,OutputT> (implements org.apache.beam.sdk.transforms.display.HasDisplayData, java.io.Serializable)
    • org.apache.nemo.examples.beam.AlternatingLeastSquare.CalculateNextMatrix
    • org.apache.nemo.examples.beam.AlternatingLeastSquare.CreateInitialMatrix
    • org.apache.nemo.examples.beam.AlternatingLeastSquare.ParseLine
    • org.apache.nemo.examples.beam.AlternatingLeastSquare.UngroupSingleVectorList
    • org.apache.nemo.examples.beam.MultinomialLogisticRegression.ApplyGradient
    • org.apache.nemo.examples.beam.MultinomialLogisticRegression.CalculateGradient
  • org.apache.nemo.client.DriverEndpoint
  • org.apache.nemo.client.DriverRPCServer
  • org.apache.nemo.common.ir.edge.executionproperty.DuplicateEdgeGroupPropertyValue (implements java.io.Serializable)
  • org.apache.nemo.compiler.optimizer.policy.DynamicTaskSizingPolicy (implements org.apache.nemo.compiler.optimizer.policy.Policy)
  • org.apache.nemo.examples.beam.EDGARAvgDocSize
  • org.apache.nemo.examples.beam.EDGARDocumentSuccessRate
  • org.apache.nemo.examples.beam.EDGARRequestsByCIK
  • org.apache.nemo.examples.beam.EDGARTop10BadRefererDocs
  • org.apache.nemo.examples.beam.EDGARTop10BadRefererDocs.ValueComparator<K> (implements java.util.Comparator<T>, java.io.Serializable)
  • org.apache.nemo.examples.beam.EDGARTop10Documents
  • org.apache.nemo.examples.beam.EDGARTop10Documents.ValueComparator<K> (implements java.util.Comparator<T>, java.io.Serializable)
  • org.apache.nemo.common.dag.Edge<V> (implements java.io.Serializable)
    • org.apache.nemo.common.ir.edge.IREdge
    • org.apache.nemo.runtime.common.plan.RuntimeEdge<V>
      • org.apache.nemo.runtime.common.plan.StageEdge
  • org.apache.nemo.common.test.EmptyComponents
  • org.apache.nemo.common.coder.EncoderFactory.DummyEncoderFactory (implements org.apache.nemo.common.coder.EncoderFactory<T>)
  • org.apache.nemo.runtime.common.metric.Event (implements java.io.Serializable)
    • org.apache.nemo.runtime.common.metric.DataTransferEvent
    • org.apache.nemo.runtime.common.metric.StateTransitionEvent<T>
  • org.apache.nemo.common.test.ExampleTestArgs
  • org.apache.nemo.common.test.ExampleTestUtil
  • org.apache.nemo.common.ir.executionproperty.ExecutionProperty<T> (implements java.io.Serializable)
    • org.apache.nemo.common.ir.executionproperty.EdgeExecutionProperty<T>
      • org.apache.nemo.common.ir.edge.executionproperty.AdditionalOutputTagProperty
      • org.apache.nemo.common.ir.edge.executionproperty.BlockFetchFailureProperty
      • org.apache.nemo.common.ir.edge.executionproperty.CacheIDProperty
      • org.apache.nemo.common.ir.edge.executionproperty.CommunicationPatternProperty
      • org.apache.nemo.common.ir.edge.executionproperty.CompressionProperty
      • org.apache.nemo.common.ir.edge.executionproperty.DataFlowProperty
      • org.apache.nemo.common.ir.edge.executionproperty.DataPersistenceProperty
      • org.apache.nemo.common.ir.edge.executionproperty.DataStoreProperty
      • org.apache.nemo.common.ir.edge.executionproperty.DecoderProperty
      • org.apache.nemo.common.ir.edge.executionproperty.DecompressionProperty
      • org.apache.nemo.common.ir.edge.executionproperty.DuplicateEdgeGroupProperty
      • org.apache.nemo.common.ir.edge.executionproperty.EncoderProperty
      • org.apache.nemo.common.ir.edge.executionproperty.KeyDecoderProperty
      • org.apache.nemo.common.ir.edge.executionproperty.KeyEncoderProperty
      • org.apache.nemo.common.ir.edge.executionproperty.KeyExtractorProperty
      • org.apache.nemo.common.ir.edge.executionproperty.MessageIdEdgeProperty
      • org.apache.nemo.common.ir.edge.executionproperty.PartitionerProperty
      • org.apache.nemo.common.ir.edge.executionproperty.PartitionSetProperty
      • org.apache.nemo.common.ir.edge.executionproperty.SubPartitionSetProperty
    • org.apache.nemo.common.ir.executionproperty.VertexExecutionProperty<T>
      • org.apache.nemo.common.ir.vertex.executionproperty.ClonedSchedulingProperty
      • org.apache.nemo.common.ir.vertex.executionproperty.EnableDynamicTaskSizingProperty
      • org.apache.nemo.common.ir.vertex.executionproperty.IgnoreSchedulingTempDataReceiverProperty
      • org.apache.nemo.common.ir.vertex.executionproperty.MessageIdVertexProperty
      • org.apache.nemo.common.ir.vertex.executionproperty.ParallelismProperty
      • org.apache.nemo.common.ir.vertex.executionproperty.ResourceAntiAffinityProperty
      • org.apache.nemo.common.ir.vertex.executionproperty.ResourceLambdaProperty
      • org.apache.nemo.common.ir.vertex.executionproperty.ResourceLocalityProperty
      • org.apache.nemo.common.ir.vertex.executionproperty.ResourcePriorityProperty
      • org.apache.nemo.common.ir.vertex.executionproperty.ResourceSiteProperty
      • org.apache.nemo.common.ir.vertex.executionproperty.ResourceSlotProperty
      • org.apache.nemo.common.ir.vertex.executionproperty.ScheduleGroupProperty
  • org.apache.nemo.common.ir.executionproperty.ExecutionPropertyMap<T> (implements java.io.Serializable)
  • org.apache.nemo.runtime.executor.Executor
  • org.apache.nemo.runtime.master.scheduler.ExecutorRegistry
  • org.apache.nemo.runtime.common.message.FailedMessageSender (implements org.apache.nemo.runtime.common.message.MessageSender<T>)
  • org.apache.nemo.runtime.executor.data.FileArea (implements java.io.Serializable)
  • org.apache.beam.sdk.io.FileBasedSink.FilenamePolicy (implements java.io.Serializable)
    • org.apache.nemo.examples.beam.WriteOneFilePerWindow.PerWindowFiles
  • org.apache.nemo.runtime.executor.data.block.FileBlock<K> (implements org.apache.nemo.runtime.executor.data.block.Block<K>)
  • org.apache.nemo.runtime.executor.data.metadata.FileMetadata<K>
    • org.apache.nemo.runtime.executor.data.metadata.LocalFileMetadata<K>
    • org.apache.nemo.runtime.executor.data.metadata.RemoteFileMetadata<K>
  • org.apache.nemo.common.punctuation.Finishmark
  • org.apache.nemo.runtime.master.scheduler.FreeSlotSchedulingConstraint (implements org.apache.nemo.runtime.master.scheduler.SchedulingConstraint)
  • org.apache.nemo.compiler.frontend.beam.transform.GBKTransform.GBKOutputCollector (implements org.apache.nemo.common.ir.OutputCollector<O>)
  • javax.servlet.GenericServlet (implements java.io.Serializable, javax.servlet.Servlet, javax.servlet.ServletConfig)
    • javax.servlet.http.HttpServlet
      • org.apache.nemo.runtime.master.servlet.AllMetricServlet
      • org.apache.nemo.runtime.master.servlet.JobMetricServlet
      • org.apache.nemo.runtime.master.servlet.StageMetricServlet
      • org.apache.nemo.runtime.master.servlet.TaskMetricServlet
      • org.eclipse.jetty.websocket.servlet.WebSocketServlet
        • org.apache.nemo.runtime.master.servlet.WebSocketMetricServlet
  • org.apache.nemo.runtime.common.message.grpc.GrpcMessageEnvironment (implements org.apache.nemo.runtime.common.message.MessageEnvironment)
  • org.apache.nemo.runtime.common.comm.GrpcMessageService
  • java.util.logging.Handler
    • org.apache.nemo.driver.RemoteClientMessageLoggingHandler
  • org.apache.nemo.common.partitioner.HashPartitioner (implements org.apache.nemo.common.partitioner.Partitioner<K>)
  • org.apache.nemo.common.HashRange (implements org.apache.nemo.common.KeyRange<K>)
  • org.apache.nemo.common.ir.IdManager
  • org.apache.beam.sdk.transforms.InferableFunction<InputT,OutputT> (implements org.apache.beam.sdk.transforms.display.HasDisplayData, org.apache.beam.sdk.transforms.ProcessFunction<InputT,OutputT>)
    • org.apache.beam.sdk.transforms.SimpleFunction<InputT,OutputT> (implements org.apache.beam.sdk.transforms.SerializableFunction<InputT,OutputT>)
      • org.apache.nemo.examples.beam.BeamWordCount.FormatAsTextFn
  • org.apache.nemo.compiler.frontend.beam.InMemorySideInputReader (implements org.apache.beam.runners.core.ReadyCheckingSideInputReader)
  • 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>)
  • java.io.InputStream (implements java.io.Closeable)
    • org.apache.nemo.common.ByteBufferInputStream
    • org.apache.nemo.runtime.executor.data.LimitedInputStream
  • org.apache.nemo.common.partitioner.IntactPartitioner (implements org.apache.nemo.common.partitioner.Partitioner<K>)
  • org.apache.nemo.common.coder.IntDecoderFactory (implements org.apache.nemo.common.coder.DecoderFactory<T>)
  • org.apache.nemo.common.coder.IntEncoderFactory (implements org.apache.nemo.common.coder.EncoderFactory<T>)
  • org.apache.nemo.runtime.executor.datatransfer.IntermediateDataIOFactory
  • org.apache.nemo.common.ir.IRDAG (implements org.apache.nemo.common.dag.DAGInterface<V,E>)
  • org.apache.nemo.common.ir.IRDAGChecker
  • org.apache.nemo.common.ir.IRDAGChecker.CheckerResult
  • org.apache.nemo.examples.spark.JavaMapReduce
  • org.apache.nemo.examples.spark.JavaSparkPi
  • org.apache.nemo.examples.spark.sql.JavaSparkSQLExample
  • org.apache.nemo.examples.spark.sql.JavaSparkSQLExample.Person (implements java.io.Serializable)
  • org.apache.nemo.examples.spark.sql.JavaUserDefinedTypedAggregation
  • org.apache.nemo.examples.spark.sql.JavaUserDefinedTypedAggregation.Average (implements java.io.Serializable)
  • org.apache.nemo.examples.spark.sql.JavaUserDefinedTypedAggregation.Employee (implements java.io.Serializable)
  • org.apache.nemo.examples.spark.sql.JavaUserDefinedUntypedAggregation
  • org.apache.nemo.examples.spark.JavaWordAndLineCount
  • org.apache.nemo.examples.spark.JavaWordCount
  • org.apache.nemo.conf.JobConf.BandwidthJSONContents (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.nemo.conf.JobConf.BandwidthJSONPath (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.nemo.conf.JobConf.ChunkSizeKb (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.nemo.conf.JobConf.ClientSideRPCServerHost (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.nemo.conf.JobConf.ClientSideRPCServerPort (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.nemo.conf.JobConf.DAGDirectory (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.nemo.conf.JobConf.DBAddress (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.nemo.conf.JobConf.DBEnabled (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.nemo.conf.JobConf.DBId (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.nemo.conf.JobConf.DBPasswd (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.nemo.conf.JobConf.DeployMode (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.nemo.conf.JobConf.DriverMemMb (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.nemo.conf.JobConf.EnvironmentType (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.nemo.conf.JobConf.ExecutorId (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.nemo.conf.JobConf.ExecutorJSONContents (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.nemo.conf.JobConf.ExecutorJSONPath (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.nemo.conf.JobConf.ExecutorMemoryMb (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.nemo.conf.JobConf.ExecutorPoisonSec (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.nemo.conf.JobConf.ExecutorType (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.nemo.conf.JobConf.FileDirectory (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.nemo.conf.JobConf.GlusterVolumeDirectory (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.nemo.conf.JobConf.IORequestHandleThreadsTotal (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.nemo.conf.JobConf.JobId (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.nemo.conf.JobConf.JVMHeapSlack (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.nemo.conf.JobConf.LatencyMarkPeriod (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.nemo.conf.JobConf.MaxNumDownloadsForARuntimeEdge (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.nemo.conf.JobConf.MaxOffheapRatio (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.nemo.conf.JobConf.MaxTaskAttempt (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.nemo.conf.JobConf.OptimizationPolicy (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.nemo.conf.JobConf.PartitionTransportClientNumThreads (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.nemo.conf.JobConf.PartitionTransportServerBacklog (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.nemo.conf.JobConf.PartitionTransportServerNumListeningThreads (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.nemo.conf.JobConf.PartitionTransportServerNumWorkingThreads (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.nemo.conf.JobConf.PartitionTransportServerPort (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.nemo.conf.JobConf.SchedulerImplClassName (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.nemo.conf.JobConf.ScheduleSerThread (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.nemo.conf.JobConf.StreamMetricPeriod (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.nemo.conf.JobConf.UserMainArguments (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.nemo.conf.JobConf.UserMainClass (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.nemo.client.JobLauncher
  • org.apache.nemo.runtime.common.metric.JobMetric (implements org.apache.nemo.runtime.common.metric.StateMetric<T>)
  • org.apache.nemo.compiler.optimizer.policy.LambdaPolicy (implements org.apache.nemo.compiler.optimizer.policy.Policy)
  • org.apache.nemo.compiler.optimizer.policy.LargeShufflePolicy (implements org.apache.nemo.compiler.optimizer.policy.Policy)
  • org.apache.nemo.common.punctuation.LatencyMark (implements java.io.Serializable)
  • 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.common.ir.vertex.transform.StreamTransform<T>
    • org.apache.nemo.compiler.frontend.beam.transform.WindowFnTransform<T,W>
  • org.apache.nemo.runtime.common.metric.LatencyMetric (implements java.io.Serializable)
  • org.apache.nemo.runtime.master.scheduler.LocalitySchedulingConstraint (implements org.apache.nemo.runtime.master.scheduler.SchedulingConstraint)
  • org.apache.nemo.runtime.common.message.local.LocalMessageDispatcher
  • org.apache.nemo.runtime.common.message.local.LocalMessageEnvironment (implements org.apache.nemo.runtime.common.message.MessageEnvironment)
  • org.apache.nemo.runtime.common.message.local.LocalMessageSender<T> (implements org.apache.nemo.runtime.common.message.MessageSender<T>)
  • org.apache.nemo.runtime.executor.transfer.LocalTransferContext
    • org.apache.nemo.runtime.executor.transfer.LocalInputContext
    • org.apache.nemo.runtime.executor.transfer.LocalOutputContext (implements org.apache.nemo.runtime.executor.transfer.OutputContext)
  • org.apache.nemo.common.coder.LongDecoderFactory (implements org.apache.nemo.common.coder.DecoderFactory<T>)
  • org.apache.nemo.common.coder.LongEncoderFactory (implements org.apache.nemo.common.coder.EncoderFactory<T>)
  • org.apache.nemo.compiler.optimizer.pass.compiletime.reshaping.LoopOptimizations
  • org.apache.nemo.compiler.optimizer.examples.MapReduceDisaggregationOptimization
  • org.apache.nemo.runtime.executor.data.MemoryChunk
  • org.apache.nemo.runtime.executor.data.MemoryPoolAssigner
  • org.apache.nemo.compiler.optimizer.pass.runtime.Message<T>
  • org.apache.nemo.runtime.common.message.MessageParameters
  • org.apache.nemo.runtime.common.message.MessageParameters.SenderId (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.nemo.runtime.common.comm.MessageServiceGrpc
  • org.apache.nemo.runtime.common.comm.MessageServiceGrpc.MessageServiceImplBase (implements io.grpc.BindableService)
  • org.apache.nemo.runtime.common.message.MessageUtils
  • org.apache.nemo.runtime.master.metric.MetricBroadcaster
  • org.apache.nemo.runtime.master.metric.MetricManagerMaster (implements org.apache.nemo.runtime.master.metric.MetricMessageHandler)
  • org.apache.nemo.runtime.executor.MetricManagerWorker (implements org.apache.nemo.runtime.executor.MetricMessageSender)
  • org.apache.nemo.runtime.master.metric.MetricStore
  • org.apache.nemo.runtime.common.metric.MetricUtils
  • org.apache.nemo.examples.beam.MinimalWordCount
  • org.apache.nemo.runtime.master.scheduler.MinOccupancyFirstSchedulingPolicy (implements org.apache.nemo.runtime.master.scheduler.SchedulingPolicy)
  • org.apache.nemo.runtime.executor.datatransfer.MultiInputWatermarkManager (implements org.apache.nemo.runtime.executor.datatransfer.InputWatermarkManager)
  • org.apache.nemo.examples.beam.MultinomialLogisticRegression
  • org.apache.nemo.examples.beam.MultinomialLogisticRegression.CombineFunctionForIterable (implements org.apache.beam.sdk.transforms.SerializableFunction<InputT,OutputT>)
  • org.apache.nemo.runtime.common.NativeChannelImplementationSelector (implements org.apache.nemo.runtime.common.NettyChannelImplementationSelector)
  • org.apache.nemo.runtime.common.message.ncs.NcsMessageEnvironment (implements org.apache.nemo.runtime.common.message.MessageEnvironment)
  • org.apache.nemo.compiler.backend.nemo.NemoBackend (implements org.apache.nemo.compiler.backend.Backend<Plan>)
  • org.apache.nemo.client.NemoClient
  • org.apache.nemo.client.NemoClient.JobMessageHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.nemo.driver.NemoContext
  • org.apache.nemo.driver.NemoContext.ContextStartHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.nemo.driver.NemoContext.ContextStopHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.nemo.driver.NemoDriver
  • org.apache.nemo.driver.NemoDriver.ActiveContextHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.nemo.driver.NemoDriver.AllocatedEvaluatorHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.nemo.driver.NemoDriver.DriverStopHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.nemo.driver.NemoDriver.FailedContextHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.nemo.driver.NemoDriver.FailedEvaluatorHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.nemo.driver.NemoDriver.StartHandler (implements org.apache.reef.wake.EventHandler<T>)
  • 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.compiler.optimizer.NemoOptimizer (implements org.apache.nemo.compiler.optimizer.Optimizer)
  • org.apache.nemo.compiler.backend.nemo.NemoPlanRewriter (implements org.apache.nemo.runtime.common.plan.PlanRewriter)
  • org.apache.nemo.client.beam.NemoRunnerRegistrar
  • org.apache.nemo.client.beam.NemoRunnerRegistrar.Options (implements org.apache.beam.sdk.options.PipelineOptionsRegistrar)
  • org.apache.nemo.client.beam.NemoRunnerRegistrar.Runner (implements org.apache.beam.sdk.runners.PipelineRunnerRegistrar)
  • org.apache.nemo.examples.beam.NetworkTraceAnalysis
  • org.apache.nemo.runtime.executor.datatransfer.NextIntraTaskOperatorInfo
  • org.apache.nemo.runtime.common.NioChannelImplementationSelector (implements org.apache.nemo.runtime.common.NettyChannelImplementationSelector)
  • org.apache.nemo.runtime.master.scheduler.NodeShareSchedulingConstraint (implements org.apache.nemo.runtime.master.scheduler.SchedulingConstraint)
  • org.apache.nemo.runtime.executor.data.block.NonSerializedMemoryBlock<K> (implements org.apache.nemo.runtime.executor.data.block.Block<K>)
  • org.apache.nemo.runtime.executor.data.partition.NonSerializedPartition<K> (implements org.apache.nemo.runtime.executor.data.partition.Partition<T,K>)
  • 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.common.test.EmptyComponents.EmptyTransform<I,O>
    • org.apache.nemo.compiler.frontend.beam.transform.GroupByKeyTransform<I>
    • org.apache.nemo.common.ir.vertex.transform.MessageAggregatorTransform<K,V,O>
    • org.apache.nemo.common.ir.vertex.transform.MessageGeneratorTransform<I,K,V>
    • org.apache.nemo.common.ir.vertex.transform.SignalTransform
  • 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.compiler.optimizer.OptimizerUtils
  • java.io.OutputStream (implements java.io.Closeable, java.io.Flushable)
    • org.apache.nemo.runtime.executor.data.DirectByteBufferOutputStream
  • org.apache.nemo.common.Pair<A,B> (implements java.io.Serializable)
  • org.apache.nemo.common.coder.PairDecoderFactory<A,B> (implements org.apache.nemo.common.coder.DecoderFactory<T>)
  • org.apache.nemo.common.coder.PairEncoderFactory<A,B> (implements org.apache.nemo.common.coder.EncoderFactory<T>)
  • org.apache.nemo.common.PairKeyExtractor (implements org.apache.nemo.common.KeyExtractor)
  • org.apache.nemo.compiler.backend.nemo.prophet.ParallelismProphet (implements org.apache.nemo.compiler.backend.nemo.prophet.Prophet<K,V>)
  • org.apache.nemo.runtime.executor.data.metadata.PartitionMetadata<K>
  • org.apache.nemo.examples.beam.PartitionWordsByLength
  • org.apache.nemo.common.pass.Pass
    • org.apache.nemo.compiler.optimizer.pass.compiletime.CompileTimePass (implements java.util.function.Function<T,R>)
      • org.apache.nemo.compiler.optimizer.pass.compiletime.annotating.AnnotatingPass
        • org.apache.nemo.compiler.optimizer.pass.compiletime.annotating.AggressiveSpeculativeCloningPass
        • org.apache.nemo.compiler.optimizer.pass.compiletime.annotating.CompressionPass
        • org.apache.nemo.compiler.optimizer.pass.compiletime.annotating.DefaultDataPersistencePass
        • org.apache.nemo.compiler.optimizer.pass.compiletime.annotating.DefaultDataStorePass
        • org.apache.nemo.compiler.optimizer.pass.compiletime.annotating.DefaultEdgeDecoderPass
        • org.apache.nemo.compiler.optimizer.pass.compiletime.annotating.DefaultEdgeEncoderPass
        • org.apache.nemo.compiler.optimizer.pass.compiletime.annotating.DefaultParallelismPass
        • org.apache.nemo.compiler.optimizer.pass.compiletime.annotating.DefaultScheduleGroupPass
        • org.apache.nemo.compiler.optimizer.pass.compiletime.annotating.DisaggregationEdgeDataStorePass
        • org.apache.nemo.compiler.optimizer.pass.compiletime.annotating.DuplicateEdgeGroupSizePass
        • org.apache.nemo.compiler.optimizer.pass.compiletime.annotating.LambdaPass
        • org.apache.nemo.compiler.optimizer.pass.compiletime.annotating.LargeShuffleAnnotatingPass
        • org.apache.nemo.compiler.optimizer.pass.compiletime.annotating.PipeTransferForAllEdgesPass
        • org.apache.nemo.compiler.optimizer.pass.compiletime.annotating.ResourceLocalityPass
        • org.apache.nemo.compiler.optimizer.pass.compiletime.annotating.ResourceSitePass
        • org.apache.nemo.compiler.optimizer.pass.compiletime.annotating.ResourceSlotPass
        • org.apache.nemo.compiler.optimizer.pass.compiletime.annotating.ShuffleEdgePushPass
        • org.apache.nemo.compiler.optimizer.pass.compiletime.annotating.SkewAnnotatingPass
        • org.apache.nemo.compiler.optimizer.pass.compiletime.annotating.TransientResourceDataTransferPass
        • org.apache.nemo.compiler.optimizer.pass.compiletime.annotating.TransientResourcePriorityPass
        • org.apache.nemo.compiler.optimizer.pass.compiletime.annotating.UpfrontCloningPass
        • org.apache.nemo.compiler.optimizer.pass.compiletime.annotating.XGBoostPass
      • org.apache.nemo.compiler.optimizer.pass.compiletime.composite.CompositePass
        • org.apache.nemo.compiler.optimizer.pass.compiletime.composite.DefaultCompositePass
        • org.apache.nemo.compiler.optimizer.policy.DefaultPolicyWithSeparatePass.RefactoredPass
        • org.apache.nemo.compiler.optimizer.pass.compiletime.composite.LargeShuffleCompositePass
        • org.apache.nemo.compiler.optimizer.pass.compiletime.composite.LoopOptimizationCompositePass
        • org.apache.nemo.compiler.optimizer.pass.compiletime.composite.SkewCompositePass
        • org.apache.nemo.compiler.optimizer.pass.compiletime.composite.TransientResourceCompositePass
      • org.apache.nemo.compiler.optimizer.pass.compiletime.reshaping.ReshapingPass
        • org.apache.nemo.compiler.optimizer.pass.compiletime.reshaping.CommonSubexpressionEliminationPass
        • org.apache.nemo.compiler.optimizer.pass.compiletime.reshaping.LargeShuffleReshapingPass
        • org.apache.nemo.compiler.optimizer.pass.compiletime.reshaping.LoopExtractionPass
        • org.apache.nemo.compiler.optimizer.pass.compiletime.reshaping.LoopOptimizations.LoopFusionPass
        • org.apache.nemo.compiler.optimizer.pass.compiletime.reshaping.LoopOptimizations.LoopInvariantCodeMotionPass
        • org.apache.nemo.compiler.optimizer.pass.compiletime.reshaping.LoopUnrollingPass
        • org.apache.nemo.compiler.optimizer.pass.compiletime.reshaping.SamplingSkewReshapingPass
        • org.apache.nemo.compiler.optimizer.pass.compiletime.reshaping.SamplingTaskSizingPass
        • org.apache.nemo.compiler.optimizer.pass.compiletime.reshaping.SkewReshapingPass
    • org.apache.nemo.compiler.optimizer.pass.runtime.RunTimePass<T> (implements java.util.function.BiFunction<T,U,R>)
      • org.apache.nemo.compiler.optimizer.pass.runtime.DynamicTaskSizingRuntimePass
      • org.apache.nemo.compiler.optimizer.pass.runtime.SkewRunTimePass
  • org.apache.nemo.runtime.master.scheduler.PendingTaskCollectionPointer
  • org.apache.nemo.examples.beam.PerKeyMedian
  • org.apache.nemo.examples.beam.PerPercentileAverage
  • org.apache.nemo.runtime.common.message.PersistentConnectionToMasterMap
  • org.apache.nemo.runtime.common.plan.PhysicalPlan (implements java.io.Serializable)
  • org.apache.nemo.runtime.common.plan.PhysicalPlanGenerator (implements java.util.function.Function<T,R>)
  • org.apache.nemo.runtime.executor.data.PipeContainer
  • org.apache.nemo.runtime.executor.datatransfer.PipeInputReader (implements org.apache.nemo.runtime.executor.datatransfer.InputReader)
  • org.apache.beam.sdk.Pipeline.PipelineVisitor.Defaults (implements org.apache.beam.sdk.Pipeline.PipelineVisitor)
    • org.apache.nemo.compiler.frontend.beam.PipelineVisitor
  • org.apache.beam.sdk.PipelineRunner<ResultT>
    • org.apache.nemo.client.beam.NemoRunner
  • org.apache.nemo.runtime.master.PipeManagerMaster
  • org.apache.nemo.runtime.master.PipeManagerMaster.PipeManagerMasterControlMessageReceiver (implements org.apache.nemo.runtime.common.message.MessageListener<T>)
  • org.apache.nemo.runtime.executor.data.PipeManagerWorker
  • org.apache.nemo.runtime.executor.datatransfer.PipeOutputWriter (implements org.apache.nemo.runtime.executor.datatransfer.OutputWriter)
  • org.apache.nemo.runtime.master.PlanAppender
  • org.apache.nemo.runtime.common.state.PlanState
  • org.apache.nemo.runtime.master.PlanStateManager
  • org.apache.nemo.compiler.optimizer.policy.PolicyBuilder
  • org.apache.nemo.compiler.optimizer.policy.PolicyImpl (implements org.apache.nemo.compiler.optimizer.policy.Policy)
  • org.apache.beam.sdk.transforms.PTransform<InputT,OutputT> (implements org.apache.beam.sdk.transforms.display.HasDisplayData, java.io.Serializable)
    • org.apache.nemo.examples.beam.BeamWordCount.CountWords
    • org.apache.nemo.compiler.frontend.beam.transform.LoopCompositeTransform<inputT,outputT> (implements java.io.Serializable)
      • org.apache.nemo.examples.beam.AlternatingLeastSquare.UpdateUserAndItemMatrix
      • org.apache.nemo.examples.beam.AlternatingLeastSquareInefficient.UpdateUserAndItemMatrix
      • org.apache.nemo.examples.beam.MultinomialLogisticRegression.UpdateModel
    • org.apache.nemo.examples.beam.WriteOneFilePerWindow
  • org.apache.nemo.common.eventhandler.PubSubEventHandlerWrapper
  • org.apache.nemo.runtime.common.ReplyFutureMap<T>
  • org.apache.nemo.common.ir.executionproperty.ResourceSpecification
  • org.apache.nemo.runtime.common.RuntimeIdManager
  • org.apache.nemo.runtime.master.RuntimeMaster
  • org.apache.nemo.runtime.master.RuntimeMaster.MasterControlMessageReceiver (implements org.apache.nemo.runtime.common.message.MessageListener<T>)
  • org.apache.nemo.runtime.executor.datatransfer.RunTimeMessageOutputCollector<O> (implements org.apache.nemo.common.ir.OutputCollector<O>)
  • org.apache.nemo.runtime.common.RuntimeTestUtil
  • org.apache.nemo.compiler.optimizer.policy.SamplingLargeShuffleSkewPolicy (implements org.apache.nemo.compiler.optimizer.policy.Policy)
  • org.apache.nemo.runtime.master.scheduler.SchedulingConstraintRegistry
  • org.apache.nemo.runtime.executor.data.block.SerializedMemoryBlock<K> (implements org.apache.nemo.runtime.executor.data.block.Block<K>)
  • org.apache.nemo.runtime.executor.data.partition.SerializedPartition<K> (implements org.apache.nemo.runtime.executor.data.partition.Partition<T,K>)
  • org.apache.nemo.runtime.executor.data.streamchainer.Serializer<E,D>
  • org.apache.nemo.runtime.executor.data.SerializerManager
  • org.apache.nemo.compiler.frontend.beam.SideInputElement<T>
  • org.apache.nemo.examples.beam.SimpleSumSQL
  • org.apache.nemo.runtime.master.scheduler.SimulatedTaskExecutor
  • org.apache.nemo.runtime.master.scheduler.SimulationScheduler (implements org.apache.nemo.runtime.master.scheduler.Scheduler)
  • org.apache.nemo.runtime.executor.datatransfer.SingleInputWatermarkManager (implements org.apache.nemo.runtime.executor.datatransfer.InputWatermarkManager)
  • org.apache.nemo.compiler.backend.nemo.prophet.SkewProphet (implements org.apache.nemo.compiler.backend.nemo.prophet.Prophet<K,V>)
  • org.apache.nemo.compiler.frontend.spark.SparkBroadcastVariables
  • org.apache.nemo.compiler.frontend.spark.SparkKeyExtractor (implements org.apache.nemo.common.KeyExtractor)
  • org.apache.nemo.runtime.common.metric.StageMetric (implements org.apache.nemo.runtime.common.metric.StateMetric<T>)
  • org.apache.nemo.runtime.common.plan.StagePartitioner (implements java.util.function.Function<T,R>)
  • org.apache.nemo.runtime.common.state.StageState
  • org.apache.nemo.common.StateMachine
  • org.apache.nemo.common.StateMachine.Builder
  • org.apache.nemo.compiler.optimizer.policy.StreamingPolicy (implements org.apache.nemo.compiler.optimizer.policy.Policy)
  • org.apache.nemo.runtime.master.scheduler.StreamingScheduler (implements org.apache.nemo.runtime.master.scheduler.Scheduler)
  • org.apache.nemo.runtime.common.metric.StreamMetric (implements java.io.Serializable)
  • org.apache.nemo.runtime.common.plan.Task (implements java.io.Serializable)
  • org.apache.nemo.runtime.executor.task.TaskExecutor
  • org.apache.nemo.runtime.common.metric.TaskMetric (implements org.apache.nemo.runtime.common.metric.StateMetric<T>)
  • org.apache.nemo.runtime.common.state.TaskState
  • org.apache.nemo.runtime.executor.TaskStateManager
  • org.apache.nemo.runtime.common.plan.TestPlanGenerator
  • org.apache.nemo.compiler.optimizer.policy.TestPolicy (implements org.apache.nemo.compiler.optimizer.policy.Policy)
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • org.apache.nemo.runtime.common.exception.AbsentBlockException
      • org.apache.nemo.runtime.executor.data.DataUtil.IteratorWithNumBytes.NumBytesNotSupportedException
      • org.apache.nemo.common.exception.IllegalStateTransitionException
      • org.apache.nemo.common.exception.InvalidUserMainException
      • org.apache.nemo.runtime.executor.data.MemoryAllocationException
      • java.lang.RuntimeException
        • org.apache.nemo.common.exception.BlockFetchException
        • org.apache.nemo.common.exception.BlockWriteException
        • org.apache.nemo.common.exception.CompileTimeOptimizationException
        • org.apache.nemo.common.exception.ContainerException
        • org.apache.nemo.common.exception.DataSourceException
        • org.apache.nemo.common.exception.DynamicOptimizationException
        • org.apache.nemo.common.exception.IllegalEdgeOperationException
        • org.apache.nemo.common.exception.IllegalMessageException
        • org.apache.nemo.common.exception.IllegalVertexOperationException
        • org.apache.nemo.common.exception.InvalidParameterException
        • org.apache.nemo.common.exception.JsonParseException
        • org.apache.nemo.common.exception.MetricException
        • org.apache.nemo.common.exception.NodeConnectionException
        • org.apache.nemo.common.exception.OutputMismatchException
        • org.apache.nemo.common.exception.PhysicalPlanGenerationException
        • org.apache.nemo.runtime.common.exception.PlanAppenderException
        • org.apache.nemo.common.exception.RuntimeOptimizationException
        • org.apache.nemo.common.exception.SchedulingException
        • org.apache.nemo.common.exception.SimulationException
        • org.apache.nemo.common.exception.UnknownExecutionStateException
        • org.apache.nemo.common.exception.UnknownFailureCauseException
        • org.apache.nemo.common.exception.UnrecoverableFailureException
        • org.apache.nemo.common.exception.UnsupportedBlockStoreException
        • org.apache.nemo.common.exception.UnsupportedCommPatternException
        • org.apache.nemo.common.exception.UnsupportedCompressionException
        • org.apache.nemo.common.exception.UnsupportedExecutionPropertyException
        • org.apache.nemo.common.exception.UnsupportedMethodException
        • org.apache.nemo.common.exception.UnsupportedMetricException
        • org.apache.nemo.common.exception.UnsupportedPartitionerException
  • org.apache.nemo.runtime.executor.TransformContextImpl (implements org.apache.nemo.common.ir.vertex.transform.Transform.Context)
  • org.apache.nemo.compiler.optimizer.policy.TransientResourcePolicy (implements org.apache.nemo.compiler.optimizer.policy.Policy)
  • org.apache.nemo.driver.UserApplicationRunner
  • org.apache.spark.sql.expressions.UserDefinedAggregateFunction (implements scala.Serializable)
    • org.apache.nemo.examples.spark.sql.JavaUserDefinedUntypedAggregation.MyAverage
  • org.apache.nemo.common.Util
  • org.apache.nemo.common.dag.Vertex (implements java.io.Serializable)
    • org.apache.nemo.common.ir.vertex.IRVertex (implements org.apache.nemo.common.Cloneable<T>)
      • org.apache.nemo.common.ir.vertex.LoopVertex
        • org.apache.nemo.common.ir.vertex.utility.TaskSizeSplitterVertex
      • org.apache.nemo.common.ir.vertex.OperatorVertex
        • org.apache.nemo.common.ir.vertex.utility.runtimepass.MessageAggregatorVertex<K,V,O>
        • org.apache.nemo.common.ir.vertex.utility.runtimepass.MessageGeneratorVertex<I,K,V>
        • org.apache.nemo.common.ir.vertex.utility.RelayVertex
        • org.apache.nemo.common.ir.vertex.utility.runtimepass.SignalVertex
      • org.apache.nemo.common.ir.vertex.utility.SamplingVertex
      • org.apache.nemo.common.ir.vertex.SourceVertex<O>
        • org.apache.nemo.compiler.frontend.beam.source.BeamBoundedSourceVertex<O>
        • org.apache.nemo.compiler.frontend.beam.source.BeamUnboundedSourceVertex<O,M>
        • org.apache.nemo.common.ir.vertex.CachedSourceVertex<T>
        • org.apache.nemo.common.test.EmptyComponents.EmptySourceVertex<T>
        • org.apache.nemo.common.ir.vertex.InMemorySourceVertex<T>
    • org.apache.nemo.runtime.common.plan.Stage
  • org.apache.nemo.common.punctuation.Watermark (implements java.lang.Comparable<T>, java.io.Serializable)
  • org.apache.nemo.runtime.executor.datatransfer.WatermarkWithIndex (implements java.io.Serializable)
  • org.eclipse.jetty.websocket.api.WebSocketAdapter (implements org.eclipse.jetty.websocket.api.WebSocketListener)
    • org.apache.nemo.runtime.master.servlet.WebSocketMetricAdapter
  • org.apache.nemo.examples.beam.WindowedBroadcast
  • org.apache.nemo.examples.beam.WindowedWordCount
  • org.apache.nemo.examples.beam.WordCount
  • org.apache.nemo.examples.beam.WordCountTimeOut1Sec
  • org.apache.nemo.compiler.optimizer.policy.XGBoostPolicy (implements org.apache.nemo.compiler.optimizer.policy.Policy)

Interface Hierarchy

• java.lang.AutoCloseable
  • org.apache.nemo.runtime.executor.MetricMessageSender
  • org.apache.nemo.runtime.executor.transfer.OutputContext
  • org.apache.nemo.runtime.executor.transfer.TransferOutputStream
• org.apache.nemo.compiler.backend.Backend<Plan>
• java.util.function.BiFunction<T,U,R>
  • org.apache.nemo.common.ir.vertex.utility.runtimepass.MessageAggregatorVertex.MessageAggregatorFunction<K,V,O> (also extends java.io.Serializable)
  • org.apache.nemo.common.ir.vertex.utility.runtimepass.MessageGeneratorVertex.MessageGeneratorFunction<I,K,V> (also extends java.io.Serializable)
• org.apache.nemo.runtime.executor.data.block.Block<K>
• org.apache.nemo.runtime.executor.data.stores.BlockStore
  • org.apache.nemo.runtime.executor.data.stores.RemoteFileStore
• org.apache.nemo.common.Cloneable<T>
• org.apache.nemo.common.eventhandler.CompilerEvent
• org.apache.nemo.runtime.executor.data.streamchainer.DecodeStreamChainer
• org.apache.nemo.runtime.executor.data.streamchainer.EncodeStreamChainer
• org.apache.reef.wake.EventHandler<T>
  • org.apache.nemo.common.eventhandler.CommonEventHandler<T>
    • org.apache.nemo.common.eventhandler.CompilerEventHandler<T>
    • org.apache.nemo.common.eventhandler.RuntimeEventHandler<T>
• org.apache.nemo.runtime.master.resource.ExecutorRepresenter
• org.apache.beam.sdk.transforms.display.HasDisplayData
  • org.apache.beam.sdk.options.PipelineOptions
    • org.apache.nemo.examples.beam.BeamWordCount.WordCountOptions
    • org.apache.nemo.compiler.frontend.beam.NemoPipelineOptions
• org.apache.nemo.runtime.executor.datatransfer.InputReader
• org.apache.nemo.runtime.executor.datatransfer.InputWatermarkManager
• org.apache.nemo.common.ir.IRDAGChecker.GlobalDAGChecker
• java.util.Iterator<E>
  • org.apache.nemo.runtime.executor.data.DataUtil.IteratorWithNumBytes<T>
• org.apache.nemo.runtime.common.message.MessageContext
• org.apache.nemo.runtime.common.message.MessageEnvironment
• org.apache.nemo.runtime.common.message.MessageListener<T>
• com.google.protobuf.MessageLiteOrBuilder
  • com.google.protobuf.MessageOrBuilder
    • org.apache.nemo.runtime.common.comm.ControlMessage.BlockLocationInfoMsgOrBuilder
    • org.apache.nemo.runtime.common.comm.ControlMessage.BlockStateChangedMsgOrBuilder
    • org.apache.nemo.runtime.common.comm.ControlMessage.BlockTransferContextDescriptorOrBuilder
    • org.apache.nemo.runtime.common.comm.ControlMessage.ByteTransferContextSetupMessageOrBuilder
    • org.apache.nemo.runtime.common.comm.ControlMessage.ClientToDriverMessageOrBuilder
    • org.apache.nemo.runtime.common.comm.ControlMessage.ContainerFailedMsgOrBuilder
    • org.apache.nemo.runtime.common.comm.ControlMessage.DataCollectMessageOrBuilder
    • org.apache.nemo.runtime.common.comm.ControlMessage.DriverToClientMessageOrBuilder
    • org.apache.nemo.runtime.common.comm.ControlMessage.ExecutorFailedMsgOrBuilder
    • org.apache.nemo.runtime.common.comm.ControlMessage.InMasterBroadcastVariableMessageOrBuilder
    • org.apache.nemo.runtime.common.comm.ControlMessage.LaunchDAGMessageOrBuilder
    • org.apache.nemo.runtime.common.comm.ControlMessage.MessageOrBuilder
    • org.apache.nemo.runtime.common.comm.ControlMessage.MetricMsgOrBuilder
    • org.apache.nemo.runtime.common.comm.ControlMessage.MetricOrBuilder
    • org.apache.nemo.runtime.common.comm.ControlMessage.NotificationMessageOrBuilder
    • org.apache.nemo.runtime.common.comm.ControlMessage.PipeInitMessageOrBuilder
    • org.apache.nemo.runtime.common.comm.ControlMessage.PipeLocationInfoMessageOrBuilder
    • org.apache.nemo.runtime.common.comm.ControlMessage.PipeTransferContextDescriptorOrBuilder
    • org.apache.nemo.runtime.common.comm.ControlMessage.RequestBlockLocationMsgOrBuilder
    • org.apache.nemo.runtime.common.comm.ControlMessage.RequestBroadcastVariableMessageOrBuilder
    • org.apache.nemo.runtime.common.comm.ControlMessage.RequestPipeLocationMessageOrBuilder
    • org.apache.nemo.runtime.common.comm.ControlMessage.RunTimePassMessageEntryOrBuilder
    • org.apache.nemo.runtime.common.comm.ControlMessage.RunTimePassMessageMsgOrBuilder
    • org.apache.nemo.runtime.common.comm.ControlMessage.ScheduleTaskMsgOrBuilder
    • org.apache.nemo.runtime.common.comm.ControlMessage.TaskStateChangedMsgOrBuilder
    • org.apache.nemo.runtime.common.comm.GrpcMessageService.VoidOrBuilder
• org.apache.nemo.runtime.common.message.MessageSender<T>
• org.apache.nemo.runtime.common.metric.Metric
  • org.apache.nemo.runtime.common.metric.StateMetric<T>
• org.apache.nemo.runtime.master.metric.MetricMessageHandler
• org.apache.nemo.runtime.common.NettyChannelImplementationSelector
• org.apache.nemo.compiler.optimizer.Optimizer
• org.apache.nemo.runtime.executor.datatransfer.OutputWriter
• org.apache.nemo.runtime.executor.data.partition.Partition<T,K>
• org.apache.nemo.common.partitioner.Partitioner<K>
• org.apache.nemo.runtime.common.plan.PlanRewriter
• org.apache.nemo.compiler.backend.nemo.prophet.Prophet<K,V>
• org.apache.nemo.common.eventhandler.RuntimeEvent
• org.apache.nemo.runtime.master.scheduler.Scheduler
• org.apache.nemo.runtime.master.scheduler.SchedulingConstraint
• org.apache.nemo.runtime.master.scheduler.SchedulingPolicy
• java.io.Serializable
  • org.apache.nemo.common.dag.DAGInterface<V,E>
  • org.apache.nemo.common.coder.DecoderFactory<T>
  • org.apache.nemo.common.coder.DecoderFactory.Decoder<T>
  • org.apache.nemo.common.coder.EncoderFactory<T>
  • org.apache.nemo.common.coder.EncoderFactory.Encoder<T>
  • org.apache.nemo.common.KeyExtractor
  • org.apache.nemo.common.KeyRange<K>
  • org.apache.nemo.common.ir.vertex.utility.runtimepass.MessageAggregatorVertex.InitialStateSupplier<O> (also extends java.util.function.Supplier<T>)
  • org.apache.nemo.common.ir.vertex.utility.runtimepass.MessageAggregatorVertex.MessageAggregatorFunction<K,V,O> (also extends java.util.function.BiFunction<T,U,R>)
  • org.apache.nemo.common.ir.vertex.utility.runtimepass.MessageGeneratorVertex.MessageGeneratorFunction<I,K,V> (also extends java.util.function.BiFunction<T,U,R>)
  • org.apache.nemo.common.ir.OutputCollector<O>
  • org.apache.nemo.compiler.optimizer.policy.Policy
  • org.apache.nemo.common.ir.Readable<O>
  • org.apache.nemo.common.ir.vertex.transform.Transform<I,O>
  • org.apache.nemo.common.ir.vertex.transform.Transform.Context
• org.apache.nemo.client.StateTranslator
• java.util.function.Supplier<T>
  • org.apache.nemo.common.ir.vertex.utility.runtimepass.MessageAggregatorVertex.InitialStateSupplier<O> (also extends java.io.Serializable)

Annotation Type Hierarchy

• org.apache.nemo.compiler.optimizer.pass.compiletime.annotating.Annotates (implements java.lang.annotation.Annotation)
• org.apache.nemo.common.ir.executionproperty.AssociatedProperty (implements java.lang.annotation.Annotation)
• org.apache.nemo.common.partitioner.DedicatedKeyPerElement (implements java.lang.annotation.Annotation)
• org.apache.nemo.compiler.optimizer.pass.compiletime.Requires (implements java.lang.annotation.Annotation)

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • org.apache.nemo.common.ir.edge.executionproperty.BlockFetchFailureProperty.Value
    • org.apache.nemo.runtime.common.state.BlockState.State
    • org.apache.nemo.common.ir.edge.executionproperty.CommunicationPatternProperty.Value
    • org.apache.nemo.common.ir.edge.executionproperty.CompressionProperty.Value
    • org.apache.nemo.runtime.common.comm.ControlMessage.BlockStateFromExecutor (implements com.google.protobuf.ProtocolMessageEnum)
    • org.apache.nemo.runtime.common.comm.ControlMessage.BlockStore (implements com.google.protobuf.ProtocolMessageEnum)
    • org.apache.nemo.runtime.common.comm.ControlMessage.ByteTransferDataDirection (implements com.google.protobuf.ProtocolMessageEnum)
    • org.apache.nemo.runtime.common.comm.ControlMessage.ClientToDriverMessageType (implements com.google.protobuf.ProtocolMessageEnum)
    • org.apache.nemo.runtime.common.comm.ControlMessage.DriverToClientMessageType (implements com.google.protobuf.ProtocolMessageEnum)
    • org.apache.nemo.runtime.common.comm.ControlMessage.MessageType (implements com.google.protobuf.ProtocolMessageEnum)
    • org.apache.nemo.runtime.common.comm.ControlMessage.OptimizationType (implements com.google.protobuf.ProtocolMessageEnum)
    • org.apache.nemo.runtime.common.comm.ControlMessage.RecoverableFailureCause (implements com.google.protobuf.ProtocolMessageEnum)
    • org.apache.nemo.runtime.common.comm.ControlMessage.TaskStateFromExecutor (implements com.google.protobuf.ProtocolMessageEnum)
    • org.apache.nemo.common.dag.DAGInterface.TraversalOrder
    • org.apache.nemo.common.ir.edge.executionproperty.DataFlowProperty.Value
    • org.apache.nemo.common.ir.edge.executionproperty.DataPersistenceProperty.Value
    • org.apache.nemo.common.ir.edge.executionproperty.DataStoreProperty.Value
    • org.apache.nemo.runtime.common.metric.DataTransferEvent.TransferType
    • org.apache.nemo.common.ir.edge.executionproperty.PartitionerProperty.Type
    • org.apache.nemo.runtime.common.state.PlanState.State
    • org.apache.nemo.common.ir.vertex.executionproperty.ResourceLambdaProperty.Value
    • org.apache.nemo.runtime.common.state.StageState.State
    • org.apache.nemo.runtime.common.state.TaskState.RecoverableTaskFailureCause
    • org.apache.nemo.runtime.common.state.TaskState.State
    • org.apache.nemo.runtime.common.plan.TestPlanGenerator.PlanType