T
- @PublicEvolving public class TypeSerializerInputFormat<T> extends BinaryInputFormat<T> implements ResultTypeQueryable<T>
BinaryInputFormat.BlockBasedInput
FileInputFormat.FileBaseStatistics, FileInputFormat.InputSplitOpenThread
BLOCK_SIZE_PARAMETER_KEY, NATIVE_BLOCK_SIZE
currentSplit, ENUMERATE_NESTED_FILES_FLAG, enumerateNestedFiles, filePath, INFLATER_INPUT_STREAM_FACTORIES, minSplitSize, numSplits, openTimeout, READ_WHOLE_SPLIT_FLAG, splitLength, splitStart, stream, unsplittable
Constructor and Description |
---|
TypeSerializerInputFormat(TypeInformation<T> resultType) |
Modifier and Type | Method and Description |
---|---|
protected T |
deserialize(T reuse,
DataInputView dataInput) |
TypeInformation<T> |
getProducedType()
Gets the data type (as a
TypeInformation ) produced by this function or input format. |
configure, createBlockInfo, createInputSplits, createStatistics, getFiles, getInputSplits, getStatistics, nextRecord, open, reachedEnd
acceptFile, close, decorateInputStream, extractFileExtension, getFilePath, getFileStats, getInflaterInputStreamFactory, getInputSplitAssigner, getMinSplitSize, getNumSplits, getOpenTimeout, getSplitLength, getSplitStart, registerInflaterInputStreamFactory, setFilePath, setFilePath, setMinSplitSize, setNumSplits, setOpenTimeout, testForUnsplittable, toString
getRuntimeContext, setRuntimeContext
public TypeSerializerInputFormat(TypeInformation<T> resultType)
protected T deserialize(T reuse, DataInputView dataInput) throws IOException
deserialize
in class BinaryInputFormat<T>
IOException
public TypeInformation<T> getProducedType()
ResultTypeQueryable
TypeInformation
) produced by this function or input format.getProducedType
in interface ResultTypeQueryable<T>
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.