Hierarchy For All Packages

Package Hierarchies:

• edu.snu.coral.client,
• edu.snu.coral.common,
• edu.snu.coral.common.coder,
• edu.snu.coral.common.dag,
• edu.snu.coral.common.eventhandler,
• edu.snu.coral.common.exception,
• edu.snu.coral.common.ir,
• edu.snu.coral.common.ir.edge,
• edu.snu.coral.common.ir.edge.executionproperty,
• edu.snu.coral.common.ir.executionproperty,
• edu.snu.coral.common.ir.vertex,
• edu.snu.coral.common.ir.vertex.executionproperty,
• edu.snu.coral.common.ir.vertex.transform,
• edu.snu.coral.compiler.backend,
• edu.snu.coral.compiler.backend.coral,
• edu.snu.coral.compiler.frontend.beam,
• edu.snu.coral.compiler.frontend.beam.coder,
• edu.snu.coral.compiler.frontend.beam.source,
• edu.snu.coral.compiler.frontend.beam.transform,
• edu.snu.coral.compiler.frontend.spark,
• edu.snu.coral.compiler.frontend.spark.coder,
• edu.snu.coral.compiler.frontend.spark.core,
• edu.snu.coral.compiler.frontend.spark.core.java,
• edu.snu.coral.compiler.frontend.spark.source,
• edu.snu.coral.compiler.frontend.spark.sql,
• edu.snu.coral.compiler.frontend.spark.transform,
• edu.snu.coral.compiler.optimizer,
• edu.snu.coral.compiler.optimizer.examples,
• edu.snu.coral.compiler.optimizer.pass.compiletime,
• edu.snu.coral.compiler.optimizer.pass.compiletime.annotating,
• edu.snu.coral.compiler.optimizer.pass.compiletime.composite,
• edu.snu.coral.compiler.optimizer.pass.compiletime.reshaping,
• edu.snu.coral.compiler.optimizer.policy,
• edu.snu.coral.conf,
• edu.snu.coral.driver,
• edu.snu.coral.examples.beam,
• edu.snu.coral.examples.spark,
• edu.snu.coral.runtime.common,
• edu.snu.coral.runtime.common.data,
• edu.snu.coral.runtime.common.eventhandler,
• edu.snu.coral.runtime.common.exception,
• edu.snu.coral.runtime.common.message,
• edu.snu.coral.runtime.common.message.grpc,
• edu.snu.coral.runtime.common.message.local,
• edu.snu.coral.runtime.common.message.ncs,
• edu.snu.coral.runtime.common.metric,
• edu.snu.coral.runtime.common.metric.parameter,
• edu.snu.coral.runtime.common.optimizer,
• edu.snu.coral.runtime.common.optimizer.pass.runtime,
• edu.snu.coral.runtime.common.plan,
• edu.snu.coral.runtime.common.plan.physical,
• edu.snu.coral.runtime.common.plan.stage,
• edu.snu.coral.runtime.common.state,
• edu.snu.coral.runtime.executor,
• edu.snu.coral.runtime.executor.data,
• edu.snu.coral.runtime.executor.data.block,
• edu.snu.coral.runtime.executor.data.blocktransfer,
• edu.snu.coral.runtime.executor.data.metadata,
• edu.snu.coral.runtime.executor.data.partitioner,
• edu.snu.coral.runtime.executor.data.stores,
• edu.snu.coral.runtime.executor.datatransfer,
• edu.snu.coral.runtime.master,
• edu.snu.coral.runtime.master.eventhandler,
• edu.snu.coral.runtime.master.resource,
• edu.snu.coral.runtime.master.scheduler

Class Hierarchy

