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

Class IntermediateDataIOFactory

java.lang.Object

org.apache.nemo.runtime.executor.datatransfer.IntermediateDataIOFactory

public final class IntermediateDataIOFactory
extends java.lang.Object

A factory that produces InputReader and OutputWriter.

Method Summary

Modifier and Type	Method	Description
InputReader	createReader(java.lang.String dstTaskId, IRVertex srcIRVertex, RuntimeEdge runtimeEdge)	Creates an InputReader between two stages.
OutputWriter	createWriter(java.lang.String srcTaskId, RuntimeEdge<?> runtimeEdge)	Creates an OutputWriter between two stages.

Methods inherited from class java.lang.Object

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

Method Detail

createWriter

public OutputWriter createWriter(java.lang.String srcTaskId,
                                 RuntimeEdge<?> runtimeEdge)

Creates an OutputWriter between two stages.

Parameters:

srcTaskId - the id of the source task.

runtimeEdge - that connects the srcTask to the tasks belonging to dstIRVertex.

Returns:

the OutputWriter created.

createReader

public InputReader createReader(java.lang.String dstTaskId,
                                IRVertex srcIRVertex,
                                RuntimeEdge runtimeEdge)

Creates an InputReader between two stages.

Parameters:

dstTaskId - the id of the destination task.

srcIRVertex - the IRVertex that output the data to be read.

runtimeEdge - that connects the tasks belonging to srcIRVertex to dstTask.

Returns:

the InputReader created.