DynamicParallelismInference.Context (Flink : Core 1.20.2-cp1 API)

Enclosing interface:

DynamicParallelismInference
```
@PublicEvolving
public static interface DynamicParallelismInference.Context
```
A context that provides dynamic parallelism decision infos.

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`long`	`getDataVolumePerTask()`	Get the average size of data volume (in bytes) to expect each task instance to process.
`Optional<DynamicFilteringInfo>`	`getDynamicFilteringInfo()`	Get the dynamic filtering info of the source vertex.
`int`	`getParallelismInferenceUpperBound()`	Get the upper bound for the inferred parallelism.

- Method Detail
  - getDynamicFilteringInfo
```
Optional<DynamicFilteringInfo> getDynamicFilteringInfo()
```
    Get the dynamic filtering info of the source vertex.
    
    Returns:
    
    the dynamic filter instance.
  - getParallelismInferenceUpperBound
```
int getParallelismInferenceUpperBound()
```
    Get the upper bound for the inferred parallelism.
    
    Returns:
    
    the upper bound for the inferred parallelism.
  - getDataVolumePerTask
```
long getDataVolumePerTask()
```
    Get the average size of data volume (in bytes) to expect each task instance to process.
    
    Returns:
    
    the data volume per task in bytes.