• java.lang.Object
  • edu.snu.coral.runtime.executor.data.stores.AbstractBlockStore (implements edu.snu.coral.runtime.executor.data.stores.BlockStore)
    • edu.snu.coral.runtime.executor.data.stores.GlusterFileStore (implements edu.snu.coral.runtime.executor.data.stores.RemoteFileStore)
    • edu.snu.coral.runtime.executor.data.stores.LocalBlockStore
      • edu.snu.coral.runtime.executor.data.stores.LocalFileStore (implements edu.snu.coral.runtime.executor.data.stores.FileStore)
      • edu.snu.coral.runtime.executor.data.stores.MemoryStore
      • edu.snu.coral.runtime.executor.data.stores.SerializedMemoryStore
  • org.apache.spark.api.java.AbstractJavaRDDLike<T,This> (implements org.apache.spark.api.java.JavaRDDLike<T,This>)
    • org.apache.spark.api.java.JavaPairRDD<K,V>
      • edu.snu.coral.compiler.frontend.spark.core.java.JavaPairRDD<K,V>
    • org.apache.spark.api.java.JavaRDD<T>
      • edu.snu.coral.compiler.frontend.spark.core.java.JavaRDD<T>
  • edu.snu.coral.examples.beam.AlternatingLeastSquare
  • edu.snu.coral.examples.beam.AlternatingLeastSquareInefficient
  • edu.snu.coral.compiler.optimizer.pass.compiletime.annotating.AnnotatingPass (implements edu.snu.coral.compiler.optimizer.pass.compiletime.CompileTimePass)
    • edu.snu.coral.compiler.optimizer.pass.compiletime.annotating.CompressionPass
    • edu.snu.coral.compiler.optimizer.pass.compiletime.annotating.DataSkewEdgeDataStorePass
    • edu.snu.coral.compiler.optimizer.pass.compiletime.annotating.DataSkewEdgeMetricCollectionPass
    • edu.snu.coral.compiler.optimizer.pass.compiletime.annotating.DataSkewEdgePartitionerPass
    • edu.snu.coral.compiler.optimizer.pass.compiletime.annotating.DataSkewVertexPass
    • edu.snu.coral.compiler.optimizer.pass.compiletime.annotating.DefaultEdgeUsedDataHandlingPass
    • edu.snu.coral.compiler.optimizer.pass.compiletime.annotating.DefaultParallelismPass
    • edu.snu.coral.compiler.optimizer.pass.compiletime.annotating.DefaultStagePartitioningPass
    • edu.snu.coral.compiler.optimizer.pass.compiletime.annotating.DisaggregationEdgeDataStorePass
    • edu.snu.coral.compiler.optimizer.pass.compiletime.annotating.PadoEdgeDataFlowModelPass
    • edu.snu.coral.compiler.optimizer.pass.compiletime.annotating.PadoEdgeDataStorePass
    • edu.snu.coral.compiler.optimizer.pass.compiletime.annotating.PadoVertexExecutorPlacementPass
    • edu.snu.coral.compiler.optimizer.pass.compiletime.annotating.ReviseInterStageEdgeDataStorePass
    • edu.snu.coral.compiler.optimizer.pass.compiletime.annotating.SailfishEdgeDataFlowModelPass
    • edu.snu.coral.compiler.optimizer.pass.compiletime.annotating.SailfishEdgeDataStorePass
    • edu.snu.coral.compiler.optimizer.pass.compiletime.annotating.SailfishEdgeUsedDataHandlingPass
    • edu.snu.coral.compiler.optimizer.pass.compiletime.annotating.ScheduleGroupPass
    • edu.snu.coral.compiler.optimizer.pass.compiletime.annotating.ShuffleEdgePushPass
  • edu.snu.coral.common.ArgBuilder
  • edu.snu.coral.runtime.master.scheduler.BatchSingleJobScheduler (implements edu.snu.coral.runtime.master.scheduler.Scheduler)
  • edu.snu.coral.compiler.frontend.beam.coder.BeamCoder<T> (implements edu.snu.coral.common.coder.Coder<T>)
  • edu.snu.coral.compiler.frontend.beam.BeamStateTranslator (implements edu.snu.coral.client.StateTranslator)
  • edu.snu.coral.runtime.executor.data.blocktransfer.BlockInputStream<T> (implements edu.snu.coral.runtime.executor.data.blocktransfer.BlockStream)
  • edu.snu.coral.runtime.master.BlockManagerMaster
  • edu.snu.coral.runtime.master.BlockManagerMaster.PartitionManagerMasterControlMessageReceiver (implements edu.snu.coral.runtime.common.message.MessageListener<T>)
  • edu.snu.coral.runtime.executor.data.BlockManagerWorker
  • edu.snu.coral.runtime.executor.data.blocktransfer.BlockOutputStream<T> (implements java.lang.AutoCloseable, edu.snu.coral.runtime.executor.data.blocktransfer.BlockStream)
  • edu.snu.coral.runtime.common.state.BlockState
  • edu.snu.coral.examples.beam.Broadcast
  • edu.snu.coral.common.coder.BytesCoder (implements edu.snu.coral.common.coder.Coder<T>)
  • io.netty.channel.ChannelHandlerAdapter (implements io.netty.channel.ChannelHandler)
    • io.netty.channel.ChannelInboundHandlerAdapter (implements io.netty.channel.ChannelInboundHandler)
      • io.netty.channel.SimpleChannelInboundHandler<I>
        • edu.snu.coral.runtime.executor.data.blocktransfer.BlockTransfer
  • edu.snu.coral.client.ClientEndpoint
    • edu.snu.coral.compiler.frontend.beam.CoralPipelineResult (implements org.apache.beam.sdk.PipelineResult)
  • edu.snu.coral.runtime.executor.data.blocktransfer.ClosableBlockingQueue<T> (implements java.lang.AutoCloseable)
  • org.apache.beam.sdk.coders.Coder<T> (implements java.io.Serializable)
    • org.apache.beam.sdk.coders.StructuredCoder<T>
      • edu.snu.coral.compiler.frontend.beam.coder.PairCoder<A,B>
  • edu.snu.coral.common.coder.Coder.DummyCoder (implements edu.snu.coral.common.coder.Coder<T>)
  • edu.snu.coral.runtime.executor.data.CoderManager
  • edu.snu.coral.compiler.frontend.spark.transform.CollectTransform<T> (implements edu.snu.coral.common.ir.vertex.transform.Transform<I,O>)
  • org.apache.beam.sdk.transforms.Combine.CombineFn<InputT,AccumT,OutputT>
    • edu.snu.coral.examples.beam.AlternatingLeastSquare.TrainingDataCombiner
    • org.apache.beam.sdk.transforms.Combine.BinaryCombineFn<V>
      • edu.snu.coral.examples.beam.MultinomialLogisticRegression.CombineFunction
  • edu.snu.coral.compiler.optimizer.CompiletimeOptimizer
  • edu.snu.coral.compiler.optimizer.pass.compiletime.composite.CompositePass (implements edu.snu.coral.compiler.optimizer.pass.compiletime.CompileTimePass)
    • edu.snu.coral.compiler.optimizer.pass.compiletime.composite.DataSkewCompositePass
    • edu.snu.coral.compiler.optimizer.policy.DefaultPolicyWithSeparatePass.RefactoredPass
    • edu.snu.coral.compiler.optimizer.pass.compiletime.composite.LoopOptimizationCompositePass
    • edu.snu.coral.compiler.optimizer.pass.compiletime.composite.PadoCompositePass
    • edu.snu.coral.compiler.optimizer.pass.compiletime.composite.PrimitiveCompositePass
    • edu.snu.coral.compiler.optimizer.pass.compiletime.composite.SailfishPass
  • org.apache.reef.tang.formats.ConfigurationModuleBuilder
    • edu.snu.coral.conf.JobConf
  • edu.snu.coral.runtime.master.resource.ContainerManager
  • edu.snu.coral.common.ContextImpl (implements edu.snu.coral.common.ir.vertex.transform.Transform.Context)
  • edu.snu.coral.compiler.backend.coral.CoralBackend (implements edu.snu.coral.compiler.backend.Backend<Plan>)
  • edu.snu.coral.client.CoralClient
  • edu.snu.coral.client.CoralClient.JobMessageHandler (implements org.apache.reef.wake.EventHandler<T>)
  • edu.snu.coral.driver.CoralContext
  • edu.snu.coral.driver.CoralContext.ContextStartHandler (implements org.apache.reef.wake.EventHandler<T>)
  • edu.snu.coral.driver.CoralContext.ContextStopHandler (implements org.apache.reef.wake.EventHandler<T>)
  • edu.snu.coral.driver.CoralDriver
  • edu.snu.coral.driver.CoralDriver.ActiveContextHandler (implements org.apache.reef.wake.EventHandler<T>)
  • edu.snu.coral.driver.CoralDriver.AllocatedEvaluatorHandler (implements org.apache.reef.wake.EventHandler<T>)
  • edu.snu.coral.driver.CoralDriver.DriverStopHandler (implements org.apache.reef.wake.EventHandler<T>)
  • edu.snu.coral.driver.CoralDriver.FailedContextHandler (implements org.apache.reef.wake.EventHandler<T>)
  • edu.snu.coral.driver.CoralDriver.FailedEvaluatorHandler (implements org.apache.reef.wake.EventHandler<T>)
  • edu.snu.coral.driver.CoralDriver.StartHandler (implements org.apache.reef.wake.EventHandler<T>)
  • edu.snu.coral.compiler.frontend.beam.transform.CreateViewTransform<I,O> (implements edu.snu.coral.common.ir.vertex.transform.Transform<I,O>)
  • edu.snu.coral.common.dag.DAG<V,E> (implements java.io.Serializable)
  • edu.snu.coral.common.dag.DAGBuilder<V,E> (implements java.io.Serializable)
  • org.apache.spark.sql.DataFrameReader (implements org.apache.spark.internal.Logging)
    • edu.snu.coral.compiler.frontend.spark.sql.DataFrameReader
  • org.apache.spark.sql.Dataset<T> (implements scala.Serializable)
    • edu.snu.coral.compiler.frontend.spark.sql.Dataset<T>
  • edu.snu.coral.runtime.executor.data.partitioner.DataSkewHashPartitioner (implements edu.snu.coral.runtime.executor.data.partitioner.Partitioner)
  • edu.snu.coral.compiler.optimizer.policy.DataSkewPolicy (implements edu.snu.coral.compiler.optimizer.policy.Policy)
  • edu.snu.coral.runtime.common.optimizer.pass.runtime.DataSkewRuntimePass (implements edu.snu.coral.runtime.common.optimizer.pass.runtime.RuntimePass<T>)
  • edu.snu.coral.runtime.executor.datatransfer.DataTransfer
    • edu.snu.coral.runtime.executor.datatransfer.InputReader
    • edu.snu.coral.runtime.executor.datatransfer.OutputWriter (implements java.lang.AutoCloseable)
  • edu.snu.coral.runtime.executor.datatransfer.DataTransferFactory
  • edu.snu.coral.runtime.executor.data.DataUtil
  • edu.snu.coral.runtime.executor.data.DataUtil.InputStreamIterator<T> (implements java.util.Iterator<E>)
  • edu.snu.coral.compiler.optimizer.policy.DefaultPolicy (implements edu.snu.coral.compiler.optimizer.policy.Policy)
  • edu.snu.coral.compiler.optimizer.policy.DefaultPolicyWithSeparatePass (implements edu.snu.coral.compiler.optimizer.policy.Policy)
  • edu.snu.coral.compiler.optimizer.policy.DisaggregationPolicy (implements edu.snu.coral.compiler.optimizer.policy.Policy)
  • org.apache.beam.sdk.transforms.DoFn<InputT,OutputT> (implements org.apache.beam.sdk.transforms.display.HasDisplayData, java.io.Serializable)
    • edu.snu.coral.examples.beam.AlternatingLeastSquare.CalculateNextMatrix
    • edu.snu.coral.examples.beam.AlternatingLeastSquare.ParseLine
    • edu.snu.coral.examples.beam.AlternatingLeastSquare.UngroupSingleVectorList
    • edu.snu.coral.examples.beam.MultinomialLogisticRegression.ApplyGradient
    • edu.snu.coral.examples.beam.MultinomialLogisticRegression.CalculateGradient
  • edu.snu.coral.compiler.frontend.beam.transform.DoTransform<I,O> (implements edu.snu.coral.common.ir.vertex.transform.Transform<I,O>)
  • edu.snu.coral.client.DriverEndpoint
  • edu.snu.coral.runtime.common.eventhandler.DynamicOptimizationEvent (implements edu.snu.coral.common.eventhandler.RuntimeEvent)
  • edu.snu.coral.runtime.common.eventhandler.DynamicOptimizationEventHandler (implements edu.snu.coral.common.eventhandler.RuntimeEventHandler<T>)
  • edu.snu.coral.common.dag.Edge<V> (implements java.io.Serializable)
    • edu.snu.coral.common.ir.edge.IREdge
    • edu.snu.coral.runtime.common.plan.RuntimeEdge<V>
      • edu.snu.coral.runtime.common.plan.physical.PhysicalStageEdge
      • edu.snu.coral.runtime.common.plan.stage.StageEdge
  • edu.snu.coral.compiler.optimizer.examples.EmptyComponents
  • edu.snu.coral.compiler.optimizer.examples.EmptyComponents.EmptyTransform<I,O> (implements edu.snu.coral.common.ir.vertex.transform.Transform<I,O>)
  • edu.snu.coral.common.ir.executionproperty.ExecutionProperty<T> (implements java.io.Serializable)
    • edu.snu.coral.common.ir.edge.executionproperty.CompressionProperty
    • edu.snu.coral.common.ir.edge.executionproperty.DataCommunicationPatternProperty
    • edu.snu.coral.common.ir.edge.executionproperty.DataFlowModelProperty
    • edu.snu.coral.common.ir.edge.executionproperty.DataStoreProperty
    • edu.snu.coral.common.ir.vertex.executionproperty.DynamicOptimizationProperty
    • edu.snu.coral.common.ir.vertex.executionproperty.ExecutorPlacementProperty
    • edu.snu.coral.common.ir.edge.executionproperty.KeyExtractorProperty
    • edu.snu.coral.common.ir.edge.executionproperty.MetricCollectionProperty
    • edu.snu.coral.common.ir.vertex.executionproperty.ParallelismProperty
    • edu.snu.coral.common.ir.edge.executionproperty.PartitionerProperty
    • edu.snu.coral.common.ir.vertex.executionproperty.ScheduleGroupIndexProperty
    • edu.snu.coral.common.ir.vertex.executionproperty.StageIdProperty
    • edu.snu.coral.common.ir.edge.executionproperty.UsedDataHandlingProperty
  • edu.snu.coral.common.ir.executionproperty.ExecutionPropertyMap (implements java.io.Serializable)
  • edu.snu.coral.runtime.executor.Executor
  • edu.snu.coral.runtime.master.resource.ExecutorRepresenter
  • edu.snu.coral.runtime.executor.data.FileArea (implements java.io.Serializable)
  • edu.snu.coral.runtime.executor.data.block.FileBlock<K> (implements edu.snu.coral.runtime.executor.data.block.Block<K>)
  • edu.snu.coral.runtime.executor.data.metadata.FileMetadata<K>
    • edu.snu.coral.runtime.executor.data.metadata.LocalFileMetadata<K>
    • edu.snu.coral.runtime.executor.data.metadata.RemoteFileMetadata<K>
  • edu.snu.coral.compiler.frontend.spark.transform.FlatMapTransform<T,U> (implements edu.snu.coral.common.ir.vertex.transform.Transform<I,O>)
  • edu.snu.coral.compiler.frontend.beam.transform.FlattenTransform<T> (implements edu.snu.coral.common.ir.vertex.transform.Transform<I,O>)
  • edu.snu.coral.compiler.frontend.beam.transform.GroupByKeyTransform<I> (implements edu.snu.coral.common.ir.vertex.transform.Transform<I,O>)
  • edu.snu.coral.compiler.frontend.spark.transform.GroupByKeyTransform<K,V> (implements edu.snu.coral.common.ir.vertex.transform.Transform<I,O>)
  • edu.snu.coral.runtime.common.message.grpc.GrpcMessageEnvironment (implements edu.snu.coral.runtime.common.message.MessageEnvironment)
  • java.util.logging.Handler
    • edu.snu.coral.driver.RemoteClientMessageLoggingHandler
  • edu.snu.coral.runtime.executor.data.partitioner.HashPartitioner (implements edu.snu.coral.runtime.executor.data.partitioner.Partitioner)
  • edu.snu.coral.runtime.common.data.HashRange (implements edu.snu.coral.runtime.common.data.KeyRange<K>)
  • edu.snu.coral.common.ir.IdManager
  • edu.snu.coral.runtime.executor.data.partitioner.IntactPartitioner (implements edu.snu.coral.runtime.executor.data.partitioner.Partitioner)
  • edu.snu.coral.compiler.frontend.spark.core.java.JavaSparkContext
  • edu.snu.coral.examples.spark.JavaSparkPi
  • edu.snu.coral.examples.spark.JavaWordCount
  • edu.snu.coral.conf.JobConf.DAGDirectory (implements org.apache.reef.tang.annotations.Name<T>)
  • edu.snu.coral.conf.JobConf.DeployMode (implements org.apache.reef.tang.annotations.Name<T>)
  • edu.snu.coral.conf.JobConf.DriverMemMb (implements org.apache.reef.tang.annotations.Name<T>)
  • edu.snu.coral.conf.JobConf.ExecutorCapacity (implements org.apache.reef.tang.annotations.Name<T>)
  • edu.snu.coral.conf.JobConf.ExecutorId (implements org.apache.reef.tang.annotations.Name<T>)
  • edu.snu.coral.conf.JobConf.ExecutorJsonContents (implements org.apache.reef.tang.annotations.Name<T>)
  • edu.snu.coral.conf.JobConf.ExecutorJsonPath (implements org.apache.reef.tang.annotations.Name<T>)
  • edu.snu.coral.conf.JobConf.FileDirectory (implements org.apache.reef.tang.annotations.Name<T>)
  • edu.snu.coral.conf.JobConf.GlusterVolumeDirectory (implements org.apache.reef.tang.annotations.Name<T>)
  • edu.snu.coral.conf.JobConf.HashRangeMultiplier (implements org.apache.reef.tang.annotations.Name<T>)
  • edu.snu.coral.conf.JobConf.IORequestHandleThreadsTotal (implements org.apache.reef.tang.annotations.Name<T>)
  • edu.snu.coral.conf.JobConf.JobId (implements org.apache.reef.tang.annotations.Name<T>)
  • edu.snu.coral.conf.JobConf.JVMHeapSlack (implements org.apache.reef.tang.annotations.Name<T>)
  • edu.snu.coral.conf.JobConf.MaxScheduleAttempt (implements org.apache.reef.tang.annotations.Name<T>)
  • edu.snu.coral.conf.JobConf.OptimizationPolicy (implements org.apache.reef.tang.annotations.Name<T>)
  • edu.snu.coral.conf.JobConf.PartitionTransportClientNumThreads (implements org.apache.reef.tang.annotations.Name<T>)
  • edu.snu.coral.conf.JobConf.PartitionTransportServerBacklog (implements org.apache.reef.tang.annotations.Name<T>)
  • edu.snu.coral.conf.JobConf.PartitionTransportServerNumListeningThreads (implements org.apache.reef.tang.annotations.Name<T>)
  • edu.snu.coral.conf.JobConf.PartitionTransportServerNumWorkingThreads (implements org.apache.reef.tang.annotations.Name<T>)
  • edu.snu.coral.conf.JobConf.PartitionTransportServerPort (implements org.apache.reef.tang.annotations.Name<T>)
  • edu.snu.coral.conf.JobConf.SchedulerTimeoutMs (implements org.apache.reef.tang.annotations.Name<T>)
  • edu.snu.coral.conf.JobConf.ScheduleSerThread (implements org.apache.reef.tang.annotations.Name<T>)
  • edu.snu.coral.conf.JobConf.SerializedDAG (implements org.apache.reef.tang.annotations.Name<T>)
  • edu.snu.coral.conf.JobConf.UserMainArguments (implements org.apache.reef.tang.annotations.Name<T>)
  • edu.snu.coral.conf.JobConf.UserMainClass (implements org.apache.reef.tang.annotations.Name<T>)
  • edu.snu.coral.client.JobLauncher
  • edu.snu.coral.runtime.common.state.JobState
  • edu.snu.coral.runtime.master.JobStateManager
  • edu.snu.coral.runtime.common.message.local.LocalMessageDispatcher
  • edu.snu.coral.runtime.common.message.local.LocalMessageEnvironment (implements edu.snu.coral.runtime.common.message.MessageEnvironment)
  • edu.snu.coral.runtime.common.message.local.LocalMessageSender<T> (implements edu.snu.coral.runtime.common.message.MessageSender<T>)
  • edu.snu.coral.compiler.optimizer.pass.compiletime.reshaping.LoopOptimizations
  • edu.snu.coral.examples.beam.MapReduce
  • edu.snu.coral.compiler.optimizer.examples.MapReduceDisaggregationOptimization
  • edu.snu.coral.compiler.frontend.spark.transform.MapToPairTransform<T,K,V> (implements edu.snu.coral.common.ir.vertex.transform.Transform<I,O>)
  • edu.snu.coral.compiler.frontend.spark.transform.MapTransform<I,O> (implements edu.snu.coral.common.ir.vertex.transform.Transform<I,O>)
  • edu.snu.coral.runtime.common.message.MessageParameters
  • edu.snu.coral.runtime.common.message.MessageParameters.SenderId (implements org.apache.reef.tang.annotations.Name<T>)
  • edu.snu.coral.runtime.common.metric.MetricData
  • edu.snu.coral.runtime.common.metric.MetricDataBuilder
  • edu.snu.coral.runtime.common.metric.parameter.MetricFlushPeriod (implements org.apache.reef.tang.annotations.Name<T>)
  • edu.snu.coral.runtime.master.MetricManagerMaster (implements edu.snu.coral.runtime.master.MetricMessageHandler)
  • edu.snu.coral.runtime.executor.MetricManagerWorker (implements edu.snu.coral.runtime.executor.MetricMessageSender)
  • edu.snu.coral.examples.beam.MultinomialLogisticRegression
  • edu.snu.coral.examples.beam.MultinomialLogisticRegression.CombineFunctionForIterable (implements org.apache.beam.sdk.transforms.SerializableFunction<InputT,OutputT>)
  • edu.snu.coral.runtime.common.NativeChannelImplementationSelector (implements edu.snu.coral.runtime.common.NettyChannelImplementationSelector)
  • edu.snu.coral.runtime.common.message.ncs.NcsMessageEnvironment (implements edu.snu.coral.runtime.common.message.MessageEnvironment)
  • edu.snu.coral.runtime.common.NioChannelImplementationSelector (implements edu.snu.coral.runtime.common.NettyChannelImplementationSelector)
  • edu.snu.coral.runtime.executor.data.block.NonSerializedMemoryBlock<K> (implements edu.snu.coral.runtime.executor.data.block.Block<K>)
  • edu.snu.coral.runtime.executor.data.NonSerializedPartition<K> (implements edu.snu.coral.runtime.executor.data.Partition<T,K>)
  • edu.snu.coral.runtime.executor.datatransfer.OutputCollectorImpl<O> (implements edu.snu.coral.common.ir.OutputCollector<O>)
  • java.io.OutputStream (implements java.io.Closeable, java.io.Flushable)
    • java.io.ByteArrayOutputStream
      • edu.snu.coral.common.DirectByteArrayOutputStream
  • edu.snu.coral.compiler.optimizer.policy.PadoPolicy (implements edu.snu.coral.compiler.optimizer.policy.Policy)
  • edu.snu.coral.common.Pair<A,B> (implements java.io.Serializable)
  • edu.snu.coral.runtime.executor.data.metadata.PartitionMetadata<K>
  • edu.snu.coral.runtime.common.message.PersistentConnectionToMasterMap
  • edu.snu.coral.runtime.common.plan.physical.PhysicalPlan (implements java.io.Serializable)
  • edu.snu.coral.runtime.common.plan.physical.PhysicalPlanGenerator (implements java.util.function.Function<T,R>)
  • org.apache.beam.sdk.Pipeline.PipelineVisitor.Defaults (implements org.apache.beam.sdk.Pipeline.PipelineVisitor)
    • edu.snu.coral.compiler.frontend.beam.CoralPipelineVisitor
  • org.apache.beam.sdk.PipelineRunner<ResultT>
    • edu.snu.coral.compiler.frontend.beam.CoralPipelineRunner
  • edu.snu.coral.compiler.optimizer.policy.PolicyBuilder
  • org.apache.beam.sdk.transforms.PTransform<InputT,OutputT> (implements org.apache.beam.sdk.transforms.display.HasDisplayData, java.io.Serializable)
    • edu.snu.coral.compiler.frontend.beam.transform.LoopCompositeTransform<inputT,outputT> (implements java.io.Serializable)
      • edu.snu.coral.examples.beam.AlternatingLeastSquare.UpdateUserAndItemMatrix
      • edu.snu.coral.examples.beam.AlternatingLeastSquareInefficient.UpdateUserAndItemMatrix
      • edu.snu.coral.examples.beam.MultinomialLogisticRegression.UpdateModel
  • edu.snu.coral.common.eventhandler.PubSubEventHandlerWrapper
  • org.apache.spark.rdd.RDD<T> (implements org.apache.spark.internal.Logging, scala.Serializable)
    • edu.snu.coral.compiler.frontend.spark.core.RDD<T>
  • edu.snu.coral.compiler.frontend.spark.transform.ReduceByKeyTransform<K,V> (implements edu.snu.coral.common.ir.vertex.transform.Transform<I,O>)
  • edu.snu.coral.compiler.frontend.spark.transform.ReduceTransform<T> (implements edu.snu.coral.common.ir.vertex.transform.Transform<I,O>)
  • edu.snu.coral.common.ir.vertex.transform.RelayTransform<T> (implements edu.snu.coral.common.ir.vertex.transform.Transform<I,O>)
  • edu.snu.coral.runtime.common.ReplyFutureMap<T>
  • edu.snu.coral.compiler.optimizer.pass.compiletime.reshaping.ReshapingPass (implements edu.snu.coral.compiler.optimizer.pass.compiletime.CompileTimePass)
    • edu.snu.coral.compiler.optimizer.pass.compiletime.reshaping.CommonSubexpressionEliminationPass
    • edu.snu.coral.compiler.optimizer.pass.compiletime.reshaping.DataSkewReshapingPass
    • edu.snu.coral.compiler.optimizer.pass.compiletime.reshaping.LoopExtractionPass
    • edu.snu.coral.compiler.optimizer.pass.compiletime.reshaping.LoopOptimizations.LoopFusionPass
    • edu.snu.coral.compiler.optimizer.pass.compiletime.reshaping.LoopOptimizations.LoopInvariantCodeMotionPass
    • edu.snu.coral.compiler.optimizer.pass.compiletime.reshaping.LoopUnrollingPass
    • edu.snu.coral.compiler.optimizer.pass.compiletime.reshaping.SailfishRelayReshapingPass
  • edu.snu.coral.runtime.master.resource.ResourceSpecification
  • edu.snu.coral.runtime.master.resource.ResourceSpecification.Builder
  • edu.snu.coral.runtime.master.scheduler.RoundRobinSchedulingPolicy (implements edu.snu.coral.runtime.master.scheduler.SchedulingPolicy)
  • edu.snu.coral.runtime.common.RuntimeIdGenerator
  • edu.snu.coral.runtime.master.RuntimeMaster
  • edu.snu.coral.runtime.master.RuntimeMaster.MasterControlMessageReceiver (implements edu.snu.coral.runtime.common.message.MessageListener<T>)
  • edu.snu.coral.runtime.common.optimizer.RuntimeOptimizer
  • edu.snu.coral.compiler.optimizer.policy.SailfishPolicy (implements edu.snu.coral.compiler.optimizer.policy.Policy)
  • edu.snu.coral.runtime.common.plan.physical.ScheduledTaskGroup (implements java.io.Serializable)
  • edu.snu.coral.runtime.master.scheduler.SchedulerRunner
  • edu.snu.coral.runtime.executor.data.block.SerializedMemoryBlock<K> (implements edu.snu.coral.runtime.executor.data.block.Block<K>)
  • edu.snu.coral.runtime.executor.data.SerializedPartition<K> (implements edu.snu.coral.runtime.executor.data.Partition<T,K>)
  • edu.snu.coral.runtime.master.scheduler.SingleJobTaskGroupQueue (implements edu.snu.coral.runtime.master.scheduler.PendingTaskGroupQueue)
  • edu.snu.coral.compiler.frontend.spark.coder.SparkCoder<T> (implements edu.snu.coral.common.coder.Coder<T>)
  • edu.snu.coral.compiler.frontend.spark.core.java.SparkFrontendUtils
  • edu.snu.coral.compiler.frontend.spark.SparkKeyExtractor (implements edu.snu.coral.common.KeyExtractor)
  • org.apache.spark.sql.SparkSession (implements java.io.Closeable, org.apache.spark.internal.Logging, scala.Serializable)
    • edu.snu.coral.compiler.frontend.spark.sql.SparkSession
  • org.apache.spark.sql.SparkSession.Builder (implements org.apache.spark.internal.Logging)
    • edu.snu.coral.compiler.frontend.spark.sql.SparkSession.Builder
  • edu.snu.coral.runtime.common.plan.stage.StageBuilder
  • edu.snu.coral.runtime.common.plan.stage.StageEdgeBuilder
  • edu.snu.coral.runtime.common.state.StageState
  • edu.snu.coral.common.StateMachine
  • edu.snu.coral.common.StateMachine.Builder
  • edu.snu.coral.runtime.executor.TaskGroupExecutor
  • edu.snu.coral.runtime.common.state.TaskGroupState
  • edu.snu.coral.runtime.executor.TaskGroupStateManager
  • edu.snu.coral.runtime.common.state.TaskState
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • edu.snu.coral.runtime.common.exception.AbsentBlockException
      • java.lang.RuntimeException
        • edu.snu.coral.common.exception.BlockFetchException
        • edu.snu.coral.common.exception.BlockWriteException
        • edu.snu.coral.common.exception.CompileTimeOptimizationException
        • edu.snu.coral.common.exception.ContainerException
        • edu.snu.coral.common.exception.DynamicOptimizationException
        • edu.snu.coral.common.exception.IllegalEdgeOperationException
        • edu.snu.coral.common.exception.IllegalMessageException
        • edu.snu.coral.common.exception.IllegalStateTransitionException
        • edu.snu.coral.common.exception.IllegalVertexOperationException
        • edu.snu.coral.common.exception.InvalidParameterException
        • edu.snu.coral.common.exception.JsonParseException
        • edu.snu.coral.common.exception.NodeConnectionException
        • edu.snu.coral.common.exception.PhysicalPlanGenerationException
        • edu.snu.coral.common.exception.SchedulingException
        • edu.snu.coral.common.exception.UnknownExecutionStateException
        • edu.snu.coral.common.exception.UnknownFailureCauseException
        • edu.snu.coral.common.exception.UnrecoverableFailureException
        • edu.snu.coral.common.exception.UnsupportedBlockStoreException
        • edu.snu.coral.common.exception.UnsupportedCommPatternException
        • edu.snu.coral.common.exception.UnsupportedExecutionPropertyException
        • edu.snu.coral.common.exception.UnsupportedMethodException
        • edu.snu.coral.common.exception.UnsupportedPartitionerException
  • edu.snu.coral.runtime.common.eventhandler.UpdatePhysicalPlanEvent (implements edu.snu.coral.common.eventhandler.CompilerEvent)
  • edu.snu.coral.runtime.master.eventhandler.UpdatePhysicalPlanEventHandler (implements edu.snu.coral.common.eventhandler.CompilerEventHandler<T>)
  • edu.snu.coral.driver.UserApplicationRunner (implements java.lang.Runnable)
  • edu.snu.coral.common.dag.Vertex (implements java.io.Serializable)
    • edu.snu.coral.common.ir.vertex.IRVertex
      • edu.snu.coral.common.ir.vertex.LoopVertex
      • edu.snu.coral.common.ir.vertex.MetricCollectionBarrierVertex<T>
      • edu.snu.coral.common.ir.vertex.OperatorVertex
      • edu.snu.coral.common.ir.vertex.SourceVertex<O>
        • edu.snu.coral.compiler.frontend.beam.source.BeamBoundedSourceVertex<O>
        • edu.snu.coral.compiler.optimizer.examples.EmptyComponents.EmptySourceVertex<T>
        • edu.snu.coral.common.ir.vertex.InitializedSourceVertex<T>
        • edu.snu.coral.compiler.frontend.spark.source.SparkBoundedSourceVertex<T>
    • edu.snu.coral.runtime.common.plan.physical.PhysicalStage
    • edu.snu.coral.runtime.common.plan.stage.Stage
    • edu.snu.coral.runtime.common.plan.physical.Task
      • edu.snu.coral.runtime.common.plan.physical.BoundedSourceTask<O>
      • edu.snu.coral.runtime.common.plan.physical.MetricCollectionBarrierTask
      • edu.snu.coral.runtime.common.plan.physical.OperatorTask
      • edu.snu.coral.runtime.common.plan.physical.UnboundedSourceTask
  • edu.snu.coral.compiler.frontend.beam.transform.WindowTransform<T> (implements edu.snu.coral.common.ir.vertex.transform.Transform<I,O>)

