Interface FailureEnricher.Context

  • Enclosing interface:
    FailureEnricher

    @Experimental
    public static interface FailureEnricher.Context
    An interface used by the FailureEnricher. Context includes an executor pool for the enrichers to run heavy operations, the Classloader used for code gen, and other metadata.
    • 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 user ClassLoader used 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