Uses of Class
org.apache.flink.core.memory.MemorySegment

Packages that use MemorySegment

Package	Description
org.apache.flink.api.common.typeutils
org.apache.flink.api.common.typeutils.base
org.apache.flink.api.common.typeutils.base.array
org.apache.flink.api.java.typeutils.runtime
org.apache.flink.core.memory
org.apache.flink.types

Uses of MemorySegment in org.apache.flink.api.common.typeutils

Methods in org.apache.flink.api.common.typeutils with parameters of type MemorySegment

Modifier and Type	Method	Description
abstract void	TypeComparator.putNormalizedKey(T record, MemorySegment target, int offset, int numBytes)	Writes a normalized key for the given record into the target byte array, starting at the specified position and writing exactly the given number of bytes.

Uses of MemorySegment in org.apache.flink.api.common.typeutils.base

Methods in org.apache.flink.api.common.typeutils.base with parameters of type MemorySegment

Modifier and Type	Method	Description
static void	NormalizedKeyUtil.putBooleanNormalizedKey(boolean value, MemorySegment target, int offset, int numBytes)
static void	NormalizedKeyUtil.putByteNormalizedKey(byte value, MemorySegment target, int offset, int numBytes)
static void	NormalizedKeyUtil.putCharNormalizedKey(char value, MemorySegment target, int offset, int numBytes)
static void	NormalizedKeyUtil.putIntNormalizedKey(int iValue, MemorySegment target, int offset, int numBytes)
static void	NormalizedKeyUtil.putLongNormalizedKey(long lValue, MemorySegment target, int offset, int numBytes)
void	BigDecComparator.putNormalizedKey(BigDecimal record, MemorySegment target, int offset, int len)	Adds a normalized key containing a normalized order of magnitude of the given record.
void	BigIntComparator.putNormalizedKey(BigInteger record, MemorySegment target, int offset, int len)	Adds a normalized key containing the normalized number of bits and MSBs of the given record.
void	BooleanComparator.putNormalizedKey(Boolean value, MemorySegment target, int offset, int numBytes)
void	BooleanValueComparator.putNormalizedKey(BooleanValue record, MemorySegment target, int offset, int numBytes)
void	ByteComparator.putNormalizedKey(Byte value, MemorySegment target, int offset, int numBytes)
void	ByteValueComparator.putNormalizedKey(ByteValue record, MemorySegment target, int offset, int numBytes)
void	CharComparator.putNormalizedKey(Character value, MemorySegment target, int offset, int numBytes)
void	CharValueComparator.putNormalizedKey(CharValue record, MemorySegment target, int offset, int numBytes)
void	DateComparator.putNormalizedKey(Date record, MemorySegment target, int offset, int numBytes)
void	DoubleComparator.putNormalizedKey(Double value, MemorySegment target, int offset, int numBytes)
void	DoubleValueComparator.putNormalizedKey(DoubleValue record, MemorySegment target, int offset, int numBytes)
void	EnumComparator.putNormalizedKey(T iValue, MemorySegment target, int offset, int numBytes)
void	FloatComparator.putNormalizedKey(Float value, MemorySegment target, int offset, int numBytes)
void	FloatValueComparator.putNormalizedKey(FloatValue record, MemorySegment target, int offset, int numBytes)
void	InstantComparator.putNormalizedKey(java.time.Instant record, MemorySegment target, int offset, int numBytes)
void	IntComparator.putNormalizedKey(Integer iValue, MemorySegment target, int offset, int numBytes)
void	IntValueComparator.putNormalizedKey(IntValue record, MemorySegment target, int offset, int numBytes)
void	LocalDateComparator.putNormalizedKey(java.time.LocalDate record, MemorySegment target, int offset, int numBytes)
void	LocalDateTimeComparator.putNormalizedKey(java.time.LocalDateTime record, MemorySegment target, int offset, int numBytes)
void	LocalTimeComparator.putNormalizedKey(java.time.LocalTime record, MemorySegment target, int offset, int numBytes)
void	LongComparator.putNormalizedKey(Long lValue, MemorySegment target, int offset, int numBytes)
void	LongValueComparator.putNormalizedKey(LongValue record, MemorySegment target, int offset, int numBytes)
void	NullValueComparator.putNormalizedKey(NullValue record, MemorySegment target, int offset, int numBytes)
void	ShortComparator.putNormalizedKey(Short value, MemorySegment target, int offset, int numBytes)
void	ShortValueComparator.putNormalizedKey(ShortValue record, MemorySegment target, int offset, int numBytes)
void	SqlTimestampComparator.putNormalizedKey(Date record, MemorySegment target, int offset, int numBytes)
void	StringComparator.putNormalizedKey(String record, MemorySegment target, int offset, int len)
void	StringValueComparator.putNormalizedKey(StringValue record, MemorySegment target, int offset, int numBytes)
static void	DateComparator.putNormalizedKeyDate(Date record, MemorySegment target, int offset, int numBytes)
static void	LocalDateComparator.putNormalizedKeyLocalDate(java.time.LocalDate record, MemorySegment target, int offset, int numBytes)
static void	LocalTimeComparator.putNormalizedKeyLocalTime(java.time.LocalTime record, MemorySegment target, int offset, int numBytes)
static void	NormalizedKeyUtil.putShortNormalizedKey(short value, MemorySegment target, int offset, int numBytes)
static void	NormalizedKeyUtil.putUnsignedIntegerNormalizedKey(int value, MemorySegment target, int offset, int numBytes)
static void	NormalizedKeyUtil.putUnsignedLongNormalizedKey(long value, MemorySegment target, int offset, int numBytes)

