Package org.apache.nemo.runtime.master

Class PipeManagerMaster

java.lang.Object

org.apache.nemo.runtime.master.PipeManagerMaster

@ThreadSafe
public final class PipeManagerMaster
extends java.lang.Object

Master-side pipe manager.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	PipeManagerMaster.PipeManagerMasterControlMessageReceiver	Handler for control messages received.

Method Summary

Modifier and Type	Method	Description
void	onTaskScheduled(java.lang.String edgeId, long srcIndex)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

onTaskScheduled

public void onTaskScheduled(java.lang.String edgeId,
                            long srcIndex)