Interface Hierarchy

• java.lang.AutoCloseable
  • edu.snu.coral.runtime.executor.MetricMessageSender
• edu.snu.coral.compiler.backend.Backend<Plan>
• java.util.function.BiFunction<T,U,R>
  • edu.snu.coral.runtime.common.optimizer.pass.runtime.RuntimePass<T> (also extends java.io.Serializable)
• edu.snu.coral.runtime.executor.data.block.Block<K>
• edu.snu.coral.runtime.executor.data.stores.BlockStore
  • edu.snu.coral.runtime.executor.data.stores.FileStore
    • edu.snu.coral.runtime.executor.data.stores.RemoteFileStore
  • edu.snu.coral.runtime.executor.data.stores.RemoteFileStore
• edu.snu.coral.runtime.executor.data.blocktransfer.BlockStream
• edu.snu.coral.common.eventhandler.CompilerEvent
• org.apache.reef.wake.EventHandler<T>
  • edu.snu.coral.common.eventhandler.CommonEventHandler<T>
    • edu.snu.coral.common.eventhandler.CompilerEventHandler<T>
    • edu.snu.coral.common.eventhandler.RuntimeEventHandler<T>
  • edu.snu.coral.common.eventhandler.CompilerEventHandler<T>
  • edu.snu.coral.common.eventhandler.RuntimeEventHandler<T>
