org.apache.flink.runtime.jobgraph

Interface JobVertex.InitializeOnMasterContext

All Known Implementing Classes:

SimpleInitializeOnMasterContext

Enclosing class:

JobVertex

public static interface JobVertex.InitializeOnMasterContext

Method Summary

Modifier and Type	Method and Description
ClassLoader	getClassLoader() The class loader for user defined code.
int	getExecutionParallelism() The actual parallelism this vertex will be run with.

Method Detail

getClassLoader

ClassLoader getClassLoader()

The class loader for user defined code.

getExecutionParallelism

int getExecutionParallelism()

The actual parallelism this vertex will be run with. In contrast, the JobVertex.getParallelism() is the original parallelism set when creating the JobGraph and might be updated e.g. by the AdaptiveScheduler.