@Experimental public static interface FailureEnricher.Context
FailureEnricher
. Context includes an executor pool for the
enrichers to run heavy operations, the Classloader used for code gen, and other metadata.Modifier and Type | Interface and Description |
---|---|
static class |
FailureEnricher.Context.FailureType
Type of failure.
|
Modifier and Type | Method and Description |
---|---|
FailureEnricher.Context.FailureType |
getFailureType()
Return the type of the failure e.g., global failure that happened in the scheduler
context.
|
Executor |
getIOExecutor()
Get an Executor pool for the Enrichers to run async operations that can potentially be
IO-heavy.
|
default JobID |
getJobId()
Deprecated.
This method is deprecated since Flink 1.19. All metadata about the job should
be provided uniformly by
getJobInfo() . |
JobInfo |
getJobInfo()
Get the meta information of current job.
|
default String |
getJobName()
Deprecated.
This method is deprecated since Flink 1.19. All metadata about the job should
be provided uniformly by
getJobInfo() . |
MetricGroup |
getMetricGroup()
Get the metric group of the JobMaster.
|
ClassLoader |
getUserClassLoader()
Get the user
ClassLoader used for code generation, UDF loading and other
operations requiring reflections on user code. |
@Deprecated default JobID getJobId()
getJobInfo()
.@Deprecated default String getJobName()
getJobInfo()
.MetricGroup getMetricGroup()
FailureEnricher.Context.FailureType getFailureType()
ClassLoader getUserClassLoader()
ClassLoader
used for code generation, UDF loading and other
operations requiring reflections on user code.Executor getIOExecutor()
@PublicEvolving JobInfo getJobInfo()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.