org.apache.flink.core.io

Interface InputSplit

All Superinterfaces:

Serializable

All Known Subinterfaces:

PrioritizedOperatorSubtaskStateInputSplit, TimestampedInputSplit

All Known Implementing Classes:

FileCopyTaskInputSplit, FileInputSplit, GenericInputSplit, HadoopInputSplit, HadoopInputSplit, HiveTableInputSplit, KeyGroupRangeInputSplit, LocatableInputSplit, OperatorStateInputSplit, TableInputSplit, TimestampedFileInputSplit

@Public
public interface InputSplit
extends Serializable

This interface must be implemented by all kind of input splits that can be assigned to input formats.

Input splits are transferred in serialized form via the messages, so they need to be serializable as defined by Serializable.

Method Summary

Modifier and Type	Method and Description
int	getSplitNumber() Returns the number of this input split.

Method Detail

getSplitNumber

int getSplitNumber()

Returns the number of this input split.

Returns:

the number of this input split