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.JobIDgetJobId()Get the ID of the job.StringgetJobName()Get the name of the 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
-
getJobId
JobID getJobId()
Get the ID of the job.- Returns:
- the ID of the job
-
getJobName
String getJobName()
Get the name of the job.- Returns:
- the name of the job
-
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
-
-