Interface InputReader

    • Method Detail

      • read

        java.util.List<java.util.concurrent.CompletableFuture<DataUtil.IteratorWithNumBytes>> read()
        Reads input data depending on the communication pattern of the srcVertex.
        Returns:
        the list of iterators.
      • retry

        java.util.concurrent.CompletableFuture<DataUtil.IteratorWithNumBytes> retry​(int index)
        Retry reading input data.
        Parameters:
        index - of the failed iterator in the list returned by read().
        Returns:
        the retried iterator.
      • getSrcIrVertex

        IRVertex getSrcIrVertex()
      • getSourceParallelism

        static int getSourceParallelism​(InputReader inputReader)