org.apache.flink.runtime.metrics

Class ReporterSetup

java.lang.Object

org.apache.flink.runtime.metrics.ReporterSetup

public final class ReporterSetup
extends Object

Encapsulates everything needed for the instantiation and configuration of a MetricReporter.

Constructor Summary

Constructors

Constructor and Description
ReporterSetup(String name, MetricConfig configuration, MetricReporter reporter)

Method Summary

Modifier and Type	Method and Description
static ReporterSetup	forReporter(String reporterName, MetricConfig metricConfig, MetricReporter reporter)
static ReporterSetup	forReporter(String reporterName, MetricReporter reporter)
static List<ReporterSetup>	fromConfiguration(Configuration configuration, PluginManager pluginManager)
Optional<String>	getDelimiter()
Set<String>	getExcludedVariables()
Optional<String>	getIntervalSettings()
String	getName()
MetricReporter	getReporter()

Methods inherited from class java.lang.Object

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

Constructor Detail

ReporterSetup

public ReporterSetup(String name,
                     MetricConfig configuration,
                     MetricReporter reporter)

Method Detail

getDelimiter

public Optional<String> getDelimiter()

getIntervalSettings

public Optional<String> getIntervalSettings()

getExcludedVariables

public Set<String> getExcludedVariables()

getName

public String getName()

getReporter

public MetricReporter getReporter()

forReporter

@VisibleForTesting
public static ReporterSetup forReporter(String reporterName,
                                                           MetricReporter reporter)

forReporter

@VisibleForTesting
public static ReporterSetup forReporter(String reporterName,
                                                           MetricConfig metricConfig,
                                                           MetricReporter reporter)

fromConfiguration

public static List<ReporterSetup> fromConfiguration(Configuration configuration,
                                                    @Nullable
                                                    PluginManager pluginManager)