public class ManagedMemoryUtils extends Object
Constructor and Description |
---|
ManagedMemoryUtils() |
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) |
public static void declareManagedMemory(org.apache.flink.streaming.api.datastream.DataStream<?> dataStream, MemorySize memorySize)
public static long computeManagedMemory(org.apache.flink.streaming.api.operators.AbstractStreamOperator<?> operator)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.