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

Class SerializedInputFormat<T extends IOReadableWritable>

java.lang.Object

org.apache.flink.api.common.io.RichInputFormat<OT,FileInputSplit>

org.apache.flink.api.common.io.FileInputFormat<T>

org.apache.flink.api.common.io.BinaryInputFormat<T>

org.apache.flink.api.common.io.SerializedInputFormat<T>

All Implemented Interfaces:

Serializable, CheckpointableInputFormat<FileInputSplit,Tuple2<Long,Long>>, InputFormat<T,FileInputSplit>, InputSplitSource<FileInputSplit>

@Public
public class SerializedInputFormat<T extends IOReadableWritable>
extends BinaryInputFormat<T>

Reads elements by deserializing them with their regular serialization/deserialization functionality.

See Also:

SerializedOutputFormat, Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.api.common.io.BinaryInputFormat

BinaryInputFormat.BlockBasedInput

Nested classes/interfaces inherited from class org.apache.flink.api.common.io.FileInputFormat

FileInputFormat.FileBaseStatistics, 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

Constructor Summary

Constructors

Constructor	Description
SerializedInputFormat()

Method Summary

Modifier and Type	Method	Description
protected T	deserialize(T reuse, DataInputView dataInput)

Methods inherited from class org.apache.flink.api.common.io.BinaryInputFormat

configure, createBlockInfo, createInputSplits, createStatistics, getBlockSize, getCurrentState, getFiles, getInputSplits, getStatistics, nextRecord, open, reachedEnd, reopen, setBlockSize

Methods inherited from class org.apache.flink.api.common.io.FileInputFormat

acceptFile, close, decorateInputStream, extractFileExtension, getFilePath, getFilePaths, getFileStats, getFileStats, getInflaterInputStreamFactory, getInputSplitAssigner, getMinSplitSize, getNestedFileEnumeration, getNumSplits, getOpenTimeout, getSplitLength, getSplitStart, getSupportedCompressionFormats, registerInflaterInputStreamFactory, setFilePath, setFilePath, setFilePaths, setFilePaths, setFilesFilter, setMinSplitSize, setNestedFileEnumeration, setNumSplits, setOpenTimeout, supportsMultiPaths, testForUnsplittable, toString

Methods inherited from class org.apache.flink.api.common.io.RichInputFormat

closeInputFormat, getRuntimeContext, openInputFormat, setRuntimeContext

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

SerializedInputFormat

public SerializedInputFormat()

Method Detail

deserialize

protected T deserialize(T reuse,
                        DataInputView dataInput)
                 throws IOException

Specified by:

deserialize in class BinaryInputFormat<T extends IOReadableWritable>

Throws:

IOException