StreamMetricsProcessor (Nuxeo 2021.64.6 API Documentation)

java.lang.Object
- org.nuxeo.runtime.stream.StreamMetricsProcessor

All Implemented Interfaces:

StreamProcessorTopology
```
public class StreamMetricsProcessor
extends Object
implements StreamProcessorTopology
```
A processor fetching stream metrics populating Dropwizard metrics.

Since:

11.1

Field Summary

Fields
Modifier and Type	Field	Description
`protected static Duration`	`DEFAULT_INTERVAL`
`protected static String`	`STREAM_METRICS_FETCH_INTERVAL`
`protected static String`	`STREAM_METRICS_LIST`

Constructor Summary

Constructors
Constructor Description

StreamMetricsProcessor()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`Topology`	`getTopology(Map<String,String> options)`	Returns a Stream computation topology.
`protected List<String>`	`parseInputStreams(String streams)`

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

- Field Detail
  - DEFAULT_INTERVAL
```
protected static final Duration DEFAULT_INTERVAL
```
  - STREAM_METRICS_FETCH_INTERVAL
```
protected static final String STREAM_METRICS_FETCH_INTERVAL
```
    See Also:
    
    Constant Field Values
  - STREAM_METRICS_LIST
```
protected static final String STREAM_METRICS_LIST
```
    See Also:
    
    Constant Field Values
- Constructor Detail
  - StreamMetricsProcessor
```
public StreamMetricsProcessor()
```
- Method Detail
  - getTopology
```
public Topology getTopology(Map<String,String> options)
```
    Description copied from interface: StreamProcessorTopology
    
    Returns a Stream computation topology.
    
    Specified by:
    
    getTopology in interface StreamProcessorTopology
  - parseInputStreams
```
protected List<String> parseInputStreams(String streams)
```