org.apache.flink.runtime.jobgraph.tasks

Interface InputSplitProvider

All Known Implementing Classes:

TaskInputSplitProvider

@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 Summary

Modifier and Type	Method and Description
InputSplit	getNextInputSplit() Requests the next input split to be consumed by the calling task.

Method Detail

getNextInputSplit

InputSplit getNextInputSplit()

Requests the next input split to be consumed by the calling task.

Returns:

the next input split to be consumed by the calling task or null if the task shall not consume any further input splits.