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

Packages that use InputSplit

Package	Description
org.apache.flink.addons.hbase
org.apache.flink.api.common.io
org.apache.flink.api.java.hadoop.common
org.apache.flink.api.java.hadoop.mapreduce.wrapper
org.apache.flink.api.java.io.jdbc
org.apache.flink.batch.connectors.cassandra
org.apache.flink.core.fs
org.apache.flink.core.io
org.apache.flink.examples.java.distcp
org.apache.flink.runtime.jobgraph.tasks
org.apache.flink.runtime.taskexecutor.rpc
org.apache.flink.runtime.taskmanager
org.apache.flink.streaming.api.functions.source

Uses of InputSplit in org.apache.flink.addons.hbase

Classes in org.apache.flink.addons.hbase that implement InputSplit

Modifier and Type	Class and Description
class	TableInputSplit This class implements a input splits for HBase.

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 and 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 and Description
S[]	ReplicatingInputFormat.createInputSplits(int minNumSplits)
T[]	InputFormat.createInputSplits(int minNumSplits) Creates the different splits of the input that can be processed in parallel.
InputSplit	ReplicatingInputSplitAssigner.getNextInputSplit(String host, int taskId)
InputSplit	DefaultInputSplitAssigner.getNextInputSplit(String host, int taskId)

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

Modifier and Type	Method and Description
InputSplitAssigner	ReplicatingInputFormat.getInputSplitAssigner(S[] inputSplits)
InputSplitAssigner	InputFormat.getInputSplitAssigner(T[] inputSplits) Gets the type of the input splits that are processed by this input format.

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

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

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

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

Uses of InputSplit in org.apache.flink.api.java.hadoop.common

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

Modifier and Type	Class and Description
class	HadoopInputFormatCommonBase<T,SPITTYPE extends InputSplit> A common base for both "mapred" and "mapreduce" Hadoop input formats.

Uses of InputSplit in org.apache.flink.api.java.hadoop.mapreduce.wrapper

Classes in org.apache.flink.api.java.hadoop.mapreduce.wrapper that implement InputSplit

Modifier and Type	Class and Description
class	HadoopInputSplit A wrapper that represents an input split from the Hadoop mapreduce API as a Flink InputSplit.

Uses of InputSplit in org.apache.flink.api.java.io.jdbc

Methods in org.apache.flink.api.java.io.jdbc that return InputSplit

Modifier and Type	Method and Description
InputSplit[]	JDBCInputFormat.createInputSplits(int minNumSplits)

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

Modifier and Type	Method and Description
InputSplitAssigner	JDBCInputFormat.getInputSplitAssigner(InputSplit[] inputSplits)
void	JDBCInputFormat.open(InputSplit inputSplit) Connects to the source database and executes the query in a parallel fashion if this InputFormat is built using a parameterized query (i.e.

Uses of InputSplit in org.apache.flink.batch.connectors.cassandra

Methods in org.apache.flink.batch.connectors.cassandra that return InputSplit

Modifier and Type	Method and Description
InputSplit[]	CassandraInputFormat.createInputSplits(int minNumSplits)

Methods in org.apache.flink.batch.connectors.cassandra with parameters of type InputSplit

Modifier and Type	Method and Description
InputSplitAssigner	CassandraInputFormat.getInputSplitAssigner(InputSplit[] inputSplits)
void	CassandraInputFormat.open(InputSplit ignored) Opens a Session and executes the query.

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

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

Modifier and Type	Class and 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 and 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 and 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 and 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 and Description
InputSplitAssigner	InputSplitSource.getInputSplitAssigner(T[] inputSplits) Returns the assigner for the input splits.

Uses of InputSplit in org.apache.flink.examples.java.distcp

Classes in org.apache.flink.examples.java.distcp that implement InputSplit

Modifier and Type	Class and Description
class	FileCopyTaskInputSplit Implementation of InputSplit for copying files.

Uses of InputSplit in org.apache.flink.runtime.jobgraph.tasks

Methods in org.apache.flink.runtime.jobgraph.tasks that return InputSplit

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

Uses of InputSplit in org.apache.flink.runtime.taskexecutor.rpc

Methods in org.apache.flink.runtime.taskexecutor.rpc that return InputSplit

Modifier and Type	Method and Description
InputSplit	RpcInputSplitProvider.getNextInputSplit(ClassLoader userCodeClassLoader)

Uses of InputSplit in org.apache.flink.runtime.taskmanager

Methods in org.apache.flink.runtime.taskmanager that return InputSplit

Modifier and Type	Method and Description
InputSplit	TaskInputSplitProvider.getNextInputSplit(ClassLoader userCodeClassLoader)

Uses of InputSplit in org.apache.flink.streaming.api.functions.source

Classes in org.apache.flink.streaming.api.functions.source that implement InputSplit

Modifier and Type	Class and Description
class	TimestampedFileInputSplit An extended FileInputSplit that also includes information about: The modification time of the file this split belongs to. When checkpointing, the state of the split at the moment of the checkpoint. This class is used by the ContinuousFileMonitoringFunction and the ContinuousFileReaderOperator to perform continuous file processing.

Methods in org.apache.flink.streaming.api.functions.source that return types with arguments of type InputSplit

Modifier and Type	Method and Description
InputFormat<OUT,InputSplit>	InputFormatSourceFunction.getFormat() Returns the InputFormat.