@Experimental(value=METRICS) public interface MetricsOptions extends PipelineOptions
PipelineOptions
that defines MetricsSink
specific options.Modifier and Type | Interface and Description |
---|---|
static class |
MetricsOptions.NoOpMetricsSink
A
DefaultValueFactory that obtains the class of the NoOpMetricsSink if it
exists on the classpath, and throws an exception otherwise. |
PipelineOptions.AtomicLongFactory, PipelineOptions.CheckEnabled, PipelineOptions.DirectRunner, PipelineOptions.JobNameFactory, PipelineOptions.UserAgentFactory
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getMetricsGraphiteHost() |
java.lang.Integer |
getMetricsGraphitePort() |
java.lang.String |
getMetricsHttpSinkUrl() |
java.lang.Long |
getMetricsPushPeriod() |
java.lang.Class<? extends MetricsSink> |
getMetricsSink() |
void |
setMetricsGraphiteHost(java.lang.String host) |
void |
setMetricsGraphitePort(java.lang.Integer port) |
void |
setMetricsHttpSinkUrl(java.lang.String metricsSink) |
void |
setMetricsPushPeriod(java.lang.Long period) |
void |
setMetricsSink(java.lang.Class<? extends MetricsSink> metricsSink) |
as, getJobName, getOptionsId, getRunner, getStableUniqueNames, getTempLocation, getUserAgent, outputRuntimeOptions, setJobName, setOptionsId, setRunner, setStableUniqueNames, setTempLocation, setUserAgent
populateDisplayData
@Default.InstanceFactory(value=MetricsOptions.NoOpMetricsSink.class) java.lang.Class<? extends MetricsSink> getMetricsSink()
void setMetricsSink(java.lang.Class<? extends MetricsSink> metricsSink)
@Default.Long(value=5L) java.lang.Long getMetricsPushPeriod()
void setMetricsPushPeriod(java.lang.Long period)
java.lang.String getMetricsHttpSinkUrl()
void setMetricsHttpSinkUrl(java.lang.String metricsSink)
java.lang.String getMetricsGraphiteHost()
void setMetricsGraphiteHost(java.lang.String host)
@Default.Integer(value=2003) java.lang.Integer getMetricsGraphitePort()
void setMetricsGraphitePort(java.lang.Integer port)