Package org.nuxeo.ecm.core.bulk.introspection

Class StreamIntrospectionToStreamFlattenMetrics.StreamFlattenMetricsBuilder

java.lang.Object

org.nuxeo.ecm.core.bulk.introspection.StreamIntrospectionToStreamFlattenMetrics.StreamFlattenMetricsBuilder

Enclosing class:

StreamIntrospectionToStreamFlattenMetrics

protected static class StreamIntrospectionToStreamFlattenMetrics.StreamFlattenMetricsBuilder
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected final Map<org.apache.commons.lang3.tuple.Pair<String,String>,StreamIntrospectionToStreamFlattenMetrics.ComputationMetricBuilder>	computationMetrics
protected Instant	date
protected final Map<String,StreamIntrospectionToStreamFlattenMetrics.NodeMetricBuilder>	nodeMetrics
protected final Map<String,StreamIntrospectionToStreamFlattenMetrics.StreamMetricBuilder>	streamMetrics

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	StreamFlattenMetricsBuilder()

Method Summary

Modifier and Type	Method	Description
StreamFlattenMetrics	build()
StreamIntrospectionToStreamFlattenMetrics.StreamFlattenMetricsBuilder	dateIfAfter(Instant date)
StreamIntrospectionToStreamFlattenMetrics.ComputationMetricBuilder	getOrComputeComputationMetricBuilder(String nodeId, String computationName)
StreamIntrospectionToStreamFlattenMetrics.NodeMetricBuilder	getOrComputeNodeMetricBuilder(String nodeId)
StreamIntrospectionToStreamFlattenMetrics.StreamComputationMetricBuilder	getOrComputeStreamComputationMetricBuilder(String streamName, String computationName)
StreamIntrospectionToStreamFlattenMetrics.StreamMetricBuilder	getOrComputeStreamMetricBuilder(String streamName)

Methods inherited from class java.lang.Object

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

Field Details

streamMetrics

protected final Map<String,StreamIntrospectionToStreamFlattenMetrics.StreamMetricBuilder> streamMetrics

computationMetrics

protected final Map<org.apache.commons.lang3.tuple.Pair<String,String>,StreamIntrospectionToStreamFlattenMetrics.ComputationMetricBuilder> computationMetrics

nodeMetrics

protected final Map<String,StreamIntrospectionToStreamFlattenMetrics.NodeMetricBuilder> nodeMetrics

date

protected Instant date

Constructor Details

StreamFlattenMetricsBuilder

protected StreamFlattenMetricsBuilder()

Method Details

dateIfAfter

public StreamIntrospectionToStreamFlattenMetrics.StreamFlattenMetricsBuilder dateIfAfter(Instant date)

getOrComputeStreamMetricBuilder

public StreamIntrospectionToStreamFlattenMetrics.StreamMetricBuilder getOrComputeStreamMetricBuilder(String streamName)

getOrComputeStreamComputationMetricBuilder

public StreamIntrospectionToStreamFlattenMetrics.StreamComputationMetricBuilder getOrComputeStreamComputationMetricBuilder(String streamName,
 String computationName)

getOrComputeComputationMetricBuilder

public StreamIntrospectionToStreamFlattenMetrics.ComputationMetricBuilder getOrComputeComputationMetricBuilder(String nodeId,
 String computationName)

getOrComputeNodeMetricBuilder

public StreamIntrospectionToStreamFlattenMetrics.NodeMetricBuilder getOrComputeNodeMetricBuilder(String nodeId)

build

public StreamFlattenMetrics build()