Package org.apache.flink.core.failure
Interface FailureEnricher.Context
-
- Enclosing interface:
- FailureEnricher
@Experimental public static interface FailureEnricher.ContextAn interface used by theFailureEnricher. Context includes an executor pool for the enrichers to run heavy operations, the Classloader used for code gen, and other metadata.
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static classFailureEnricher.Context.FailureTypeType of failure.
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description FailureEnricher.Context.FailureTypegetFailureType()Return the type of the failure e.g., global failure that happened in the scheduler context.ExecutorgetIOExecutor()Get an Executor pool for the Enrichers to run async operations that can potentially be IO-heavy.JobInfogetJobInfo()Get the meta information of current job.org.apache.flink.metrics.MetricGroupgetMetricGroup()Get the metric group of the JobMaster.ClassLoadergetUserClassLoader()Get the userClassLoaderused for code generation, UDF loading and other operations requiring reflections on user code.
-
-
-
Method Detail
-
getMetricGroup
org.apache.flink.metrics.MetricGroup getMetricGroup()
Get the metric group of the JobMaster.- Returns:
- the metric group of the JobMaster
-
getFailureType
FailureEnricher.Context.FailureType getFailureType()
Return the type of the failure e.g., global failure that happened in the scheduler context.- Returns:
- FailureType
-
getUserClassLoader
ClassLoader getUserClassLoader()
Get the userClassLoaderused for code generation, UDF loading and other operations requiring reflections on user code.- Returns:
- the user ClassLoader
-
getIOExecutor
Executor getIOExecutor()
Get an Executor pool for the Enrichers to run async operations that can potentially be IO-heavy.- Returns:
- the Executor pool
-
getJobInfo
@PublicEvolving JobInfo getJobInfo()
Get the meta information of current job.- Returns:
- the job meta information.
-
-