Uses of MemorySegment in org.apache.flink.api.common.typeutils.base.array

Methods in org.apache.flink.api.common.typeutils.base.array with parameters of type MemorySegment

Modifier and Type	Method	Description
void	PrimitiveArrayComparator.putNormalizedKey(T record, MemorySegment target, int offset, int numBytes)

Uses of MemorySegment in org.apache.flink.api.java.typeutils.runtime

Methods in org.apache.flink.api.java.typeutils.runtime with parameters of type MemorySegment

Modifier and Type	Method	Description
void	CopyableValueComparator.putNormalizedKey(T record, MemorySegment target, int offset, int numBytes)
void	GenericTypeComparator.putNormalizedKey(T record, MemorySegment target, int offset, int numBytes)
void	NullAwareComparator.putNormalizedKey(T record, MemorySegment target, int offset, int numBytes)
void	PojoComparator.putNormalizedKey(T value, MemorySegment target, int offset, int numBytes)
void	RowComparator.putNormalizedKey(Row record, MemorySegment target, int offset, int numBytes)
void	TupleComparator.putNormalizedKey(T value, MemorySegment target, int offset, int numBytes)
void	ValueComparator.putNormalizedKey(T record, MemorySegment target, int offset, int numBytes)

Uses of MemorySegment in org.apache.flink.core.memory

Methods in org.apache.flink.core.memory that return MemorySegment

