org.apache.paimon.memory

Class MemorySegment

java.lang.Object

org.apache.paimon.memory.MemorySegment

@Public
public final class MemorySegment
extends Object

This class represents a piece of memory.

Since:

0.4.0

Field Summary

Fields

Modifier and Type	Field and Description
static long	BYTE_ARRAY_BASE_OFFSET
static boolean	LITTLE_ENDIAN
static sun.misc.Unsafe	UNSAFE

Method Summary

Modifier and Type	Method and Description
static MemorySegment	allocateHeapMemory(int size)
static MemorySegment	allocateOffHeapMemory(int size)
int	compare(MemorySegment seg2, int offset1, int offset2, int len)
int	compare(MemorySegment seg2, int offset1, int offset2, int len1, int len2)
void	copyFromUnsafe(int offset, Object source, int sourcePointer, int numBytes)
void	copyTo(int offset, MemorySegment target, int targetOffset, int numBytes)
void	copyToUnsafe(int offset, Object target, int targetPointer, int numBytes)
boolean	equalTo(MemorySegment seg2, int offset1, int offset2, int length) Equals two memory segment regions.
void	get(DataOutput out, int offset, int length)
byte	get(int index)
void	get(int index, byte[] dst)
void	get(int index, byte[] dst, int offset, int length)
void	get(int offset, ByteBuffer target, int numBytes)
byte[]	getArray()
boolean	getBoolean(int index)
char	getChar(int index)
char	getCharBigEndian(int index)
char	getCharLittleEndian(int index)
double	getDouble(int index)
double	getDoubleBigEndian(int index)
double	getDoubleLittleEndian(int index)
float	getFloat(int index)
float	getFloatBigEndian(int index)
float	getFloatLittleEndian(int index)
byte[]	getHeapMemory() Get the heap byte array object.
int	getInt(int index)
int	getIntBigEndian(int index)
int	getIntLittleEndian(int index)
long	getLong(int index)
long	getLongBigEndian(int index)
long	getLongLittleEndian(int index)
short	getShort(int index)
short	getShortBigEndian(int index)
short	getShortLittleEndian(int index)
boolean	isOffHeap()
void	put(DataInput in, int offset, int length)
void	put(int index, byte b)
void	put(int index, byte[] src)
void	put(int index, byte[] src, int offset, int length)
void	put(int offset, ByteBuffer source, int numBytes)
void	putBoolean(int index, boolean value)
void	putChar(int index, char value)
void	putCharBigEndian(int index, char value)
void	putCharLittleEndian(int index, char value)
void	putDouble(int index, double value)
void	putDoubleBigEndian(int index, double value)
void	putDoubleLittleEndian(int index, double value)
void	putFloat(int index, float value)
void	putFloatBigEndian(int index, float value)
void	putFloatLittleEndian(int index, float value)
void	putInt(int index, int value)
void	putIntBigEndian(int index, int value)
void	putIntLittleEndian(int index, int value)
void	putLong(int index, long value)
void	putLongBigEndian(int index, long value)
void	putLongLittleEndian(int index, long value)
void	putShort(int index, short value)
void	putShortBigEndian(int index, short value)
void	putShortLittleEndian(int index, short value)
int	size()
void	swapBytes(byte[] tempBuffer, MemorySegment seg2, int offset1, int offset2, int len)
static MemorySegment	wrap(byte[] buffer)
ByteBuffer	wrap(int offset, int length)
static MemorySegment	wrapOffHeapMemory(ByteBuffer buffer)

Methods inherited from class java.lang.Object

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

Field Detail

UNSAFE

public static final sun.misc.Unsafe UNSAFE

BYTE_ARRAY_BASE_OFFSET

public static final long BYTE_ARRAY_BASE_OFFSET

LITTLE_ENDIAN

public static final boolean LITTLE_ENDIAN

Method Detail

wrap

public static MemorySegment wrap(byte[] buffer)

wrapOffHeapMemory

public static MemorySegment wrapOffHeapMemory(ByteBuffer buffer)

allocateHeapMemory

public static MemorySegment allocateHeapMemory(int size)

allocateOffHeapMemory

public static MemorySegment allocateOffHeapMemory(int size)

size

public int size()

isOffHeap

public boolean isOffHeap()

getArray

public byte[] getArray()

wrap

public ByteBuffer wrap(int offset,
                       int length)

get

