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

Class NextIntraTaskOperatorInfo

java.lang.Object

org.apache.nemo.runtime.executor.datatransfer.NextIntraTaskOperatorInfo

public final class NextIntraTaskOperatorInfo
extends java.lang.Object

Contains information for next operator: -- edgeIndex: the index of edge to next operator. -- nextOperator: next operator vertex -- watermarkManager: next operator's watermark manager

ex) --edge (index 0)--> --edge (index 1)--> watermarkManager --> nextOperator --edge (index 2)-->

Constructor Summary

Constructors

Constructor	Description
NextIntraTaskOperatorInfo(int edgeIndex, OperatorVertex nextOperator, InputWatermarkManager watermarkManager)

Method Summary

Modifier and Type	Method	Description
int	getEdgeIndex()
OperatorVertex	getNextOperator()
InputWatermarkManager	getWatermarkManager()

Methods inherited from class java.lang.Object

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

Constructor Detail

NextIntraTaskOperatorInfo

public NextIntraTaskOperatorInfo(int edgeIndex,
                                 OperatorVertex nextOperator,
                                 InputWatermarkManager watermarkManager)

Method Detail

getEdgeIndex

public int getEdgeIndex()

getNextOperator

public OperatorVertex getNextOperator()

getWatermarkManager

public InputWatermarkManager getWatermarkManager()