Class BinaryStreams
- java.lang.Object
-
- org.apache.ignite.internal.binary.streams.BinaryStreams
-
public class BinaryStreams extends Object
Utility class to provide static methods to createBinaryInputStreamorBinaryOutputStreamin different modes.
-
-
Constructor Summary
Constructors Constructor Description BinaryStreams()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static BinaryOutputStreamcreatePooledOutputStream(int cap, boolean disableAutoClose)static BinaryInputStreaminputStream(byte[] data)Create stream with pointer set at the given position.static BinaryInputStreaminputStream(byte[] data, int pos)Create stream with pointer set at the given position.static BinaryInputStreaminputStream(long ptr, int cap)static BinaryInputStreaminputStream(long ptr, int cap, boolean forceHeap)static BinaryInputStreaminputStream(ByteBuffer buf)static BinaryOutputStreamoutputStream(int cap)static BinaryOutputStreamoutputStream(int cap, BinaryMemoryAllocatorChunk chunk)static BinaryMemoryAllocatorChunkthreadLocalChunk()
-
-
-
Method Detail
-
inputStream
public static BinaryInputStream inputStream(byte[] data, int pos)
Create stream with pointer set at the given position.- Parameters:
data- Data.pos- Position.- Returns:
- Stream.
-
inputStream
public static BinaryInputStream inputStream(byte[] data)
Create stream with pointer set at the given position.- Parameters:
data- Data.- Returns:
- Stream.
-
inputStream
public static BinaryInputStream inputStream(ByteBuffer buf)
- Parameters:
buf- Buffer to wrap.- Returns:
- Stream.
-
inputStream
public static BinaryInputStream inputStream(long ptr, int cap)
- Parameters:
ptr- Pointer.cap- Capacity.- Returns:
- Stream.
-
inputStream
public static BinaryInputStream inputStream(long ptr, int cap, boolean forceHeap)
- Parameters:
ptr- Pointer.cap- Capacity.forceHeap- IftruemethodBinaryStream.offheapPointer()returns 0 and unmarshalling will create heap-based objects.- Returns:
- Stream.
-
createPooledOutputStream
public static BinaryOutputStream createPooledOutputStream(int cap, boolean disableAutoClose)
- Parameters:
cap- Capacity.disableAutoClose- Whether to disable resource release inBinaryOutputStream.close()method so that an explicitBinaryOutputStream.release()call is required.- Returns:
- Binary output stream data.
-
outputStream
public static BinaryOutputStream outputStream(int cap)
- Parameters:
cap- Capacity.- Returns:
- Binary output stream data.
-
outputStream
public static BinaryOutputStream outputStream(int cap, BinaryMemoryAllocatorChunk chunk)
- Parameters:
cap- Capacity.chunk- Memory allocator chunk.- Returns:
- Binary output stream.
-
threadLocalChunk
public static BinaryMemoryAllocatorChunk threadLocalChunk()
- Returns:
- Thread local binary memory allocator.
-
-