• java.util.function.Function<T,R>
  • edu.snu.coral.compiler.optimizer.pass.compiletime.CompileTimePass (also extends java.io.Serializable)
• org.apache.beam.sdk.transforms.display.HasDisplayData
  • edu.snu.coral.compiler.frontend.beam.CoralPipelineOptions
  • org.apache.beam.sdk.options.PipelineOptions
    • edu.snu.coral.compiler.frontend.beam.CoralPipelineOptions
• edu.snu.coral.runtime.common.message.MessageContext
• edu.snu.coral.runtime.common.message.MessageEnvironment
• edu.snu.coral.runtime.common.message.MessageListener<T>
• edu.snu.coral.runtime.common.message.MessageSender<T>
• edu.snu.coral.runtime.master.MetricMessageHandler
• edu.snu.coral.runtime.common.NettyChannelImplementationSelector
• edu.snu.coral.runtime.executor.data.Partition<T,K>
• edu.snu.coral.runtime.executor.data.partitioner.Partitioner
• edu.snu.coral.runtime.master.scheduler.PendingTaskGroupQueue
• edu.snu.coral.common.eventhandler.RuntimeEvent
• edu.snu.coral.runtime.master.scheduler.Scheduler
• edu.snu.coral.runtime.master.scheduler.SchedulingPolicy
• java.io.Serializable
  • edu.snu.coral.common.coder.Coder<T>
  • edu.snu.coral.compiler.optimizer.pass.compiletime.CompileTimePass (also extends java.util.function.Function<T,R>)
  • edu.snu.coral.common.KeyExtractor
  • edu.snu.coral.runtime.common.data.KeyRange<K>
  • edu.snu.coral.common.ir.OutputCollector<O>
  • edu.snu.coral.compiler.optimizer.policy.Policy
  • edu.snu.coral.common.ir.Readable<O>
  • edu.snu.coral.common.ir.ReadablesWrapper<O>
  • edu.snu.coral.runtime.common.optimizer.pass.runtime.RuntimePass<T> (also extends java.util.function.BiFunction<T,U,R>)
  • edu.snu.coral.common.ir.vertex.transform.Transform<I,O>
