Class IntermediateDataIOFactory

    • Method Detail

      • createWriter

        public OutputWriter createWriter​(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​(int dstTaskIdx,
                                        IRVertex srcIRVertex,
                                        RuntimeEdge runtimeEdge)
        Creates an InputReader between two stages.
        Parameters:
        dstTaskIdx - the index 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.