Packages

Package	Description
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	Responsible for transferring block content from one executor to another.
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