Package org.apache.iceberg.io

Class ByteBufferInputStream

java.lang.Object

java.io.InputStream

org.apache.iceberg.io.SeekableInputStream

org.apache.iceberg.io.ByteBufferInputStream

All Implemented Interfaces:

Closeable, AutoCloseable

public abstract class ByteBufferInputStream
extends SeekableInputStream

Constructor Summary

Constructors

Constructor	Description
ByteBufferInputStream()

Method Summary

Modifier and Type	Method	Description
abstract int	read(ByteBuffer out)
abstract List<ByteBuffer>	remainingBuffers()
ByteBufferInputStream	remainingStream()
void	skipFully(long length)
abstract ByteBuffer	slice(int length)
abstract List<ByteBuffer>	sliceBuffers(long length)
ByteBufferInputStream	sliceStream(long length)
static ByteBufferInputStream	wrap(ByteBuffer... buffers)
static ByteBufferInputStream	wrap(List<ByteBuffer> buffers)

Methods inherited from class org.apache.iceberg.io.SeekableInputStream

getPos, seek

Methods inherited from class java.io.InputStream

available, close, mark, markSupported, nullInputStream, read, read, read, readAllBytes, readNBytes, readNBytes, reset, skip, skipNBytes, transferTo

Methods inherited from class java.lang.Object

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

Constructor Details

ByteBufferInputStream

public ByteBufferInputStream()

Method Details

wrap

public static ByteBufferInputStream wrap(ByteBuffer... buffers)

wrap

public static ByteBufferInputStream wrap(List<ByteBuffer> buffers)

skipFully

public void skipFully(long length)
               throws IOException

Throws:

IOException

read

public abstract int read(ByteBuffer out)

slice

public abstract ByteBuffer slice(int length)
                          throws EOFException

Throws:

EOFException

sliceBuffers

public abstract List<ByteBuffer> sliceBuffers(long length)
                                       throws EOFException

Throws:

EOFException

sliceStream

public ByteBufferInputStream sliceStream(long length)
                                  throws EOFException

Throws:

EOFException

remainingBuffers

public abstract List<ByteBuffer> remainingBuffers()

remainingStream

public ByteBufferInputStream remainingStream()