Uses of Class
org.nuxeo.ecm.core.bulk.introspection.StreamIntrospectionToScaleActivity.ActiveComputationBuilder

Packages that use StreamIntrospectionToScaleActivity.ActiveComputationBuilder

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

Uses of StreamIntrospectionToScaleActivity.ActiveComputationBuilder in org.nuxeo.ecm.core.bulk.introspection

Methods in org.nuxeo.ecm.core.bulk.introspection that return StreamIntrospectionToScaleActivity.ActiveComputationBuilder

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