Uses of Interface
org.apache.nemo.runtime.executor.MetricMessageSender

Packages that use MetricMessageSender

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

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

Classes in org.apache.nemo.runtime.executor that implement MetricMessageSender

Modifier and Type	Class	Description
class	MetricManagerWorker	Metric sender that periodically flushes the collected metrics to Driver.

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

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

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

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

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