Package | Description |
---|---|
org.apache.flink.api.common.io | |
org.apache.flink.api.java.io | |
org.apache.flink.contrib.tweetinputformat.io |
Modifier and Type | Field and Description |
---|---|
protected FileInputSplit |
FileInputFormat.currentSplit
The current split that this parallel instance must consume.
|
Modifier and Type | Method and Description |
---|---|
FileInputSplit[] |
FileInputFormat.createInputSplits(int minNumSplits)
Computes the input splits for the file.
|
FileInputSplit[] |
BinaryInputFormat.createInputSplits(int minNumSplits) |
protected FileInputSplit[] |
BinaryInputFormat.getInputSplits() |
Modifier and Type | Method and 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) |
void |
GenericCsvInputFormat.open(FileInputSplit split) |
void |
FileInputFormat.open(FileInputSplit fileSplit)
Opens an input stream to the file defined in the input format.
|
void |
DelimitedInputFormat.open(FileInputSplit split)
Opens the given input split.
|
void |
BinaryInputFormat.open(FileInputSplit split) |
Constructor and Description |
---|
InputSplitOpenThread(FileInputSplit split,
long timeout) |
Modifier and Type | Method and Description |
---|---|
void |
PrimitiveInputFormat.open(FileInputSplit split) |
void |
PojoCsvInputFormat.open(FileInputSplit split) |
void |
CsvInputFormat.open(FileInputSplit split) |
void |
AvroInputFormat.open(FileInputSplit split) |
Modifier and Type | Method and Description |
---|---|
void |
SimpleTweetInputFormat.open(FileInputSplit split) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.