org.apache.flink.api.connector.source

Interface DynamicParallelismInference

All Known Implementing Classes:

FileSource, HiveSource

@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 and Description
static interface	DynamicParallelismInference.Context A context that provides dynamic parallelism decision infos.

Method Summary

Modifier and Type	Method and 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.