Interface InputSplitProvider

  • All Known Implementing Classes:
    RpcInputSplitProvider

    @Public
    public interface InputSplitProvider
    An input split provider can be successively queried to provide a series of InputSplit objects a task is supposed to consume in the course of its execution.
    • Method Detail

      • getNextInputSplit

        InputSplit getNextInputSplit​(ClassLoader userCodeClassLoader)
                              throws InputSplitProviderException
        Requests the next input split to be consumed by the calling task.
        Parameters:
        userCodeClassLoader - used to deserialize input splits
        Returns:
        the next input split to be consumed by the calling task or null if the task shall not consume any further input splits.
        Throws:
        InputSplitProviderException - if fetching the next input split fails