public class DefaultFailureEnricherContext extends Object implements FailureEnricher.Context
FailureEnricher.Context
class.FailureEnricher.Context.FailureType
Modifier and Type | Method and Description |
---|---|
static FailureEnricher.Context |
forGlobalFailure(JobInfo jobInfo,
MetricGroup metricGroup,
Executor ioExecutor,
ClassLoader classLoader)
Factory method returning a Global failure Context for the given params.
|
static FailureEnricher.Context |
forTaskFailure(JobInfo jobInfo,
MetricGroup metricGroup,
Executor ioExecutor,
ClassLoader classLoader)
Factory method returning a Task failure Context for the given params.
|
static FailureEnricher.Context |
forTaskManagerFailure(JobInfo jobInfo,
MetricGroup metricGroup,
Executor ioExecutor,
ClassLoader classLoader)
Factory method returning a TaskManager failure Context for the given params.
|
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.
|
JobInfo |
getJobInfo()
Get the meta information of current job.
|
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. |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getJobId, getJobName
public MetricGroup getMetricGroup()
FailureEnricher.Context
getMetricGroup
in interface FailureEnricher.Context
public FailureEnricher.Context.FailureType getFailureType()
FailureEnricher.Context
getFailureType
in interface FailureEnricher.Context
public ClassLoader getUserClassLoader()
FailureEnricher.Context
ClassLoader
used for code generation, UDF loading and other
operations requiring reflections on user code.getUserClassLoader
in interface FailureEnricher.Context
public Executor getIOExecutor()
FailureEnricher.Context
getIOExecutor
in interface FailureEnricher.Context
public JobInfo getJobInfo()
FailureEnricher.Context
getJobInfo
in interface FailureEnricher.Context
public static FailureEnricher.Context forTaskFailure(JobInfo jobInfo, MetricGroup metricGroup, Executor ioExecutor, ClassLoader classLoader)
public static FailureEnricher.Context forGlobalFailure(JobInfo jobInfo, MetricGroup metricGroup, Executor ioExecutor, ClassLoader classLoader)
public static FailureEnricher.Context forTaskManagerFailure(JobInfo jobInfo, MetricGroup metricGroup, Executor ioExecutor, ClassLoader classLoader)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.