typeSearchIndex = [{"p":"org.apache.nemo.runtime.common.exception","l":"AbsentBlockException"},{"p":"org.apache.nemo.runtime.executor.data.stores","l":"AbstractBlockStore"},{"p":"org.apache.nemo.compiler.frontend.beam.transform","l":"AbstractDoFnTransform"},{"p":"org.apache.nemo.driver","l":"NemoDriver.ActiveContextHandler"},{"p":"org.apache.nemo.common.ir.edge.executionproperty","l":"AdditionalOutputTagProperty"},{"p":"org.apache.nemo.compiler.optimizer.pass.compiletime.annotating","l":"AggressiveSpeculativeCloningPass"},{"l":"All Classes","url":"allclasses-index.html"},{"p":"org.apache.nemo.runtime.master.servlet","l":"AllMetricServlet"},{"p":"org.apache.nemo.driver","l":"NemoDriver.AllocatedEvaluatorHandler"},{"p":"org.apache.nemo.examples.beam","l":"AlternatingLeastSquare"},{"p":"org.apache.nemo.examples.beam","l":"AlternatingLeastSquareInefficient"},{"p":"org.apache.nemo.compiler.optimizer.pass.compiletime.annotating","l":"Annotates"},{"p":"org.apache.nemo.compiler.optimizer.pass.compiletime.annotating","l":"AnnotatingPass"},{"p":"org.apache.nemo.runtime.master.scheduler","l":"AntiAffinitySchedulingConstraint"},{"p":"org.apache.nemo.examples.beam","l":"MultinomialLogisticRegression.ApplyGradient"},{"p":"org.apache.nemo.common.test","l":"ArgBuilder"},{"p":"org.apache.nemo.common.ir.executionproperty","l":"AssociatedProperty"},{"p":"org.apache.nemo.examples.spark.sql","l":"JavaUserDefinedTypedAggregation.Average"},{"p":"org.apache.nemo.compiler.backend","l":"Backend"},{"p":"org.apache.nemo.conf","l":"JobConf.BandwidthJSONContents"},{"p":"org.apache.nemo.conf","l":"JobConf.BandwidthJSONPath"},{"p":"org.apache.nemo.compiler.optimizer.policy","l":"BasicPullPolicy"},{"p":"org.apache.nemo.compiler.optimizer.policy","l":"BasicPushPolicy"},{"p":"org.apache.nemo.runtime.master.scheduler","l":"BatchScheduler"},{"p":"org.apache.nemo.runtime.master.scheduler","l":"BatchSchedulerUtils"},{"p":"org.apache.nemo.compiler.frontend.beam.source","l":"BeamBoundedSourceVertex"},{"p":"org.apache.nemo.compiler.frontend.beam.coder","l":"BeamDecoderFactory"},{"p":"org.apache.nemo.compiler.frontend.beam.coder","l":"BeamEncoderFactory"},{"p":"org.apache.nemo.client.beam","l":"BeamStateTranslator"},{"p":"org.apache.nemo.compiler.frontend.beam.source","l":"BeamUnboundedSourceVertex"},{"p":"org.apache.nemo.examples.beam","l":"BeamWordCount"},{"p":"org.apache.nemo.runtime.executor.data.block","l":"Block"},{"p":"org.apache.nemo.common.exception","l":"BlockFetchException"},{"p":"org.apache.nemo.common.ir.edge.executionproperty","l":"BlockFetchFailureProperty"},{"p":"org.apache.nemo.runtime.executor.datatransfer","l":"BlockInputReader"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.BlockLocationInfoMsg"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.BlockLocationInfoMsgOrBuilder"},{"p":"org.apache.nemo.runtime.master","l":"BlockManagerMaster"},{"p":"org.apache.nemo.runtime.master","l":"BlockManagerMaster.BlockManagerMasterControlMessageReceiver"},{"p":"org.apache.nemo.runtime.executor.data","l":"BlockManagerWorker"},{"p":"org.apache.nemo.runtime.executor.datatransfer","l":"BlockOutputWriter"},{"p":"org.apache.nemo.runtime.master","l":"BlockManagerMaster.BlockRequestHandler"},{"p":"org.apache.nemo.runtime.common.state","l":"BlockState"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.BlockStateChangedMsg"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.BlockStateChangedMsgOrBuilder"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.BlockStateFromExecutor"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.BlockStore"},{"p":"org.apache.nemo.runtime.executor.data.stores","l":"BlockStore"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.BlockTransferContextDescriptor"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.BlockTransferContextDescriptorOrBuilder"},{"p":"org.apache.nemo.runtime.executor.data","l":"BlockTransferThrottler"},{"p":"org.apache.nemo.common.exception","l":"BlockWriteException"},{"p":"org.apache.nemo.common.ir","l":"BoundedIteratorReadable"},{"p":"org.apache.nemo.examples.beam","l":"Broadcast"},{"p":"org.apache.nemo.runtime.master","l":"BroadcastManagerMaster"},{"p":"org.apache.nemo.runtime.executor.data","l":"BroadcastManagerWorker"},{"p":"org.apache.nemo.common","l":"StateMachine.Builder"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.BlockLocationInfoMsg.Builder"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.BlockStateChangedMsg.Builder"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.BlockTransferContextDescriptor.Builder"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.ByteTransferContextSetupMessage.Builder"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.ClientToDriverMessage.Builder"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.ContainerFailedMsg.Builder"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.DataCollectMessage.Builder"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.DriverToClientMessage.Builder"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.ExecutorFailedMsg.Builder"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.InMasterBroadcastVariableMessage.Builder"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.LaunchDAGMessage.Builder"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.Message.Builder"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.Metric.Builder"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.MetricMsg.Builder"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.NotificationMessage.Builder"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.PipeInitMessage.Builder"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.PipeLocationInfoMessage.Builder"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.PipeTransferContextDescriptor.Builder"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.RequestBlockLocationMsg.Builder"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.RequestBroadcastVariableMessage.Builder"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.RequestPipeLocationMessage.Builder"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.RunTimePassMessageEntry.Builder"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.RunTimePassMessageMsg.Builder"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.ScheduleTaskMsg.Builder"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.TaskStateChangedMsg.Builder"},{"p":"org.apache.nemo.runtime.common.comm","l":"GrpcMessageService.Void.Builder"},{"p":"org.apache.nemo.common","l":"ByteBufferInputStream"},{"p":"org.apache.nemo.runtime.executor.transfer","l":"ByteInputContext"},{"p":"org.apache.nemo.runtime.executor.transfer","l":"ByteOutputContext"},{"p":"org.apache.nemo.runtime.executor.transfer","l":"ByteOutputContext.ByteOutputStream"},{"p":"org.apache.nemo.common.coder","l":"BytesDecoderFactory"},{"p":"org.apache.nemo.common.coder","l":"BytesEncoderFactory"},{"p":"org.apache.nemo.runtime.executor.transfer","l":"ByteTransfer"},{"p":"org.apache.nemo.runtime.executor.transfer","l":"ByteTransferContext"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.ByteTransferContextSetupMessage"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.ByteTransferContextSetupMessageOrBuilder"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.ByteTransferDataDirection"},{"p":"org.apache.nemo.common.ir.vertex","l":"CachedSourceVertex"},{"p":"org.apache.nemo.common.ir.edge.executionproperty","l":"CacheIDProperty"},{"p":"org.apache.nemo.examples.beam","l":"MultinomialLogisticRegression.CalculateGradient"},{"p":"org.apache.nemo.examples.beam","l":"AlternatingLeastSquare.CalculateNextMatrix"},{"p":"org.apache.nemo.common.ir","l":"IRDAGChecker.CheckerResult"},{"p":"org.apache.nemo.conf","l":"JobConf.ChunkSizeKb"},{"p":"org.apache.nemo.client","l":"ClientEndpoint"},{"p":"org.apache.nemo.runtime.common.message","l":"ClientRPC"},{"p":"org.apache.nemo.conf","l":"JobConf.ClientSideRPCServerHost"},{"p":"org.apache.nemo.conf","l":"JobConf.ClientSideRPCServerPort"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.ClientToDriverMessage"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.ClientToDriverMessageOrBuilder"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.ClientToDriverMessageType"},{"p":"org.apache.nemo.client","l":"ClientUtils"},{"p":"org.apache.nemo.common","l":"Cloneable"},{"p":"org.apache.nemo.common.ir.vertex.executionproperty","l":"ClonedSchedulingProperty.CloneConf"},{"p":"org.apache.nemo.common.ir.vertex.executionproperty","l":"ClonedSchedulingProperty"},{"p":"org.apache.nemo.runtime.executor.transfer","l":"ClosableBlockingQueue"},{"p":"org.apache.nemo.compiler.frontend.beam.transform","l":"CombineFnFinalTransform"},{"p":"org.apache.nemo.compiler.frontend.beam.transform","l":"CombineFnPartialTransform"},{"p":"org.apache.nemo.examples.beam","l":"MultinomialLogisticRegression.CombineFunction"},{"p":"org.apache.nemo.examples.beam","l":"MultinomialLogisticRegression.CombineFunctionForIterable"},{"p":"org.apache.nemo.common.eventhandler","l":"CommonEventHandler"},{"p":"org.apache.nemo.compiler.optimizer.pass.compiletime.reshaping","l":"CommonSubexpressionEliminationPass"},{"p":"org.apache.nemo.common.ir.edge.executionproperty","l":"CommunicationPatternProperty"},{"p":"org.apache.nemo.common.eventhandler","l":"CompilerEvent"},{"p":"org.apache.nemo.common.eventhandler","l":"CompilerEventHandler"},{"p":"org.apache.nemo.compiler","l":"CompilerTestUtil"},{"p":"org.apache.nemo.common.exception","l":"CompileTimeOptimizationException"},{"p":"org.apache.nemo.compiler.optimizer.pass.compiletime","l":"CompileTimePass"},{"p":"org.apache.nemo.compiler.optimizer.pass.compiletime.composite","l":"CompositePass"},{"p":"org.apache.nemo.compiler.optimizer.pass.compiletime.annotating","l":"CompressionPass"},{"p":"org.apache.nemo.common.ir.edge.executionproperty","l":"CompressionProperty"},{"p":"org.apache.nemo.runtime.executor.data.streamchainer","l":"CompressionStreamChainer"},{"p":"org.apache.nemo.compiler.optimizer.policy","l":"ConditionalLargeShufflePolicy"},{"p":"org.apache.nemo.common.exception","l":"ContainerException"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.ContainerFailedMsg"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.ContainerFailedMsgOrBuilder"},{"p":"org.apache.nemo.runtime.master.resource","l":"ContainerManager"},{"p":"org.apache.nemo.runtime.master.scheduler","l":"ContainerTypeAwareSchedulingConstraint"},{"p":"org.apache.nemo.common.ir.vertex.transform","l":"Transform.Context"},{"p":"org.apache.nemo.driver","l":"NemoContext.ContextStartHandler"},{"p":"org.apache.nemo.driver","l":"NemoContext.ContextStopHandler"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage"},{"p":"org.apache.nemo.examples.beam","l":"BeamWordCount.CountWords"},{"p":"org.apache.nemo.examples.beam","l":"AlternatingLeastSquare.CreateInitialMatrix"},{"p":"org.apache.nemo.compiler.frontend.beam.transform","l":"CreateViewTransform"},{"p":"org.apache.nemo.common.dag","l":"DAG"},{"p":"org.apache.nemo.common.dag","l":"DAGBuilder"},{"p":"org.apache.nemo.conf","l":"JobConf.DAGDirectory"},{"p":"org.apache.nemo.common.dag","l":"DAGInterface"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.DataCollectMessage"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.DataCollectMessageOrBuilder"},{"p":"org.apache.nemo.runtime.executor.datatransfer","l":"DataFetcherOutputCollector"},{"p":"org.apache.nemo.common.ir.edge.executionproperty","l":"DataFlowProperty"},{"p":"org.apache.nemo.common.ir.edge.executionproperty","l":"DataPersistenceProperty"},{"p":"org.apache.nemo.conf","l":"DataPlaneConf"},{"p":"org.apache.nemo.compiler.optimizer.policy","l":"DataSkewPolicy"},{"p":"org.apache.nemo.common.exception","l":"DataSourceException"},{"p":"org.apache.nemo.common.ir.edge.executionproperty","l":"DataStoreProperty"},{"p":"org.apache.nemo.runtime.common.metric","l":"DataTransferEvent"},{"p":"org.apache.nemo.runtime.executor.data","l":"DataUtil"},{"p":"org.apache.nemo.conf","l":"JobConf.DBAddress"},{"p":"org.apache.nemo.conf","l":"JobConf.DBEnabled"},{"p":"org.apache.nemo.conf","l":"JobConf.DBId"},{"p":"org.apache.nemo.conf","l":"JobConf.DBPasswd"},{"p":"org.apache.nemo.common.coder","l":"DecoderFactory.Decoder"},{"p":"org.apache.nemo.common.coder","l":"DecoderFactory"},{"p":"org.apache.nemo.common.ir.edge.executionproperty","l":"DecoderProperty"},{"p":"org.apache.nemo.runtime.executor.data.streamchainer","l":"DecodeStreamChainer"},{"p":"org.apache.nemo.common.ir.edge.executionproperty","l":"DecompressionProperty"},{"p":"org.apache.nemo.runtime.executor.data.streamchainer","l":"DecompressionStreamChainer"},{"p":"org.apache.nemo.common.partitioner","l":"DedicatedKeyPerElement"},{"p":"org.apache.nemo.common.partitioner","l":"DedicatedKeyPerElementPartitioner"},{"p":"org.apache.nemo.compiler.optimizer.pass.compiletime.composite","l":"DefaultCompositePass"},{"p":"org.apache.nemo.compiler.optimizer.pass.compiletime.annotating","l":"DefaultDataPersistencePass"},{"p":"org.apache.nemo.compiler.optimizer.pass.compiletime.annotating","l":"DefaultDataStorePass"},{"p":"org.apache.nemo.compiler.optimizer.pass.compiletime.annotating","l":"DefaultEdgeDecoderPass"},{"p":"org.apache.nemo.compiler.optimizer.pass.compiletime.annotating","l":"DefaultEdgeEncoderPass"},{"p":"org.apache.nemo.runtime.master.resource","l":"DefaultExecutorRepresenter"},{"p":"org.apache.nemo.compiler.frontend.beam.transform","l":"DefaultOutputManager"},{"p":"org.apache.nemo.compiler.optimizer.pass.compiletime.annotating","l":"DefaultParallelismPass"},{"p":"org.apache.nemo.compiler.optimizer.policy","l":"DefaultPolicy"},{"p":"org.apache.nemo.compiler.optimizer.policy","l":"DefaultPolicyWithSeparatePass"},{"p":"org.apache.nemo.compiler.optimizer.pass.compiletime.annotating","l":"DefaultScheduleGroupPass"},{"p":"org.apache.nemo.conf","l":"JobConf.DeployMode"},{"p":"org.apache.nemo.runtime.executor.data","l":"DirectByteBufferOutputStream"},{"p":"org.apache.nemo.compiler.optimizer.pass.compiletime.annotating","l":"DisaggregationEdgeDataStorePass"},{"p":"org.apache.nemo.compiler.optimizer.policy","l":"DisaggregationPolicy"},{"p":"org.apache.nemo.compiler.frontend.beam.transform","l":"DoFnTransform"},{"p":"org.apache.nemo.client","l":"DriverEndpoint"},{"p":"org.apache.nemo.conf","l":"JobConf.DriverMemMb"},{"p":"org.apache.nemo.client","l":"DriverRPCServer"},{"p":"org.apache.nemo.driver","l":"NemoDriver.DriverStopHandler"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.DriverToClientMessage"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.DriverToClientMessageOrBuilder"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.DriverToClientMessageType"},{"p":"org.apache.nemo.common.coder","l":"DecoderFactory.DummyDecoderFactory"},{"p":"org.apache.nemo.common.coder","l":"EncoderFactory.DummyEncoderFactory"},{"p":"org.apache.nemo.common.ir.edge.executionproperty","l":"DuplicateEdgeGroupProperty"},{"p":"org.apache.nemo.common.ir.edge.executionproperty","l":"DuplicateEdgeGroupPropertyValue"},{"p":"org.apache.nemo.compiler.optimizer.pass.compiletime.annotating","l":"DuplicateEdgeGroupSizePass"},{"p":"org.apache.nemo.common.exception","l":"DynamicOptimizationException"},{"p":"org.apache.nemo.compiler.optimizer.policy","l":"DynamicTaskSizingPolicy"},{"p":"org.apache.nemo.compiler.optimizer.pass.runtime","l":"DynamicTaskSizingRuntimePass"},{"p":"org.apache.nemo.examples.beam","l":"EDGARAvgDocSize"},{"p":"org.apache.nemo.examples.beam","l":"EDGARDocumentSuccessRate"},{"p":"org.apache.nemo.examples.beam","l":"EDGARRequestsByCIK"},{"p":"org.apache.nemo.examples.beam","l":"EDGARTop10BadRefererDocs"},{"p":"org.apache.nemo.examples.beam","l":"EDGARTop10Documents"},{"p":"org.apache.nemo.common.dag","l":"Edge"},{"p":"org.apache.nemo.common.ir.executionproperty","l":"EdgeExecutionProperty"},{"p":"org.apache.nemo.examples.spark.sql","l":"JavaUserDefinedTypedAggregation.Employee"},{"p":"org.apache.nemo.common.test","l":"EmptyComponents"},{"p":"org.apache.nemo.common.test","l":"EmptyComponents.EmptySourceVertex"},{"p":"org.apache.nemo.common.test","l":"EmptyComponents.EmptyTransform"},{"p":"org.apache.nemo.common.ir.vertex.executionproperty","l":"EnableDynamicTaskSizingProperty"},{"p":"org.apache.nemo.common.coder","l":"EncoderFactory.Encoder"},{"p":"org.apache.nemo.common.coder","l":"EncoderFactory"},{"p":"org.apache.nemo.common.ir.edge.executionproperty","l":"EncoderProperty"},{"p":"org.apache.nemo.runtime.executor.data.streamchainer","l":"EncodeStreamChainer"},{"p":"org.apache.nemo.conf","l":"JobConf.EnvironmentType"},{"p":"org.apache.nemo.runtime.common.metric","l":"Event"},{"p":"org.apache.nemo.common.test","l":"ExampleTestArgs"},{"p":"org.apache.nemo.common.test","l":"ExampleTestUtil"},{"p":"org.apache.nemo.common.ir.executionproperty","l":"ExecutionProperty"},{"p":"org.apache.nemo.common.ir.executionproperty","l":"ExecutionPropertyMap"},{"p":"org.apache.nemo.runtime.executor","l":"Executor"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.ExecutorFailedMsg"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.ExecutorFailedMsgOrBuilder"},{"p":"org.apache.nemo.conf","l":"JobConf.ExecutorId"},{"p":"org.apache.nemo.conf","l":"JobConf.ExecutorJSONContents"},{"p":"org.apache.nemo.conf","l":"JobConf.ExecutorJSONPath"},{"p":"org.apache.nemo.conf","l":"JobConf.ExecutorMemoryMb"},{"p":"org.apache.nemo.conf","l":"JobConf.ExecutorPoisonSec"},{"p":"org.apache.nemo.runtime.master.scheduler","l":"ExecutorRegistry"},{"p":"org.apache.nemo.runtime.master.resource","l":"ExecutorRepresenter"},{"p":"org.apache.nemo.conf","l":"JobConf.ExecutorType"},{"p":"org.apache.nemo.driver","l":"NemoDriver.FailedContextHandler"},{"p":"org.apache.nemo.driver","l":"NemoDriver.FailedEvaluatorHandler"},{"p":"org.apache.nemo.runtime.common.message","l":"FailedMessageSender"},{"p":"org.apache.nemo.runtime.executor.data","l":"FileArea"},{"p":"org.apache.nemo.runtime.executor.data.block","l":"FileBlock"},{"p":"org.apache.nemo.conf","l":"JobConf.FileDirectory"},{"p":"org.apache.nemo.runtime.executor.data.metadata","l":"FileMetadata"},{"p":"org.apache.nemo.compiler.frontend.beam.transform","l":"FinalCombineFn"},{"p":"org.apache.nemo.common.punctuation","l":"Finishmark"},{"p":"org.apache.nemo.compiler.frontend.beam.transform","l":"FlattenTransform"},{"p":"org.apache.nemo.examples.beam","l":"FloatArrayCoder"},{"p":"org.apache.nemo.examples.beam","l":"BeamWordCount.FormatAsTextFn"},{"p":"org.apache.nemo.runtime.master.scheduler","l":"FreeSlotSchedulingConstraint"},{"p":"org.apache.nemo.compiler.frontend.beam.transform","l":"GBKTransform.GBKOutputCollector"},{"p":"org.apache.nemo.compiler.frontend.beam.transform","l":"GBKTransform"},{"p":"org.apache.nemo.common.ir","l":"IRDAGChecker.GlobalDAGChecker"},{"p":"org.apache.nemo.runtime.executor.data.stores","l":"GlusterFileStore"},{"p":"org.apache.nemo.conf","l":"JobConf.GlusterVolumeDirectory"},{"p":"org.apache.nemo.compiler.frontend.beam.transform","l":"GroupByKeyTransform"},{"p":"org.apache.nemo.runtime.common.message.grpc","l":"GrpcMessageEnvironment"},{"p":"org.apache.nemo.runtime.common.comm","l":"GrpcMessageService"},{"p":"org.apache.nemo.common.partitioner","l":"HashPartitioner"},{"p":"org.apache.nemo.common","l":"HashRange"},{"p":"org.apache.nemo.common.ir","l":"IdManager"},{"p":"org.apache.nemo.common.ir.vertex.executionproperty","l":"IgnoreSchedulingTempDataReceiverProperty"},{"p":"org.apache.nemo.common.exception","l":"IllegalEdgeOperationException"},{"p":"org.apache.nemo.common.exception","l":"IllegalMessageException"},{"p":"org.apache.nemo.common.exception","l":"IllegalStateTransitionException"},{"p":"org.apache.nemo.common.exception","l":"IllegalVertexOperationException"},{"p":"org.apache.nemo.common.ir.vertex.utility.runtimepass","l":"MessageAggregatorVertex.InitialStateSupplier"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.InMasterBroadcastVariableMessage"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.InMasterBroadcastVariableMessageOrBuilder"},{"p":"org.apache.nemo.compiler.frontend.beam","l":"InMemorySideInputReader"},{"p":"org.apache.nemo.common.ir.vertex","l":"InMemorySourceVertex"},{"p":"org.apache.nemo.compiler.frontend.beam.transform","l":"InMemoryStateInternalsFactory"},{"p":"org.apache.nemo.compiler.frontend.beam.transform","l":"InMemoryTimerInternalsFactory"},{"p":"org.apache.nemo.runtime.executor.datatransfer","l":"InputReader"},{"p":"org.apache.nemo.runtime.executor.data","l":"DataUtil.InputStreamIterator"},{"p":"org.apache.nemo.runtime.executor.datatransfer","l":"InputWatermarkManager"},{"p":"org.apache.nemo.common.partitioner","l":"IntactPartitioner"},{"p":"org.apache.nemo.examples.beam","l":"IntArrayCoder"},{"p":"org.apache.nemo.common.coder","l":"IntDecoderFactory"},{"p":"org.apache.nemo.common.coder","l":"IntEncoderFactory"},{"p":"org.apache.nemo.runtime.executor.datatransfer","l":"IntermediateDataIOFactory"},{"p":"org.apache.nemo.common.exception","l":"InvalidParameterException"},{"p":"org.apache.nemo.common.exception","l":"InvalidUserMainException"},{"p":"org.apache.nemo.conf","l":"JobConf.IORequestHandleThreadsTotal"},{"p":"org.apache.nemo.common.ir","l":"IRDAG"},{"p":"org.apache.nemo.common.ir","l":"IRDAGChecker"},{"p":"org.apache.nemo.common.ir.edge","l":"IREdge"},{"p":"org.apache.nemo.common.ir.vertex","l":"IRVertex"},{"p":"org.apache.nemo.runtime.executor.data","l":"DataUtil.IteratorWithNumBytes"},{"p":"org.apache.nemo.examples.spark","l":"JavaMapReduce"},{"p":"org.apache.nemo.examples.spark","l":"JavaSparkPi"},{"p":"org.apache.nemo.examples.spark.sql","l":"JavaSparkSQLExample"},{"p":"org.apache.nemo.examples.spark.sql","l":"JavaUserDefinedTypedAggregation"},{"p":"org.apache.nemo.examples.spark.sql","l":"JavaUserDefinedUntypedAggregation"},{"p":"org.apache.nemo.examples.spark","l":"JavaWordAndLineCount"},{"p":"org.apache.nemo.examples.spark","l":"JavaWordCount"},{"p":"org.apache.nemo.conf","l":"JobConf"},{"p":"org.apache.nemo.conf","l":"JobConf.JobId"},{"p":"org.apache.nemo.client","l":"JobLauncher"},{"p":"org.apache.nemo.client","l":"NemoClient.JobMessageHandler"},{"p":"org.apache.nemo.runtime.common.metric","l":"JobMetric"},{"p":"org.apache.nemo.runtime.master.servlet","l":"JobMetricServlet"},{"p":"org.apache.nemo.common.exception","l":"JsonParseException"},{"p":"org.apache.nemo.conf","l":"JobConf.JVMHeapSlack"},{"p":"org.apache.nemo.common.ir.edge.executionproperty","l":"KeyDecoderProperty"},{"p":"org.apache.nemo.common.ir.edge.executionproperty","l":"KeyEncoderProperty"},{"p":"org.apache.nemo.common","l":"KeyExtractor"},{"p":"org.apache.nemo.common.ir.edge.executionproperty","l":"KeyExtractorProperty"},{"p":"org.apache.nemo.common","l":"KeyRange"},{"p":"org.apache.nemo.compiler.optimizer.pass.compiletime.annotating","l":"LambdaPass"},{"p":"org.apache.nemo.compiler.optimizer.policy","l":"LambdaPolicy"},{"p":"org.apache.nemo.compiler.optimizer.pass.compiletime.annotating","l":"LargeShuffleAnnotatingPass"},{"p":"org.apache.nemo.compiler.optimizer.pass.compiletime.composite","l":"LargeShuffleCompositePass"},{"p":"org.apache.nemo.compiler.optimizer.policy","l":"LargeShufflePolicy"},{"p":"org.apache.nemo.compiler.optimizer.pass.compiletime.reshaping","l":"LargeShuffleReshapingPass"},{"p":"org.apache.nemo.common.punctuation","l":"LatencyMark"},{"p":"org.apache.nemo.common.ir.vertex.transform","l":"LatencymarkEmitTransform"},{"p":"org.apache.nemo.conf","l":"JobConf.LatencyMarkPeriod"},{"p":"org.apache.nemo.runtime.common.metric","l":"LatencyMetric"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.LaunchDAGMessage"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.LaunchDAGMessageOrBuilder"},{"p":"org.apache.nemo.runtime.executor.data","l":"LimitedInputStream"},{"p":"org.apache.nemo.runtime.executor.data.stores","l":"LocalBlockStore"},{"p":"org.apache.nemo.runtime.executor.data.metadata","l":"LocalFileMetadata"},{"p":"org.apache.nemo.runtime.executor.data.stores","l":"LocalFileStore"},{"p":"org.apache.nemo.runtime.executor.transfer","l":"LocalInputContext"},{"p":"org.apache.nemo.runtime.master.scheduler","l":"LocalitySchedulingConstraint"},{"p":"org.apache.nemo.runtime.common.message.local","l":"LocalMessageDispatcher"},{"p":"org.apache.nemo.runtime.common.message.local","l":"LocalMessageEnvironment"},{"p":"org.apache.nemo.runtime.common.message.local","l":"LocalMessageSender"},{"p":"org.apache.nemo.runtime.executor.transfer","l":"LocalOutputContext"},{"p":"org.apache.nemo.runtime.executor.transfer","l":"LocalTransferContext"},{"p":"org.apache.nemo.common.coder","l":"LongDecoderFactory"},{"p":"org.apache.nemo.common.coder","l":"LongEncoderFactory"},{"p":"org.apache.nemo.compiler.frontend.beam.transform","l":"LoopCompositeTransform"},{"p":"org.apache.nemo.compiler.optimizer.pass.compiletime.reshaping","l":"LoopExtractionPass"},{"p":"org.apache.nemo.compiler.optimizer.pass.compiletime.reshaping","l":"LoopOptimizations.LoopFusionPass"},{"p":"org.apache.nemo.compiler.optimizer.pass.compiletime.reshaping","l":"LoopOptimizations.LoopInvariantCodeMotionPass"},{"p":"org.apache.nemo.compiler.optimizer.pass.compiletime.composite","l":"LoopOptimizationCompositePass"},{"p":"org.apache.nemo.compiler.optimizer.pass.compiletime.reshaping","l":"LoopOptimizations"},{"p":"org.apache.nemo.compiler.optimizer.pass.compiletime.reshaping","l":"LoopUnrollingPass"},{"p":"org.apache.nemo.common.ir.vertex","l":"LoopVertex"},{"p":"org.apache.nemo.compiler.optimizer.examples","l":"MapReduceDisaggregationOptimization"},{"p":"org.apache.nemo.runtime.master","l":"RuntimeMaster.MasterControlMessageReceiver"},{"p":"org.apache.nemo.conf","l":"JobConf.MaxNumDownloadsForARuntimeEdge"},{"p":"org.apache.nemo.conf","l":"JobConf.MaxOffheapRatio"},{"p":"org.apache.nemo.conf","l":"JobConf.MaxTaskAttempt"},{"p":"org.apache.nemo.runtime.executor.data","l":"MemoryAllocationException"},{"p":"org.apache.nemo.runtime.executor.data","l":"MemoryChunk"},{"p":"org.apache.nemo.runtime.executor.data","l":"MemoryPoolAssigner"},{"p":"org.apache.nemo.runtime.executor.data.stores","l":"MemoryStore"},{"p":"org.apache.nemo.compiler.optimizer.pass.runtime","l":"Message"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.Message"},{"p":"org.apache.nemo.common.ir.vertex.utility.runtimepass","l":"MessageAggregatorVertex.MessageAggregatorFunction"},{"p":"org.apache.nemo.common.ir.vertex.transform","l":"MessageAggregatorTransform"},{"p":"org.apache.nemo.common.ir.vertex.utility.runtimepass","l":"MessageAggregatorVertex"},{"p":"org.apache.nemo.runtime.common.message","l":"MessageContext"},{"p":"org.apache.nemo.runtime.common.message","l":"MessageEnvironment"},{"p":"org.apache.nemo.common.ir.vertex.utility.runtimepass","l":"MessageGeneratorVertex.MessageGeneratorFunction"},{"p":"org.apache.nemo.common.ir.vertex.transform","l":"MessageGeneratorTransform"},{"p":"org.apache.nemo.common.ir.vertex.utility.runtimepass","l":"MessageGeneratorVertex"},{"p":"org.apache.nemo.common.ir.edge.executionproperty","l":"MessageIdEdgeProperty"},{"p":"org.apache.nemo.common.ir.vertex.executionproperty","l":"MessageIdVertexProperty"},{"p":"org.apache.nemo.runtime.common.message","l":"MessageListener"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.MessageOrBuilder"},{"p":"org.apache.nemo.runtime.common.message","l":"MessageParameters"},{"p":"org.apache.nemo.runtime.common.message","l":"MessageSender"},{"p":"org.apache.nemo.runtime.common.comm","l":"MessageServiceGrpc.MessageServiceBlockingStub"},{"p":"org.apache.nemo.runtime.common.comm","l":"MessageServiceGrpc.MessageServiceFutureStub"},{"p":"org.apache.nemo.runtime.common.comm","l":"MessageServiceGrpc"},{"p":"org.apache.nemo.runtime.common.comm","l":"MessageServiceGrpc.MessageServiceImplBase"},{"p":"org.apache.nemo.runtime.common.comm","l":"MessageServiceGrpc.MessageServiceStub"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.MessageType"},{"p":"org.apache.nemo.runtime.common.message","l":"MessageUtils"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.Metric"},{"p":"org.apache.nemo.runtime.common.metric","l":"Metric"},{"p":"org.apache.nemo.runtime.master.metric","l":"MetricBroadcaster"},{"p":"org.apache.nemo.common.exception","l":"MetricException"},{"p":"org.apache.nemo.runtime.master.metric","l":"MetricManagerMaster"},{"p":"org.apache.nemo.runtime.executor","l":"MetricManagerWorker"},{"p":"org.apache.nemo.runtime.master.metric","l":"MetricMessageHandler"},{"p":"org.apache.nemo.runtime.executor","l":"MetricMessageSender"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.MetricMsg"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.MetricMsgOrBuilder"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.MetricOrBuilder"},{"p":"org.apache.nemo.runtime.master.metric","l":"MetricStore"},{"p":"org.apache.nemo.runtime.common.metric","l":"MetricUtils"},{"p":"org.apache.nemo.examples.beam","l":"MinimalWordCount"},{"p":"org.apache.nemo.runtime.master.scheduler","l":"MinOccupancyFirstSchedulingPolicy"},{"p":"org.apache.nemo.runtime.executor.datatransfer","l":"MultiInputWatermarkManager"},{"p":"org.apache.nemo.examples.beam","l":"MultinomialLogisticRegression"},{"p":"org.apache.nemo.compiler.frontend.beam.transform","l":"CreateViewTransform.MultiView"},{"p":"org.apache.nemo.examples.spark.sql","l":"JavaUserDefinedTypedAggregation.MyAverage"},{"p":"org.apache.nemo.examples.spark.sql","l":"JavaUserDefinedUntypedAggregation.MyAverage"},{"p":"org.apache.nemo.runtime.common","l":"NativeChannelImplementationSelector"},{"p":"org.apache.nemo.runtime.common.message.ncs","l":"NcsMessageEnvironment"},{"p":"org.apache.nemo.compiler.backend.nemo","l":"NemoBackend"},{"p":"org.apache.nemo.client","l":"NemoClient"},{"p":"org.apache.nemo.driver","l":"NemoContext"},{"p":"org.apache.nemo.driver","l":"NemoDriver"},{"p":"org.apache.nemo.runtime.executor.datatransfer","l":"NemoEventDecoderFactory"},{"p":"org.apache.nemo.runtime.executor.datatransfer","l":"NemoEventEncoderFactory"},{"p":"org.apache.nemo.compiler.optimizer","l":"NemoOptimizer"},{"p":"org.apache.nemo.compiler.frontend.beam","l":"NemoPipelineOptions"},{"p":"org.apache.nemo.client.beam","l":"NemoPipelineResult"},{"p":"org.apache.nemo.compiler.backend.nemo","l":"NemoPlanRewriter"},{"p":"org.apache.nemo.client.beam","l":"NemoRunner"},{"p":"org.apache.nemo.client.beam","l":"NemoRunnerRegistrar"},{"p":"org.apache.nemo.runtime.common","l":"NettyChannelImplementationSelector"},{"p":"org.apache.nemo.examples.beam","l":"NetworkTraceAnalysis"},{"p":"org.apache.nemo.runtime.executor.datatransfer","l":"NextIntraTaskOperatorInfo"},{"p":"org.apache.nemo.runtime.common","l":"NioChannelImplementationSelector"},{"p":"org.apache.nemo.common.exception","l":"NodeConnectionException"},{"p":"org.apache.nemo.runtime.master.scheduler","l":"NodeShareSchedulingConstraint"},{"p":"org.apache.nemo.runtime.executor.data.block","l":"NonSerializedMemoryBlock"},{"p":"org.apache.nemo.runtime.executor.data.partition","l":"NonSerializedPartition"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.NotificationMessage"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.NotificationMessageOrBuilder"},{"p":"org.apache.nemo.common.ir.vertex.transform","l":"NoWatermarkEmitTransform"},{"p":"org.apache.nemo.runtime.executor.data","l":"DataUtil.IteratorWithNumBytes.NumBytesNotSupportedException"},{"p":"org.apache.nemo.examples.beam","l":"ObjectCoderForString"},{"p":"org.apache.nemo.common.ir.vertex","l":"OperatorVertex"},{"p":"org.apache.nemo.runtime.executor.datatransfer","l":"OperatorVertexOutputCollector"},{"p":"org.apache.nemo.runtime.executor.datatransfer","l":"OperatorWatermarkCollector"},{"p":"org.apache.nemo.conf","l":"JobConf.OptimizationPolicy"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.OptimizationType"},{"p":"org.apache.nemo.compiler.optimizer","l":"Optimizer"},{"p":"org.apache.nemo.compiler.optimizer","l":"OptimizerUtils"},{"p":"org.apache.nemo.client.beam","l":"NemoRunnerRegistrar.Options"},{"p":"org.apache.nemo.common.ir","l":"OutputCollector"},{"p":"org.apache.nemo.runtime.executor.transfer","l":"OutputContext"},{"p":"org.apache.nemo.common.exception","l":"OutputMismatchException"},{"p":"org.apache.nemo.runtime.executor.datatransfer","l":"OutputWriter"},{"p":"org.apache.nemo.common","l":"Pair"},{"p":"org.apache.nemo.common.coder","l":"PairDecoderFactory"},{"p":"org.apache.nemo.common.coder","l":"PairEncoderFactory"},{"p":"org.apache.nemo.common","l":"PairKeyExtractor"},{"p":"org.apache.nemo.common.ir.vertex.executionproperty","l":"ParallelismProperty"},{"p":"org.apache.nemo.compiler.backend.nemo.prophet","l":"ParallelismProphet"},{"p":"org.apache.nemo.examples.beam","l":"AlternatingLeastSquare.ParseLine"},{"p":"org.apache.nemo.compiler.frontend.beam.transform","l":"PartialCombineFn"},{"p":"org.apache.nemo.runtime.executor.data.partition","l":"Partition"},{"p":"org.apache.nemo.common.partitioner","l":"Partitioner"},{"p":"org.apache.nemo.common.ir.edge.executionproperty","l":"PartitionerProperty"},{"p":"org.apache.nemo.runtime.executor.data.metadata","l":"PartitionMetadata"},{"p":"org.apache.nemo.common.ir.edge.executionproperty","l":"PartitionSetProperty"},{"p":"org.apache.nemo.conf","l":"JobConf.PartitionTransportClientNumThreads"},{"p":"org.apache.nemo.conf","l":"JobConf.PartitionTransportServerBacklog"},{"p":"org.apache.nemo.conf","l":"JobConf.PartitionTransportServerNumListeningThreads"},{"p":"org.apache.nemo.conf","l":"JobConf.PartitionTransportServerNumWorkingThreads"},{"p":"org.apache.nemo.conf","l":"JobConf.PartitionTransportServerPort"},{"p":"org.apache.nemo.examples.beam","l":"PartitionWordsByLength"},{"p":"org.apache.nemo.common.pass","l":"Pass"},{"p":"org.apache.nemo.runtime.master.scheduler","l":"PendingTaskCollectionPointer"},{"p":"org.apache.nemo.examples.beam","l":"PerKeyMedian"},{"p":"org.apache.nemo.examples.beam","l":"PerPercentileAverage"},{"p":"org.apache.nemo.runtime.common.message","l":"PersistentConnectionToMasterMap"},{"p":"org.apache.nemo.examples.spark.sql","l":"JavaSparkSQLExample.Person"},{"p":"org.apache.nemo.examples.beam","l":"WriteOneFilePerWindow.PerWindowFiles"},{"p":"org.apache.nemo.runtime.common.plan","l":"PhysicalPlan"},{"p":"org.apache.nemo.common.exception","l":"PhysicalPlanGenerationException"},{"p":"org.apache.nemo.runtime.common.plan","l":"PhysicalPlanGenerator"},{"p":"org.apache.nemo.runtime.executor.data","l":"PipeContainer"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.PipeInitMessage"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.PipeInitMessageOrBuilder"},{"p":"org.apache.nemo.runtime.executor.datatransfer","l":"PipeInputReader"},{"p":"org.apache.nemo.compiler.frontend.beam","l":"PipelineVisitor"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.PipeLocationInfoMessage"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.PipeLocationInfoMessageOrBuilder"},{"p":"org.apache.nemo.runtime.master","l":"PipeManagerMaster"},{"p":"org.apache.nemo.runtime.master","l":"PipeManagerMaster.PipeManagerMasterControlMessageReceiver"},{"p":"org.apache.nemo.runtime.executor.data","l":"PipeManagerWorker"},{"p":"org.apache.nemo.runtime.executor.datatransfer","l":"PipeOutputWriter"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.PipeTransferContextDescriptor"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.PipeTransferContextDescriptorOrBuilder"},{"p":"org.apache.nemo.compiler.optimizer.pass.compiletime.annotating","l":"PipeTransferForAllEdgesPass"},{"p":"org.apache.nemo.runtime.master","l":"PlanAppender"},{"p":"org.apache.nemo.runtime.common.exception","l":"PlanAppenderException"},{"p":"org.apache.nemo.runtime.common.plan","l":"PlanRewriter"},{"p":"org.apache.nemo.runtime.common.state","l":"PlanState"},{"p":"org.apache.nemo.runtime.master","l":"PlanStateManager"},{"p":"org.apache.nemo.runtime.common.plan","l":"TestPlanGenerator.PlanType"},{"p":"org.apache.nemo.compiler.optimizer.policy","l":"Policy"},{"p":"org.apache.nemo.compiler.optimizer.policy","l":"PolicyBuilder"},{"p":"org.apache.nemo.compiler.optimizer.policy","l":"PolicyImpl"},{"p":"org.apache.nemo.compiler.backend.nemo.prophet","l":"Prophet"},{"p":"org.apache.nemo.common.eventhandler","l":"PubSubEventHandlerWrapper"},{"p":"org.apache.nemo.compiler.frontend.beam.transform","l":"PushBackDoFnTransform"},{"p":"org.apache.nemo.common.ir","l":"Readable"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.RecoverableFailureCause"},{"p":"org.apache.nemo.runtime.common.state","l":"TaskState.RecoverableTaskFailureCause"},{"p":"org.apache.nemo.compiler.optimizer.policy","l":"DefaultPolicyWithSeparatePass.RefactoredPass"},{"p":"org.apache.nemo.common.ir.vertex.utility","l":"RelayVertex"},{"p":"org.apache.nemo.driver","l":"RemoteClientMessageLoggingHandler"},{"p":"org.apache.nemo.runtime.executor.data.metadata","l":"RemoteFileMetadata"},{"p":"org.apache.nemo.runtime.executor.data.stores","l":"RemoteFileStore"},{"p":"org.apache.nemo.runtime.common","l":"ReplyFutureMap"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.RequestBlockLocationMsg"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.RequestBlockLocationMsgOrBuilder"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.RequestBroadcastVariableMessage"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.RequestBroadcastVariableMessageOrBuilder"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.RequestPipeLocationMessage"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.RequestPipeLocationMessageOrBuilder"},{"p":"org.apache.nemo.compiler.optimizer.pass.compiletime","l":"Requires"},{"p":"org.apache.nemo.compiler.optimizer.pass.compiletime.reshaping","l":"ReshapingPass"},{"p":"org.apache.nemo.common.ir.vertex.executionproperty","l":"ResourceAntiAffinityProperty"},{"p":"org.apache.nemo.common.ir.vertex.executionproperty","l":"ResourceLambdaProperty"},{"p":"org.apache.nemo.compiler.optimizer.pass.compiletime.annotating","l":"ResourceLocalityPass"},{"p":"org.apache.nemo.common.ir.vertex.executionproperty","l":"ResourceLocalityProperty"},{"p":"org.apache.nemo.common.ir.vertex.executionproperty","l":"ResourcePriorityProperty"},{"p":"org.apache.nemo.compiler.optimizer.pass.compiletime.annotating","l":"ResourceSitePass"},{"p":"org.apache.nemo.common.ir.vertex.executionproperty","l":"ResourceSiteProperty"},{"p":"org.apache.nemo.compiler.optimizer.pass.compiletime.annotating","l":"ResourceSlotPass"},{"p":"org.apache.nemo.common.ir.vertex.executionproperty","l":"ResourceSlotProperty"},{"p":"org.apache.nemo.common.ir.executionproperty","l":"ResourceSpecification"},{"p":"org.apache.nemo.client.beam","l":"NemoRunnerRegistrar.Runner"},{"p":"org.apache.nemo.runtime.common.plan","l":"RuntimeEdge"},{"p":"org.apache.nemo.common.eventhandler","l":"RuntimeEvent"},{"p":"org.apache.nemo.common.eventhandler","l":"RuntimeEventHandler"},{"p":"org.apache.nemo.runtime.common","l":"RuntimeIdManager"},{"p":"org.apache.nemo.runtime.master","l":"RuntimeMaster"},{"p":"org.apache.nemo.runtime.executor.datatransfer","l":"RunTimeMessageOutputCollector"},{"p":"org.apache.nemo.common.exception","l":"RuntimeOptimizationException"},{"p":"org.apache.nemo.compiler.optimizer.pass.runtime","l":"RunTimePass"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.RunTimePassMessageEntry"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.RunTimePassMessageEntryOrBuilder"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.RunTimePassMessageMsg"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.RunTimePassMessageMsgOrBuilder"},{"p":"org.apache.nemo.runtime.common","l":"RuntimeTestUtil"},{"p":"org.apache.nemo.compiler.optimizer.policy","l":"SamplingLargeShuffleSkewPolicy"},{"p":"org.apache.nemo.compiler.optimizer.pass.compiletime.reshaping","l":"SamplingSkewReshapingPass"},{"p":"org.apache.nemo.compiler.optimizer.pass.compiletime.reshaping","l":"SamplingTaskSizingPass"},{"p":"org.apache.nemo.common.ir.vertex.utility","l":"SamplingVertex"},{"p":"org.apache.nemo.common.ir.vertex.executionproperty","l":"ScheduleGroupProperty"},{"p":"org.apache.nemo.runtime.master.scheduler","l":"Scheduler"},{"p":"org.apache.nemo.conf","l":"JobConf.SchedulerImplClassName"},{"p":"org.apache.nemo.conf","l":"JobConf.ScheduleSerThread"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.ScheduleTaskMsg"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.ScheduleTaskMsgOrBuilder"},{"p":"org.apache.nemo.runtime.master.scheduler","l":"SchedulingConstraint"},{"p":"org.apache.nemo.runtime.master.scheduler","l":"SchedulingConstraintRegistry"},{"p":"org.apache.nemo.common.exception","l":"SchedulingException"},{"p":"org.apache.nemo.runtime.master.scheduler","l":"SchedulingPolicy"},{"p":"org.apache.nemo.runtime.common.message","l":"MessageParameters.SenderId"},{"p":"org.apache.nemo.runtime.executor.data.block","l":"SerializedMemoryBlock"},{"p":"org.apache.nemo.runtime.executor.data.stores","l":"SerializedMemoryStore"},{"p":"org.apache.nemo.runtime.executor.data.partition","l":"SerializedPartition"},{"p":"org.apache.nemo.runtime.executor.data.streamchainer","l":"Serializer"},{"p":"org.apache.nemo.runtime.executor.data","l":"SerializerManager"},{"p":"org.apache.nemo.compiler.optimizer.pass.compiletime.annotating","l":"ShuffleEdgePushPass"},{"p":"org.apache.nemo.compiler.frontend.beam.coder","l":"SideInputCoder"},{"p":"org.apache.nemo.compiler.frontend.beam","l":"SideInputElement"},{"p":"org.apache.nemo.compiler.frontend.beam.transform","l":"SideInputTransform"},{"p":"org.apache.nemo.common.ir.vertex.transform","l":"SignalTransform"},{"p":"org.apache.nemo.common.ir.vertex.utility.runtimepass","l":"SignalVertex"},{"p":"org.apache.nemo.examples.beam","l":"SimpleSumSQL"},{"p":"org.apache.nemo.runtime.master.scheduler","l":"SimulatedTaskExecutor"},{"p":"org.apache.nemo.common.exception","l":"SimulationException"},{"p":"org.apache.nemo.runtime.master.scheduler","l":"SimulationScheduler"},{"p":"org.apache.nemo.runtime.executor.datatransfer","l":"SingleInputWatermarkManager"},{"p":"org.apache.nemo.compiler.optimizer.pass.compiletime.annotating","l":"SkewAnnotatingPass"},{"p":"org.apache.nemo.compiler.optimizer.pass.compiletime.composite","l":"SkewCompositePass"},{"p":"org.apache.nemo.compiler.backend.nemo.prophet","l":"SkewProphet"},{"p":"org.apache.nemo.compiler.optimizer.pass.compiletime.reshaping","l":"SkewReshapingPass"},{"p":"org.apache.nemo.compiler.optimizer.pass.runtime","l":"SkewRunTimePass"},{"p":"org.apache.nemo.common.ir.vertex","l":"SourceVertex"},{"p":"org.apache.nemo.compiler.frontend.spark","l":"SparkBroadcastVariables"},{"p":"org.apache.nemo.compiler.frontend.spark","l":"SparkKeyExtractor"},{"p":"org.apache.nemo.runtime.common.plan","l":"Stage"},{"p":"org.apache.nemo.runtime.common.plan","l":"StageEdge"},{"p":"org.apache.nemo.runtime.common.metric","l":"StageMetric"},{"p":"org.apache.nemo.runtime.master.servlet","l":"StageMetricServlet"},{"p":"org.apache.nemo.runtime.common.plan","l":"StagePartitioner"},{"p":"org.apache.nemo.runtime.common.state","l":"StageState"},{"p":"org.apache.nemo.driver","l":"NemoDriver.StartHandler"},{"p":"org.apache.nemo.runtime.common.state","l":"BlockState.State"},{"p":"org.apache.nemo.runtime.common.state","l":"PlanState.State"},{"p":"org.apache.nemo.runtime.common.state","l":"StageState.State"},{"p":"org.apache.nemo.runtime.common.state","l":"TaskState.State"},{"p":"org.apache.nemo.common","l":"StateMachine"},{"p":"org.apache.nemo.runtime.common.metric","l":"StateMetric"},{"p":"org.apache.nemo.runtime.common.metric","l":"StateTransitionEvent"},{"p":"org.apache.nemo.client","l":"StateTranslator"},{"p":"org.apache.nemo.compiler.optimizer.policy","l":"StreamingPolicy"},{"p":"org.apache.nemo.runtime.master.scheduler","l":"StreamingScheduler"},{"p":"org.apache.nemo.runtime.common.metric","l":"StreamMetric"},{"p":"org.apache.nemo.conf","l":"JobConf.StreamMetricPeriod"},{"p":"org.apache.nemo.common.ir.vertex.transform","l":"StreamTransform"},{"p":"org.apache.nemo.common.ir.edge.executionproperty","l":"SubPartitionSetProperty"},{"p":"org.apache.nemo.runtime.common.plan","l":"Task"},{"p":"org.apache.nemo.runtime.executor.task","l":"TaskExecutor"},{"p":"org.apache.nemo.runtime.common.metric","l":"TaskMetric"},{"p":"org.apache.nemo.runtime.master.servlet","l":"TaskMetricServlet"},{"p":"org.apache.nemo.common.ir.vertex.utility","l":"TaskSizeSplitterVertex"},{"p":"org.apache.nemo.runtime.common.state","l":"TaskState"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.TaskStateChangedMsg"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.TaskStateChangedMsgOrBuilder"},{"p":"org.apache.nemo.runtime.common.comm","l":"ControlMessage.TaskStateFromExecutor"},{"p":"org.apache.nemo.runtime.executor","l":"TaskStateManager"},{"p":"org.apache.nemo.runtime.common.plan","l":"TestPlanGenerator"},{"p":"org.apache.nemo.compiler.optimizer.policy","l":"TestPolicy"},{"p":"org.apache.nemo.examples.beam","l":"AlternatingLeastSquare.TrainingDataCombiner"},{"p":"org.apache.nemo.runtime.executor.transfer","l":"TransferOutputStream"},{"p":"org.apache.nemo.runtime.common.metric","l":"DataTransferEvent.TransferType"},{"p":"org.apache.nemo.common.ir.vertex.transform","l":"Transform"},{"p":"org.apache.nemo.runtime.executor","l":"TransformContextImpl"},{"p":"org.apache.nemo.compiler.optimizer.pass.compiletime.composite","l":"TransientResourceCompositePass"},{"p":"org.apache.nemo.compiler.optimizer.pass.compiletime.annotating","l":"TransientResourceDataTransferPass"},{"p":"org.apache.nemo.compiler.optimizer.policy","l":"TransientResourcePolicy"},{"p":"org.apache.nemo.compiler.optimizer.pass.compiletime.annotating","l":"TransientResourcePriorityPass"},{"p":"org.apache.nemo.common.dag","l":"DAGInterface.TraversalOrder"},{"p":"org.apache.nemo.common.ir.edge.executionproperty","l":"PartitionerProperty.Type"},{"p":"org.apache.nemo.examples.beam","l":"AlternatingLeastSquare.UngroupSingleVectorList"},{"p":"org.apache.nemo.common.exception","l":"UnknownExecutionStateException"},{"p":"org.apache.nemo.common.exception","l":"UnknownFailureCauseException"},{"p":"org.apache.nemo.common.exception","l":"UnrecoverableFailureException"},{"p":"org.apache.nemo.common.exception","l":"UnsupportedBlockStoreException"},{"p":"org.apache.nemo.common.exception","l":"UnsupportedCommPatternException"},{"p":"org.apache.nemo.common.exception","l":"UnsupportedCompressionException"},{"p":"org.apache.nemo.common.exception","l":"UnsupportedExecutionPropertyException"},{"p":"org.apache.nemo.common.exception","l":"UnsupportedMethodException"},{"p":"org.apache.nemo.common.exception","l":"UnsupportedMetricException"},{"p":"org.apache.nemo.common.exception","l":"UnsupportedPartitionerException"},{"p":"org.apache.nemo.examples.beam","l":"MultinomialLogisticRegression.UpdateModel"},{"p":"org.apache.nemo.examples.beam","l":"AlternatingLeastSquare.UpdateUserAndItemMatrix"},{"p":"org.apache.nemo.examples.beam","l":"AlternatingLeastSquareInefficient.UpdateUserAndItemMatrix"},{"p":"org.apache.nemo.compiler.optimizer.pass.compiletime.annotating","l":"UpfrontCloningPass"},{"p":"org.apache.nemo.driver","l":"UserApplicationRunner"},{"p":"org.apache.nemo.conf","l":"JobConf.UserMainArguments"},{"p":"org.apache.nemo.conf","l":"JobConf.UserMainClass"},{"p":"org.apache.nemo.common","l":"Util"},{"p":"org.apache.nemo.common.ir.edge.executionproperty","l":"BlockFetchFailureProperty.Value"},{"p":"org.apache.nemo.common.ir.edge.executionproperty","l":"CommunicationPatternProperty.Value"},{"p":"org.apache.nemo.common.ir.edge.executionproperty","l":"CompressionProperty.Value"},{"p":"org.apache.nemo.common.ir.edge.executionproperty","l":"DataFlowProperty.Value"},{"p":"org.apache.nemo.common.ir.edge.executionproperty","l":"DataPersistenceProperty.Value"},{"p":"org.apache.nemo.common.ir.edge.executionproperty","l":"DataStoreProperty.Value"},{"p":"org.apache.nemo.common.ir.vertex.executionproperty","l":"ResourceLambdaProperty.Value"},{"p":"org.apache.nemo.examples.beam","l":"EDGARTop10BadRefererDocs.ValueComparator"},{"p":"org.apache.nemo.examples.beam","l":"EDGARTop10Documents.ValueComparator"},{"p":"org.apache.nemo.common.dag","l":"Vertex"},{"p":"org.apache.nemo.common.ir.executionproperty","l":"VertexExecutionProperty"},{"p":"org.apache.nemo.runtime.common.comm","l":"GrpcMessageService.Void"},{"p":"org.apache.nemo.runtime.common.comm","l":"GrpcMessageService.VoidOrBuilder"},{"p":"org.apache.nemo.common.punctuation","l":"Watermark"},{"p":"org.apache.nemo.runtime.executor.datatransfer","l":"WatermarkWithIndex"},{"p":"org.apache.nemo.runtime.master.servlet","l":"WebSocketMetricAdapter"},{"p":"org.apache.nemo.runtime.master.servlet","l":"WebSocketMetricServlet"},{"p":"org.apache.nemo.examples.beam","l":"WindowedBroadcast"},{"p":"org.apache.nemo.examples.beam","l":"WindowedWordCount"},{"p":"org.apache.nemo.compiler.frontend.beam.transform","l":"WindowFnTransform"},{"p":"org.apache.nemo.examples.beam","l":"WordCount"},{"p":"org.apache.nemo.examples.beam","l":"BeamWordCount.WordCountOptions"},{"p":"org.apache.nemo.examples.beam","l":"WordCountTimeOut1Sec"},{"p":"org.apache.nemo.examples.beam","l":"WriteOneFilePerWindow"},{"p":"org.apache.nemo.compiler.optimizer.pass.compiletime.annotating","l":"XGBoostPass"},{"p":"org.apache.nemo.compiler.optimizer.policy","l":"XGBoostPolicy"}]