org.apache.paimon.flink.utils

Class ManagedMemoryUtils

java.lang.Object

org.apache.paimon.flink.utils.ManagedMemoryUtils

public class ManagedMemoryUtils
extends Object

Utils for using Flink managed memory.

Constructor Summary

Constructors

Constructor and Description
ManagedMemoryUtils()

Method Summary

Modifier and Type	Method and Description
static long	computeManagedMemory(org.apache.flink.streaming.api.operators.AbstractStreamOperator<?> operator)
static void	declareManagedMemory(org.apache.flink.streaming.api.datastream.DataStream<?> dataStream, MemorySize memorySize)

Methods inherited from class java.lang.Object

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

Constructor Detail

ManagedMemoryUtils

public ManagedMemoryUtils()

Method Detail

declareManagedMemory

public static void declareManagedMemory(org.apache.flink.streaming.api.datastream.DataStream<?> dataStream,
                                        MemorySize memorySize)

computeManagedMemory

public static long computeManagedMemory(org.apache.flink.streaming.api.operators.AbstractStreamOperator<?> operator)