- java.lang.Object
-
- org.apache.flink.api.common.io.RichInputFormat<OT,org.apache.flink.core.fs.FileInputSplit>
-
- org.apache.flink.api.common.io.FileInputFormat<FData>
-
- org.apache.mrql.FlinkParsedInputFormat.ParsedInputFormat
-
-
Nested Class Summary
-
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.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.FileInputFormat
acceptFile, close, configure, configureFileFormat, createInputSplits, decorateInputStream, extractFileExtension, getFilePath, getFileStats, getInflaterInputStreamFactory, getInputSplitAssigner, getMinSplitSize, getNumSplits, getOpenTimeout, getSplitLength, getSplitStart, getStatistics, registerInflaterInputStreamFactory, setFilePath, setFilePath, setMinSplitSize, setNumSplits, setOpenTimeout, testForUnsplittable, toString
-
Methods inherited from class org.apache.flink.api.common.io.RichInputFormat
getRuntimeContext, setRuntimeContext
-
-
Field Detail
-
data_sources
String data_sources
Copyright © 2013-2016 The Apache Software Foundation. All Rights Reserved.