Package org.apache.flink.core.memory
Class DataInputViewStreamWrapper
- java.lang.Object
-
- java.io.InputStream
-
- java.io.FilterInputStream
-
- java.io.DataInputStream
-
- org.apache.flink.core.memory.DataInputViewStreamWrapper
-
- All Implemented Interfaces:
Closeable,DataInput,AutoCloseable,DataInputView
@PublicEvolving public class DataInputViewStreamWrapper extends DataInputStream implements DataInputView
Utility class that turns anInputStreaminto aDataInputView.
-
-
Field Summary
-
Fields inherited from class java.io.FilterInputStream
in
-
-
Constructor Summary
Constructors Constructor Description DataInputViewStreamWrapper(InputStream in)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidskipBytesToRead(int numBytes)SkipsnumBytesbytes of memory.-
Methods inherited from class java.io.DataInputStream
read, read, readBoolean, readByte, readChar, readDouble, readFloat, readFully, readFully, readInt, readLine, readLong, readShort, readUnsignedByte, readUnsignedShort, readUTF, readUTF, skipBytes
-
Methods inherited from class java.io.FilterInputStream
available, close, mark, markSupported, read, reset, skip
-
Methods inherited from class java.io.InputStream
nullInputStream, readAllBytes, readNBytes, readNBytes, transferTo
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface java.io.DataInput
readBoolean, readByte, readChar, readDouble, readFloat, readFully, readFully, readInt, readLine, readLong, readShort, readUnsignedByte, readUnsignedShort, readUTF, skipBytes
-
Methods inherited from interface org.apache.flink.core.memory.DataInputView
read, read
-
-
-
-
Constructor Detail
-
DataInputViewStreamWrapper
public DataInputViewStreamWrapper(InputStream in)
-
-
Method Detail
-
skipBytesToRead
public void skipBytesToRead(int numBytes) throws IOExceptionDescription copied from interface:DataInputViewSkipsnumBytesbytes of memory. In contrast to theDataInput.skipBytes(int)method, this method always skips the desired number of bytes or throws anEOFException.- Specified by:
skipBytesToReadin interfaceDataInputView- Parameters:
numBytes- The number of bytes to skip.- Throws:
IOException- Thrown, if any I/O related problem occurred such that the input could not be advanced to the desired position.
-
-