Modifier and Type	Method	Description
static MemorySegment	MemorySegmentFactory.allocateOffHeapUnsafeMemory(int size)
static MemorySegment	MemorySegmentFactory.allocateOffHeapUnsafeMemory(int size, Object owner, Runnable customCleanupAction)	Allocates an off-heap unsafe memory and creates a new memory segment to represent that memory.
static MemorySegment	MemorySegmentFactory.allocateUnpooledOffHeapMemory(int size)	Allocates some unpooled off-heap memory and creates a new memory segment that represents that memory.
static MemorySegment	MemorySegmentFactory.allocateUnpooledOffHeapMemory(int size, Object owner)	Allocates some unpooled off-heap memory and creates a new memory segment that represents that memory.
static MemorySegment	MemorySegmentFactory.allocateUnpooledSegment(int size)	Allocates some unpooled memory and creates a new memory segment that represents that memory.
static MemorySegment	MemorySegmentFactory.allocateUnpooledSegment(int size, Object owner)	Allocates some unpooled memory and creates a new memory segment that represents that memory.
MemorySegment	MemorySegmentSource.nextSegment()	Gets the next memory segment.
static MemorySegment	MemorySegmentFactory.wrap(byte[] buffer)	Creates a new memory segment that targets the given heap memory region.
static MemorySegment	MemorySegmentFactory.wrapCopy(byte[] bytes, int start, int end)	Copies the given heap memory region and creates a new memory segment wrapping it.
static MemorySegment	MemorySegmentFactory.wrapInt(int value)	Wraps the four bytes representing the given number with a MemorySegment.
static MemorySegment	MemorySegmentFactory.wrapOffHeapMemory(ByteBuffer memory)	Creates a memory segment that wraps the off-heap memory backing the given ByteBuffer.

Methods in org.apache.flink.core.memory that return types with arguments of type MemorySegment

Modifier and Type	Method	Description
Collection<MemorySegment>	MemorySegmentProvider.requestUnpooledMemorySegments(int numberOfSegmentsToRequest)

Methods in org.apache.flink.core.memory with parameters of type MemorySegment

Modifier and Type	Method	Description
int	MemorySegment.compare(MemorySegment seg2, int offset1, int offset2, int len)	Compares two memory segment regions.
int	MemorySegment.compare(MemorySegment seg2, int offset1, int offset2, int len1, int len2)	Compares two memory segment regions with different length.
void	MemorySegment.copyTo(int offset, MemorySegment target, int targetOffset, int numBytes)	Bulk copy method.
boolean	MemorySegment.equalTo(MemorySegment seg2, int offset1, int offset2, int length)	Equals two memory segment regions.
void	MemorySegmentInputStreamWithPos.setSegment(MemorySegment segment, int offset, int length)
void	MemorySegment.swapBytes(byte[] tempBuffer, MemorySegment seg2, int offset1, int offset2, int len)	Swaps bytes between two memory segments, using the given auxiliary buffer.
void	DataOutputSerializer.write(MemorySegment segment, int off, int len)
void	MemorySegmentWritable.write(MemorySegment segment, int off, int len)	Writes len bytes from memory segment segment starting at offset off, in order, to the output.

Method parameters in org.apache.flink.core.memory with type arguments of type MemorySegment

Modifier and Type	Method	Description
void	MemorySegmentProvider.recycleUnpooledMemorySegments(Collection<MemorySegment> segments)

Constructors in org.apache.flink.core.memory with parameters of type MemorySegment

Constructor	Description
MemorySegmentInputStreamWithPos(MemorySegment segment, int offset, int length)

Uses of MemorySegment in org.apache.flink.types

Methods in org.apache.flink.types with parameters of type MemorySegment

Modifier and Type	Method	Description
void	BooleanValue.copyNormalizedKey(MemorySegment target, int offset, int len)
void	ByteValue.copyNormalizedKey(MemorySegment target, int offset, int len)
void	CharValue.copyNormalizedKey(MemorySegment target, int offset, int len)
void	IntValue.copyNormalizedKey(MemorySegment target, int offset, int len)
void	LongValue.copyNormalizedKey(MemorySegment target, int offset, int len)
void	NormalizableKey.copyNormalizedKey(MemorySegment memory, int offset, int len)	Writes a normalized key for the given record into the target byte array, starting at the specified position an writing exactly the given number of bytes.
void	NullValue.copyNormalizedKey(MemorySegment target, int offset, int len)
void	ShortValue.copyNormalizedKey(MemorySegment target, int offset, int len)
void	StringValue.copyNormalizedKey(MemorySegment target, int offset, int len)