Package org.apache.arrow.vector.ipc
Class ReadChannel
java.lang.Object
org.apache.arrow.vector.ipc.ReadChannel
- All Implemented Interfaces:
AutoCloseable
- Direct Known Subclasses:
SeekableReadChannel
Adapter around
ReadableByteChannel
that reads into ArrowBufs.-
Constructor Summary
-
Method Summary
-
Constructor Details
-
ReadChannel
-
-
Method Details
-
bytesRead
public long bytesRead() -
readFully
Reads bytes into buffer until it is full (buffer.remaining() == 0). Returns the number of bytes read which can be less than full if there are no more.- Parameters:
buffer
- The buffer to read to- Returns:
- the number of byte read
- Throws:
IOException
- if nit enough bytes left to read
-
readFully
Reads up to len into buffer. Returns bytes read.- Parameters:
buffer
- the buffer to read tolength
- the amount of bytes to read- Returns:
- the number of bytes read
- Throws:
IOException
- if nit enough bytes left to read
-
close
- Specified by:
close
in interfaceAutoCloseable
- Throws:
IOException
-