StatsDReporter (Flink : Metrics : StatsD 1.18.1-cp5 API)

java.lang.Object
- org.apache.flink.metrics.reporter.AbstractReporter
- - org.apache.flink.metrics.statsd.StatsDReporter

All Implemented Interfaces:

org.apache.flink.metrics.CharacterFilter, org.apache.flink.metrics.reporter.MetricReporter, org.apache.flink.metrics.reporter.Scheduled
```
@PublicEvolving
public class StatsDReporter
extends org.apache.flink.metrics.reporter.AbstractReporter
implements org.apache.flink.metrics.reporter.Scheduled
```
Largely based on the StatsDReporter class by ReadyTalk.
https://github.com/ReadyTalk/metrics-statsd/blob/master/metrics3-statsd/src/main/java/com/readytalk/metrics/StatsDReporter.java
Ported since it was not present in maven central.

Field Summary

Fields
Modifier and Type Field Description

static String ARG_HOST

static String ARG_PORT
- Fields inherited from class org.apache.flink.metrics.reporter.AbstractReporter
  counters, gauges, histograms, log, meters
- Fields inherited from interface org.apache.flink.metrics.CharacterFilter
  NO_OP_FILTER

Constructor Summary

Constructors
Constructor Description

StatsDReporter()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`close()`
`String`	`filterCharacters(String input)`
`void`	`open(org.apache.flink.metrics.MetricConfig config)`
`void`	`report()`

Methods inherited from class org.apache.flink.metrics.reporter.AbstractReporter
notifyOfAddedMetric, notifyOfRemovedMetric

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - ARG_HOST
```
public static final String ARG_HOST
```
    See Also:
    
    Constant Field Values
  - ARG_PORT
```
public static final String ARG_PORT
```
    See Also:
    
    Constant Field Values
- Constructor Detail
  - StatsDReporter
```
public StatsDReporter()
```
- Method Detail
  - open
```
public void open(org.apache.flink.metrics.MetricConfig config)
```
    Specified by:
    
    open in interface org.apache.flink.metrics.reporter.MetricReporter
  - close
```
public void close()
```
    Specified by:
    
    close in interface org.apache.flink.metrics.reporter.MetricReporter
  - report
```
public void report()
```
    Specified by:
    
    report in interface org.apache.flink.metrics.reporter.Scheduled
  - filterCharacters
```
public String filterCharacters(String input)
```
    Specified by:
    
    filterCharacters in interface org.apache.flink.metrics.CharacterFilter