public static final class FlinkSequenceInputFormat.FDataInputFormat extends org.apache.flink.api.common.io.BinaryInputFormat<FData>
org.apache.flink.api.common.io.BinaryInputFormat.BlockBasedInput
org.apache.flink.api.common.io.FileInputFormat.AbstractConfigBuilder<T>, org.apache.flink.api.common.io.FileInputFormat.ConfigBuilder, org.apache.flink.api.common.io.FileInputFormat.FileBaseStatistics, org.apache.flink.api.common.io.FileInputFormat.InputSplitOpenThread
Modifier and Type | Field and Description |
---|---|
(package private) MRContainer |
key |
(package private) MRContainer |
value |
Constructor and Description |
---|
FlinkSequenceInputFormat.FDataInputFormat() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
protected FData |
deserialize(FData reuse,
org.apache.flink.core.memory.DataInputView in) |
protected List<org.apache.flink.core.fs.FileStatus> |
getFiles() |
FData |
nextRecord(FData record) |
void |
open(org.apache.flink.core.fs.FileInputSplit split) |
boolean |
reachedEnd() |
configure, createBlockInfo, createInputSplits, createStatistics, getInputSplits, getStatistics
acceptFile, configureFileFormat, getFilePath, getFileStats, getInputSplitAssigner, getMinSplitSize, getNumSplits, getOpenTimeout, getSplitLength, getSplitStart, setFilePath, setFilePath, setMinSplitSize, setNumSplits, setOpenTimeout, toString
MRContainer key
MRContainer value
public FlinkSequenceInputFormat.FDataInputFormat()
public void open(org.apache.flink.core.fs.FileInputSplit split) throws IOException
open
in interface org.apache.flink.api.common.io.InputFormat<FData,org.apache.flink.core.fs.FileInputSplit>
open
in class org.apache.flink.api.common.io.BinaryInputFormat<FData>
IOException
public FData nextRecord(FData record) throws IOException
nextRecord
in interface org.apache.flink.api.common.io.InputFormat<FData,org.apache.flink.core.fs.FileInputSplit>
nextRecord
in class org.apache.flink.api.common.io.BinaryInputFormat<FData>
IOException
public boolean reachedEnd()
public void close() throws IOException
close
in interface org.apache.flink.api.common.io.InputFormat<FData,org.apache.flink.core.fs.FileInputSplit>
close
in class org.apache.flink.api.common.io.FileInputFormat<FData>
IOException
protected List<org.apache.flink.core.fs.FileStatus> getFiles() throws IOException
getFiles
in class org.apache.flink.api.common.io.BinaryInputFormat<FData>
IOException
protected FData deserialize(FData reuse, org.apache.flink.core.memory.DataInputView in) throws IOException
deserialize
in class org.apache.flink.api.common.io.BinaryInputFormat<FData>
IOException
Copyright © 2013-2015 The Apache Software Foundation. All Rights Reserved.