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

Packages that use InputSplitAssigner

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

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

Classes in org.apache.flink.api.common.io that implement InputSplitAssigner

Modifier and Type	Class	Description
class	DefaultInputSplitAssigner	This is the default implementation of the InputSplitAssigner interface.
class	LocatableInputSplitAssigner	The locatable input split assigner assigns to each host splits that are local, before assigning splits that are not local.
class	ReplicatingInputSplitAssigner	Assigns each InputSplit to each requesting parallel instance.

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

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

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

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

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