- java.lang.Object
-
- org.apache.flink.api.common.io.RichInputFormat<OT,org.apache.flink.core.fs.FileInputSplit>
-
- org.apache.flink.api.common.io.FileInputFormat<T>
-
- org.apache.flink.api.common.io.BinaryInputFormat<FData>
-
- org.apache.mrql.FlinkBinaryInputFormat.FDataInputFormat
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.apache.flink.api.common.io.BinaryInputFormat
org.apache.flink.api.common.io.BinaryInputFormat.BlockBasedInput
-
Nested classes/interfaces inherited from class org.apache.flink.api.common.io.FileInputFormat
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
-
Field Summary
-
Fields inherited from class org.apache.flink.api.common.io.BinaryInputFormat
BLOCK_SIZE_PARAMETER_KEY, NATIVE_BLOCK_SIZE
-
Fields inherited from class org.apache.flink.api.common.io.FileInputFormat
currentSplit, ENUMERATE_NESTED_FILES_FLAG, enumerateNestedFiles, filePath, INFLATER_INPUT_STREAM_FACTORIES, minSplitSize, numSplits, openTimeout, READ_WHOLE_SPLIT_FLAG, splitLength, splitStart, stream, unsplittable
-
Method Summary
-
Methods inherited from class org.apache.flink.api.common.io.BinaryInputFormat
configure, createBlockInfo, createInputSplits, createStatistics, getFiles, getInputSplits, getStatistics, nextRecord, open, reachedEnd
-
Methods inherited from class org.apache.flink.api.common.io.FileInputFormat
acceptFile, close, configureFileFormat, decorateInputStream, extractFileExtension, getFilePath, getFileStats, getInflaterInputStreamFactory, getInputSplitAssigner, getMinSplitSize, getNumSplits, getOpenTimeout, getSplitLength, getSplitStart, registerInflaterInputStreamFactory, setFilePath, setFilePath, setMinSplitSize, setNumSplits, setOpenTimeout, testForUnsplittable, toString
-
Methods inherited from class org.apache.flink.api.common.io.RichInputFormat
getRuntimeContext, setRuntimeContext
Copyright © 2013-2016 The Apache Software Foundation. All Rights Reserved.