DynamicParallelismInference (Flink : Core 1.20.2-cp1 API)

```
@PublicEvolving
public interface DynamicParallelismInference
```
Sources that implement this interface will dynamically infer the source’s parallelism when it is unspecified. It will be invoked during the Flink runtime before the source vertex is scheduled.
The implementations typically work together with the Source and are currently only effective for batch jobs that use the adaptive batch scheduler.

Nested Class Summary

Nested Classes
Modifier and Type Interface Description

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
`int`	`inferParallelism(DynamicParallelismInference.Context context)`	The method is invoked on the master (JobManager) before the initialization of the source vertex.

- Method Detail
  - inferParallelism
```
int inferParallelism(DynamicParallelismInference.Context context)
```
    The method is invoked on the master (JobManager) before the initialization of the source vertex.
    
    Parameters:
    
    context - The context to get dynamic parallelism decision infos.