Package | Description |
---|---|
org.apache.flink.api.dag | |
org.apache.flink.core.memory | |
org.apache.flink.runtime.util.config.memory | |
org.apache.flink.streaming.api.graph |
Modifier and Type | Method and Description |
---|---|
Map<ManagedMemoryUseCase,Integer> |
Transformation.getManagedMemoryOperatorScopeUseCaseWeights()
Get operator scope use cases that this transformation needs managed memory for, and the
use-case-specific weights for this transformation.
|
Set<ManagedMemoryUseCase> |
Transformation.getManagedMemorySlotScopeUseCases()
Get slot scope use cases that this transformation needs managed memory for.
|
Modifier and Type | Method and Description |
---|---|
Optional<Integer> |
Transformation.declareManagedMemoryUseCaseAtOperatorScope(ManagedMemoryUseCase managedMemoryUseCase,
int weight)
Declares that this transformation contains certain operator scope managed memory use case.
|
void |
Transformation.declareManagedMemoryUseCaseAtSlotScope(ManagedMemoryUseCase managedMemoryUseCase)
Declares that this transformation contains certain slot scope managed memory use case.
|
Modifier and Type | Method and Description |
---|---|
static ManagedMemoryUseCase |
ManagedMemoryUseCase.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static ManagedMemoryUseCase[] |
ManagedMemoryUseCase.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
static double |
ManagedMemoryUtils.convertToFractionOfSlot(ManagedMemoryUseCase useCase,
double fractionOfUseCase,
Set<ManagedMemoryUseCase> allUseCases,
Configuration jobConfig,
Configuration clusterConfig,
Optional<Boolean> stateBackendFromApplicationUsesManagedMemory,
ClassLoader classLoader) |
Modifier and Type | Method and Description |
---|---|
static double |
ManagedMemoryUtils.convertToFractionOfSlot(ManagedMemoryUseCase useCase,
double fractionOfUseCase,
Set<ManagedMemoryUseCase> allUseCases,
Configuration jobConfig,
Configuration clusterConfig,
Optional<Boolean> stateBackendFromApplicationUsesManagedMemory,
ClassLoader classLoader) |
static void |
ManagedMemoryUtils.validateUseCaseWeightsNotConflict(Map<ManagedMemoryUseCase,Integer> weights1,
Map<ManagedMemoryUseCase,Integer> weights2) |
static void |
ManagedMemoryUtils.validateUseCaseWeightsNotConflict(Map<ManagedMemoryUseCase,Integer> weights1,
Map<ManagedMemoryUseCase,Integer> weights2) |
Modifier and Type | Method and Description |
---|---|
Map<ManagedMemoryUseCase,Integer> |
StreamNode.getManagedMemoryOperatorScopeUseCaseWeights() |
Set<ManagedMemoryUseCase> |
StreamNode.getManagedMemorySlotScopeUseCases() |
Modifier and Type | Method and Description |
---|---|
double |
StreamConfig.getManagedMemoryFractionOperatorUseCaseOfSlot(ManagedMemoryUseCase managedMemoryUseCase,
Configuration jobConfig,
Configuration taskManagerConfig,
ClassLoader cl)
Fraction of total managed memory in the slot that this operator should use for the given use
case.
|
void |
StreamConfig.setManagedMemoryFractionOperatorOfUseCase(ManagedMemoryUseCase managedMemoryUseCase,
double fraction)
Fraction of managed memory reserved for the given use case that this operator should use.
|
Modifier and Type | Method and Description |
---|---|
void |
StreamGraph.setManagedMemoryUseCaseWeights(int vertexID,
Map<ManagedMemoryUseCase,Integer> operatorScopeUseCaseWeights,
Set<ManagedMemoryUseCase> slotScopeUseCases) |
void |
StreamGraph.setManagedMemoryUseCaseWeights(int vertexID,
Map<ManagedMemoryUseCase,Integer> operatorScopeUseCaseWeights,
Set<ManagedMemoryUseCase> slotScopeUseCases) |
void |
StreamNode.setManagedMemoryUseCaseWeights(Map<ManagedMemoryUseCase,Integer> operatorScopeUseCaseWeights,
Set<ManagedMemoryUseCase> slotScopeUseCases) |
void |
StreamNode.setManagedMemoryUseCaseWeights(Map<ManagedMemoryUseCase,Integer> operatorScopeUseCaseWeights,
Set<ManagedMemoryUseCase> slotScopeUseCases) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.