• edu.snu.coral.client.StateTranslator
• edu.snu.coral.common.ir.vertex.transform.Transform.Context

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • edu.snu.coral.common.ir.executionproperty.ExecutionProperty.Key
    • edu.snu.coral.common.ir.edge.executionproperty.DataStoreProperty.Value
    • edu.snu.coral.common.ir.edge.executionproperty.DataFlowModelProperty.Value
    • edu.snu.coral.common.ir.edge.executionproperty.CompressionProperty.Compression
    • edu.snu.coral.common.ir.edge.executionproperty.PartitionerProperty.Value
    • edu.snu.coral.common.ir.edge.executionproperty.DataCommunicationPatternProperty.Value
    • edu.snu.coral.common.ir.edge.executionproperty.MetricCollectionProperty.Value
    • edu.snu.coral.common.ir.edge.executionproperty.UsedDataHandlingProperty.Value
    • edu.snu.coral.common.ir.vertex.executionproperty.DynamicOptimizationProperty.Value
    • edu.snu.coral.common.dag.DAG.TraversalOrder
    • edu.snu.coral.runtime.common.state.JobState.State
    • edu.snu.coral.runtime.common.state.TaskGroupState.State
    • edu.snu.coral.runtime.common.state.TaskGroupState.RecoverableFailureCause
    • edu.snu.coral.runtime.common.state.BlockState.State
    • edu.snu.coral.runtime.common.state.StageState.State
    • edu.snu.coral.runtime.common.state.TaskState.State