public byte get(int index)

put

public void put(int index,
                byte b)

get

public void get(int index,
                byte[] dst)

put

public void put(int index,
                byte[] src)

get

public void get(int index,
                byte[] dst,
                int offset,
                int length)

put

public void put(int index,
                byte[] src,
                int offset,
                int length)

getBoolean

public boolean getBoolean(int index)

putBoolean

public void putBoolean(int index,
                       boolean value)

getChar

public char getChar(int index)

getCharLittleEndian

public char getCharLittleEndian(int index)

getCharBigEndian

public char getCharBigEndian(int index)

putChar

public void putChar(int index,
                    char value)

putCharLittleEndian

public void putCharLittleEndian(int index,
                                char value)

putCharBigEndian

public void putCharBigEndian(int index,
                             char value)

getShort

public short getShort(int index)

getShortLittleEndian

public short getShortLittleEndian(int index)

getShortBigEndian

public short getShortBigEndian(int index)

putShort

public void putShort(int index,
                     short value)

putShortLittleEndian

public void putShortLittleEndian(int index,
                                 short value)

putShortBigEndian

public void putShortBigEndian(int index,
                              short value)

getInt

public int getInt(int index)

getIntLittleEndian

public int getIntLittleEndian(int index)

getIntBigEndian

public int getIntBigEndian(int index)

putInt

public void putInt(int index,
                   int value)

putIntLittleEndian

public void putIntLittleEndian(int index,
                               int value)

putIntBigEndian

public void putIntBigEndian(int index,
                            int value)

getLong

public long getLong(int index)

getLongLittleEndian

public long getLongLittleEndian(int index)

getLongBigEndian

public long getLongBigEndian(int index)

putLong

public void putLong(int index,
                    long value)

putLongLittleEndian

public void putLongLittleEndian(int index,
                                long value)

putLongBigEndian

public void putLongBigEndian(int index,
                             long value)

getFloat

public float getFloat(int index)

getFloatLittleEndian

public float getFloatLittleEndian(int index)

getFloatBigEndian

public float getFloatBigEndian(int index)

putFloat

public void putFloat(int index,
                     float value)

putFloatLittleEndian

public void putFloatLittleEndian(int index,
                                 float value)

putFloatBigEndian

public void putFloatBigEndian(int index,
                              float value)

getDouble

public double getDouble(int index)

getDoubleLittleEndian

public double getDoubleLittleEndian(int index)

getDoubleBigEndian

public double getDoubleBigEndian(int index)

putDouble

public void putDouble(int index,
                      double value)

putDoubleLittleEndian

public void putDoubleLittleEndian(int index,
                                  double value)

putDoubleBigEndian

public void putDoubleBigEndian(int index,
                               double value)

get

public void get(DataOutput out,
                int offset,
                int length)
         throws IOException

Throws:

IOException

put

public void put(DataInput in,
                int offset,
                int length)
         throws IOException

Throws:

IOException

get

public void get(int offset,
                ByteBuffer target,
                int numBytes)

put

public void put(int offset,
                ByteBuffer source,
                int numBytes)

copyTo

public void copyTo(int offset,
                   MemorySegment target,
                   int targetOffset,
                   int numBytes)

copyToUnsafe

public void copyToUnsafe(int offset,
                         Object target,
                         int targetPointer,
                         int numBytes)

copyFromUnsafe

public void copyFromUnsafe(int offset,
                           Object source,
                           int sourcePointer,
                           int numBytes)

compare

public int compare(MemorySegment seg2,
                   int offset1,
                   int offset2,
                   int len)

compare

public int compare(MemorySegment seg2,
                   int offset1,
                   int offset2,
                   int len1,
                   int len2)

swapBytes

public void swapBytes(byte[] tempBuffer,
                      MemorySegment seg2,
                      int offset1,
                      int offset2,
                      int len)

equalTo

public boolean equalTo(MemorySegment seg2,
                       int offset1,
                       int offset2,
                       int length)

Equals two memory segment regions.

Parameters:

seg2 - Segment to equal this segment with

offset1 - Offset of this segment to start equaling

offset2 - Offset of seg2 to start equaling

length - Length of the equaled memory region

Returns:

true if equal, false otherwise

getHeapMemory

public byte[] getHeapMemory()

Get the heap byte array object.

Returns:

Return non-null if the memory is on the heap, and return null if the memory if off the heap.