org.apache.flink.core.memory

Class ByteArrayInputStreamWithPos

java.lang.Object

java.io.InputStream

org.apache.flink.core.memory.MemorySegmentInputStreamWithPos

org.apache.flink.core.memory.ByteArrayInputStreamWithPos

All Implemented Interfaces:

Closeable, AutoCloseable

@Internal
public class ByteArrayInputStreamWithPos
extends MemorySegmentInputStreamWithPos

Un-synchronized stream similar to Java's ByteArrayInputStream that also exposes the current position.

Constructor Summary

Constructors

Constructor and Description
ByteArrayInputStreamWithPos()
ByteArrayInputStreamWithPos(byte[] buffer)
ByteArrayInputStreamWithPos(byte[] buffer, int offset, int length)

Method Summary

Modifier and Type	Method and Description
void	setBuffer(byte[] buffer, int off, int len)

Methods inherited from class org.apache.flink.core.memory.MemorySegmentInputStreamWithPos

available, close, getPosition, mark, markSupported, read, read, reset, setPosition, setSegment, skip

Methods inherited from class java.io.InputStream

read

Methods inherited from class java.lang.Object

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

Constructor Detail

ByteArrayInputStreamWithPos

public ByteArrayInputStreamWithPos()

ByteArrayInputStreamWithPos

public ByteArrayInputStreamWithPos(byte[] buffer)

ByteArrayInputStreamWithPos

public ByteArrayInputStreamWithPos(byte[] buffer,
                                   int offset,
                                   int length)

Method Detail

setBuffer

public void setBuffer(byte[] buffer,
                      int off,
                      int len)