Uses of Interface
org.apache.flink.core.io.InputSplit

Packages that use InputSplit

Package	Description
org.apache.flink.api.common.io
org.apache.flink.core.fs
org.apache.flink.core.io

Uses of InputSplit in org.apache.flink.api.common.io

Classes in org.apache.flink.api.common.io with type parameters of type InputSplit

Modifier and Type	Interface	Description
interface	CheckpointableInputFormat<S extends InputSplit,T extends Serializable>	An interface that describes InputFormats that allow checkpointing/restoring their state.
interface	InputFormat<OT,T extends InputSplit>	The base interface for data sources that produces records.
class	ReplicatingInputFormat<OT,S extends InputSplit>	A ReplicatingInputFormat replicates any InputFormat to all parallel instances of a DataSource, i.e., the full input of the replicated InputFormat is completely processed by each parallel instance of the DataSource.
class	RichInputFormat<OT,T extends InputSplit>	An abstract stub implementation for Rich input formats.

Methods in org.apache.flink.api.common.io that return InputSplit

Modifier and Type	Method	Description
T[]	InputFormat.createInputSplits(int minNumSplits)
S[]	ReplicatingInputFormat.createInputSplits(int minNumSplits)
InputSplit	DefaultInputSplitAssigner.getNextInputSplit(String host, int taskId)
InputSplit	ReplicatingInputSplitAssigner.getNextInputSplit(String host, int taskId)

Methods in org.apache.flink.api.common.io with parameters of type InputSplit

Modifier and Type	Method	Description
InputSplitAssigner	InputFormat.getInputSplitAssigner(T[] inputSplits)
InputSplitAssigner	ReplicatingInputFormat.getInputSplitAssigner(S[] inputSplits)

Method parameters in org.apache.flink.api.common.io with type arguments of type InputSplit

Modifier and Type	Method	Description
void	DefaultInputSplitAssigner.returnInputSplit(List<InputSplit> splits, int taskId)
void	LocatableInputSplitAssigner.returnInputSplit(List<InputSplit> splits, int taskId)
void	ReplicatingInputSplitAssigner.returnInputSplit(List<InputSplit> splits, int taskId)

Constructors in org.apache.flink.api.common.io with parameters of type InputSplit

Constructor	Description
DefaultInputSplitAssigner(InputSplit[] splits)
ReplicatingInputSplitAssigner(InputSplit[] splits)

Constructor parameters in org.apache.flink.api.common.io with type arguments of type InputSplit

Constructor	Description
DefaultInputSplitAssigner(Collection<? extends InputSplit> splits)
ReplicatingInputSplitAssigner(Collection<InputSplit> splits)

Uses of InputSplit in org.apache.flink.core.fs

Classes in org.apache.flink.core.fs that implement InputSplit

Modifier and Type	Class	Description
class	FileInputSplit	A file input split provides information on a particular part of a file, possibly hosted on a distributed file system and replicated among several hosts.

Uses of InputSplit in org.apache.flink.core.io

Classes in org.apache.flink.core.io with type parameters of type InputSplit

Modifier and Type	Interface	Description
interface	InputSplitSource<T extends InputSplit>	InputSplitSources create InputSplits that define portions of data to be produced by InputFormats.

Classes in org.apache.flink.core.io that implement InputSplit

Modifier and Type	Class	Description
class	GenericInputSplit	A generic input split that has only a partition number.
class	LocatableInputSplit	A locatable input split is an input split referring to input data which is located on one or more hosts.

Methods in org.apache.flink.core.io that return InputSplit

Modifier and Type	Method	Description
T[]	InputSplitSource.createInputSplits(int minNumSplits)	Computes the input splits.
InputSplit	InputSplitAssigner.getNextInputSplit(String host, int taskId)	Returns the next input split that shall be consumed.

Methods in org.apache.flink.core.io with parameters of type InputSplit

Modifier and Type	Method	Description
InputSplitAssigner	InputSplitSource.getInputSplitAssigner(T[] inputSplits)	Returns the assigner for the input splits.

Method parameters in org.apache.flink.core.io with type arguments of type InputSplit

Modifier and Type	Method	Description
void	InputSplitAssigner.returnInputSplit(List<InputSplit> splits, int taskId)	Return the splits to assigner if the task failed to process it.