org.apache.flink.runtime.enricher

Class CustomTestFailureEnricherFactory

java.lang.Object

org.apache.flink.runtime.enricher.CustomTestFailureEnricherFactory

All Implemented Interfaces:

FailureEnricherFactory, Plugin

public class CustomTestFailureEnricherFactory
extends Object
implements FailureEnricherFactory

The factory of CustomTestFailureEnricher.

Constructor Summary

Constructors

Constructor and Description
CustomTestFailureEnricherFactory()

Method Summary

Modifier and Type	Method and Description
FailureEnricher	createFailureEnricher(Configuration conf) Construct a FailureEnricher.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.core.plugin.Plugin

configure, getClassLoader

Constructor Detail

CustomTestFailureEnricherFactory

public CustomTestFailureEnricherFactory()

Method Detail

createFailureEnricher

public FailureEnricher createFailureEnricher(Configuration conf)

Description copied from interface: FailureEnricherFactory

Construct a FailureEnricher.

Specified by:

createFailureEnricher in interface FailureEnricherFactory

Parameters:

conf - configuration for this failure enricher

Returns:

the FailureEnricher