Package org.apache.flink.core.io
Class GenericInputSplit
- java.lang.Object
-
- org.apache.flink.core.io.GenericInputSplit
-
- All Implemented Interfaces:
Serializable,InputSplit
@Public public class GenericInputSplit extends Object implements InputSplit, Serializable
A generic input split that has only a partition number.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description GenericInputSplit(int partitionNumber, int totalNumberOfPartitions)Creates a generic input split with the given split number.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanequals(Object obj)intgetSplitNumber()Returns the number of this input split.intgetTotalNumberOfSplits()inthashCode()StringtoString()
-
-
-
Constructor Detail
-
GenericInputSplit
public GenericInputSplit(int partitionNumber, int totalNumberOfPartitions)Creates a generic input split with the given split number.- Parameters:
partitionNumber- The number of the split's partition.totalNumberOfPartitions- The total number of the splits (partitions).
-
-
Method Detail
-
getSplitNumber
public int getSplitNumber()
Description copied from interface:InputSplitReturns the number of this input split.- Specified by:
getSplitNumberin interfaceInputSplit- Returns:
- the number of this input split
-
getTotalNumberOfSplits
public int getTotalNumberOfSplits()
-
-