ByteArrayInputStreamWithPos (Flink : Core 1.20.2-cp1 API)

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	Description
`ByteArrayInputStreamWithPos()`
`ByteArrayInputStreamWithPos(byte[] buffer)`
`ByteArrayInputStreamWithPos(byte[] buffer, int offset, int length)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type Method 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
  nullInputStream, read, readAllBytes, readNBytes, readNBytes, transferTo
- 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)