Class StreamIntrospectionToScaleActivity.ActiveComputationBuilder
java.lang.Object
org.nuxeo.ecm.core.bulk.introspection.StreamIntrospectionToScaleActivity.ActiveComputationBuilder
- Enclosing class:
- StreamIntrospectionToScaleActivity
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected final Map<String,List<ScaleActivity.ActiveComputationNode>> protected final Map<String,Map<String, StreamIntrospectionToScaleActivity.ActiveComputationStreamBuilder>> -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionaddNode(String nodeId, int threads, Instant timestamp, StreamIntrospection.TimerMetric timerMetric) build()booleanhasComputation(String computation) initComputation(String computation) populateStream(StreamIntrospection.ValueMetric metric, Consumer<StreamIntrospectionToScaleActivity.ActiveComputationStreamBuilder> consumer)
-
Field Details
-
computations
-
streams
protected final Map<String,Map<String, streamsStreamIntrospectionToScaleActivity.ActiveComputationStreamBuilder>> -
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
-
build
-