Uses of Class
org.apache.flink.core.fs.FileInputSplit

Packages that use FileInputSplit

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

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

Fields in org.apache.flink.api.common.io declared as FileInputSplit

Modifier and Type	Field	Description
protected FileInputSplit	FileInputFormat.currentSplit	The current split that this parallel instance must consume.

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

Modifier and Type	Method	Description
FileInputSplit[]	BinaryInputFormat.createInputSplits(int minNumSplits)
FileInputSplit[]	FileInputFormat.createInputSplits(int minNumSplits)	Computes the input splits for the file.
protected FileInputSplit[]	BinaryInputFormat.getInputSplits()

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

Modifier and Type	Method	Description
protected FSDataInputStream	FileInputFormat.decorateInputStream(FSDataInputStream inputStream, FileInputSplit fileSplit)	This method allows to wrap/decorate the raw FSDataInputStream for a certain file split, e.g., for decoding.
LocatableInputSplitAssigner	FileInputFormat.getInputSplitAssigner(FileInputSplit[] splits)
protected void	DelimitedInputFormat.initializeSplit(FileInputSplit split, Long state)	Initialization method that is called after opening or reopening an input split.
protected void	GenericCsvInputFormat.initializeSplit(FileInputSplit split, Long offset)
void	BinaryInputFormat.open(FileInputSplit split)
void	DelimitedInputFormat.open(FileInputSplit split)	Opens the given input split.
void	FileInputFormat.open(FileInputSplit fileSplit)	Opens an input stream to the file defined in the input format.
void	BinaryInputFormat.reopen(FileInputSplit split, Tuple2<Long,Long> state)
void	DelimitedInputFormat.reopen(FileInputSplit split, Long state)

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

Constructor	Description
InputSplitOpenThread(FileInputSplit split, long timeout)