Uses of Class
org.apache.nemo.runtime.common.message.PersistentConnectionToMasterMap

Packages that use PersistentConnectionToMasterMap

Package	Description
org.apache.nemo.runtime.executor
org.apache.nemo.runtime.executor.datatransfer
org.apache.nemo.runtime.executor.task

Uses of PersistentConnectionToMasterMap in org.apache.nemo.runtime.executor

Constructors in org.apache.nemo.runtime.executor with parameters of type PersistentConnectionToMasterMap

Constructor	Description
TaskStateManager(Task task, java.lang.String executorId, PersistentConnectionToMasterMap persistentConnectionToMasterMap, MetricMessageSender metricMessageSender)

Uses of PersistentConnectionToMasterMap in org.apache.nemo.runtime.executor.datatransfer

Constructors in org.apache.nemo.runtime.executor.datatransfer with parameters of type PersistentConnectionToMasterMap

Constructor	Description
RunTimeMessageOutputCollector(java.lang.String taskId, IRVertex irVertex, PersistentConnectionToMasterMap connectionToMasterMap, TaskExecutor taskExecutor, boolean dataTransferNeeded)

Uses of PersistentConnectionToMasterMap in org.apache.nemo.runtime.executor.task

Constructors in org.apache.nemo.runtime.executor.task with parameters of type PersistentConnectionToMasterMap

Constructor	Description
TaskExecutor(Task task, DAG<IRVertex,RuntimeEdge<IRVertex>> irVertexDag, TaskStateManager taskStateManager, IntermediateDataIOFactory intermediateDataIOFactory, BroadcastManagerWorker broadcastManagerWorker, MetricMessageSender metricMessageSender, PersistentConnectionToMasterMap persistentConnectionToMasterMap, int latencyMarkPeriod)	Constructor.