org.apache.flink.api.connector.source

Interface DynamicParallelismInference.Context

Enclosing interface:

DynamicParallelismInference

@PublicEvolving
public static interface DynamicParallelismInference.Context

A context that provides dynamic parallelism decision infos.

Method Summary

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