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

Class StreamIntrospectionToScaleActivity.ActiveComputationBuilder

java.lang.Object

org.nuxeo.ecm.core.bulk.introspection.StreamIntrospectionToScaleActivity.ActiveComputationBuilder

Enclosing class:

StreamIntrospectionToScaleActivity

protected static class StreamIntrospectionToScaleActivity.ActiveComputationBuilder
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected final Set<String>	computations
protected final Map<String,List<ScaleActivity.ActiveComputationNode>>	nodes
protected final Map<String,Map<String,StreamIntrospectionToScaleActivity.ActiveComputationStreamBuilder>>	streams

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ActiveComputationBuilder()

Method Summary

Modifier and Type	Method	Description
StreamIntrospectionToScaleActivity.ActiveComputationBuilder	addNode(String nodeId, int threads, Instant timestamp, StreamIntrospection.TimerMetric timerMetric)
StreamIntrospectionToScaleActivity.ActiveComputationBuilder	addStream(String computation, String stream, Integer partitions, long lag)
List<ScaleActivity.ActiveComputation>	build()
boolean	hasComputation(String computation)
StreamIntrospectionToScaleActivity.ActiveComputationBuilder	initComputation(String computation)
protected StreamIntrospectionToScaleActivity.ActiveComputationBuilder	populateStream(StreamIntrospection.ValueMetric metric, Consumer<StreamIntrospectionToScaleActivity.ActiveComputationStreamBuilder> consumer)
StreamIntrospectionToScaleActivity.ActiveComputationBuilder	populateStreamEnd(StreamIntrospection.ValueMetric metric)
StreamIntrospectionToScaleActivity.ActiveComputationBuilder	populateStreamLatency(StreamIntrospection.ValueMetric metric)

Methods inherited from class java.lang.Object

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

Field Details

computations

protected final Set<String> computations

streams

protected final Map<String,Map<String,StreamIntrospectionToScaleActivity.ActiveComputationStreamBuilder>> streams

nodes

protected final Map<String,List<ScaleActivity.ActiveComputationNode>> nodes

Constructor Details

ActiveComputationBuilder

protected ActiveComputationBuilder()

Method Details

initComputation

public StreamIntrospectionToScaleActivity.ActiveComputationBuilder initComputation(String computation)

addStream

public StreamIntrospectionToScaleActivity.ActiveComputationBuilder addStream(String computation,
 String stream,
 Integer partitions,
 long lag)

populateStreamLatency

public StreamIntrospectionToScaleActivity.ActiveComputationBuilder populateStreamLatency(StreamIntrospection.ValueMetric metric)

populateStreamEnd

public StreamIntrospectionToScaleActivity.ActiveComputationBuilder populateStreamEnd(StreamIntrospection.ValueMetric metric)

populateStream

protected StreamIntrospectionToScaleActivity.ActiveComputationBuilder populateStream(StreamIntrospection.ValueMetric metric,
 Consumer<StreamIntrospectionToScaleActivity.ActiveComputationStreamBuilder> consumer)

addNode

public StreamIntrospectionToScaleActivity.ActiveComputationBuilder addNode(String nodeId,
 int threads,
 Instant timestamp,
 StreamIntrospection.TimerMetric timerMetric)

hasComputation

public boolean hasComputation(String computation)

build

public List<ScaleActivity.ActiveComputation> build()