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:
java.io.Closeable
,java.lang.AutoCloseable
public abstract class ByteBufferInputStream extends SeekableInputStream
-
-
Constructor Summary
Constructors Constructor Description ByteBufferInputStream()
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description abstract int
read(java.nio.ByteBuffer out)
abstract java.util.List<java.nio.ByteBuffer>
remainingBuffers()
ByteBufferInputStream
remainingStream()
void
skipFully(long length)
abstract java.nio.ByteBuffer
slice(int length)
abstract java.util.List<java.nio.ByteBuffer>
sliceBuffers(long length)
ByteBufferInputStream
sliceStream(long length)
static ByteBufferInputStream
wrap(java.nio.ByteBuffer... buffers)
static ByteBufferInputStream
wrap(java.util.List<java.nio.ByteBuffer> buffers)
-
Methods inherited from class org.apache.iceberg.io.SeekableInputStream
getPos, seek
-
-
-
-
Method Detail
-
wrap
public static ByteBufferInputStream wrap(java.nio.ByteBuffer... buffers)
-
wrap
public static ByteBufferInputStream wrap(java.util.List<java.nio.ByteBuffer> buffers)
-
skipFully
public void skipFully(long length) throws java.io.IOException
- Throws:
java.io.IOException
-
read
public abstract int read(java.nio.ByteBuffer out)
-
slice
public abstract java.nio.ByteBuffer slice(int length) throws java.io.EOFException
- Throws:
java.io.EOFException
-
sliceBuffers
public abstract java.util.List<java.nio.ByteBuffer> sliceBuffers(long length) throws java.io.EOFException
- Throws:
java.io.EOFException
-
sliceStream
public ByteBufferInputStream sliceStream(long length) throws java.io.EOFException
- Throws:
java.io.EOFException
-
remainingBuffers
public abstract java.util.List<java.nio.ByteBuffer> remainingBuffers()
-
remainingStream
public ByteBufferInputStream remainingStream()
-
-