Package org.apache.ignite.internal.binary.streams

Interface BinaryStreamsFactory

public interface BinaryStreamsFactory

Binary streams factory. Implementation loaded via ServiceLoader mechanism.

See Also:

CommonUtils.loadService(Class), BinaryStreams

Method Summary

Modifier and Type	Method	Description
BinaryOutputStream	createPooledOutputStream(int cap, boolean disableAutoClose)
BinaryInputStream	inputStream(byte[] data)	Create stream with pointer set at the given position.
BinaryInputStream	inputStream(byte[] data, int pos)	Create stream with pointer set at the given position.
BinaryInputStream	inputStream(long ptr, int cap)
BinaryInputStream	inputStream(long ptr, int cap, boolean forceHeap)
BinaryInputStream	inputStream(ByteBuffer buf)
BinaryOutputStream	outputStream(int cap)
BinaryOutputStream	outputStream(int cap, BinaryMemoryAllocatorChunk chunk)
BinaryMemoryAllocatorChunk	threadLocalChunk()

Method Detail

inputStream

BinaryInputStream inputStream(byte[] data,
                              int pos)

Create stream with pointer set at the given position.

Parameters:

data - Data.

pos - Position.

Returns:

Stream.

inputStream

BinaryInputStream inputStream(byte[] data)

Create stream with pointer set at the given position.

Parameters:

data - Data.

Returns:

Stream.

inputStream

BinaryInputStream inputStream(ByteBuffer buf)

Parameters:

buf - Buffer to wrap.

Returns:

Stream.

inputStream

BinaryInputStream inputStream(long ptr,
                              int cap)

Parameters:

ptr - Pointer.

cap - Capacity.

Returns:

Stream.

inputStream

BinaryInputStream inputStream(long ptr,
                              int cap,
                              boolean forceHeap)

Parameters:

ptr - Pointer.

cap - Capacity.

forceHeap - If true method BinaryStream.offheapPointer() returns 0 and unmarshalling will create heap-based objects.

Returns:

Stream.

createPooledOutputStream

BinaryOutputStream createPooledOutputStream(int cap,
                                            boolean disableAutoClose)

Parameters:

cap - Capacity.

disableAutoClose - Whether to disable resource release in BinaryOutputStream.close() method so that an explicit BinaryOutputStream.release() call is required.

Returns:

Binary output stream data.

outputStream

BinaryOutputStream outputStream(int cap)

Parameters:

cap - Capacity.

Returns:

Binary output stream data.

outputStream

BinaryOutputStream outputStream(int cap,
                                BinaryMemoryAllocatorChunk chunk)

Parameters:

cap - Capacity.

chunk - Memory allocator chunk.

Returns:

Binary output stream.

threadLocalChunk

BinaryMemoryAllocatorChunk threadLocalChunk()

Returns:

Thread local binary memory allocator.