Interface InputSplitProvider
-
- All Known Implementing Classes:
RpcInputSplitProvider
@Public public interface InputSplitProvider
An input split provider can be successively queried to provide a series ofInputSplit
objects a task is supposed to consume in the course of its execution.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description InputSplit
getNextInputSplit(ClassLoader userCodeClassLoader)
Requests the next input split to be consumed by the calling task.
-
-
-
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
-
-