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

Class StreamIntrospectionToScaleActivity.ActiveComputationStreamBuilder

java.lang.Object

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

Enclosing class:

StreamIntrospectionToScaleActivity

protected static class StreamIntrospectionToScaleActivity.ActiveComputationStreamBuilder
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected Long	end
protected final long	lag
protected Duration	latency
protected final int	partitions
protected final String	stream

Constructor Summary

Constructors

Constructor	Description
ActiveComputationStreamBuilder(String stream, int partitions, long lag)

Method Summary

Modifier and Type	Method	Description
ScaleActivity.ActiveComputationStream	build()
StreamIntrospectionToScaleActivity.ActiveComputationStreamBuilder	end(Long end)
StreamIntrospectionToScaleActivity.ActiveComputationStreamBuilder	latency(Duration latency)

Methods inherited from class java.lang.Object

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

Field Details

stream

protected final String stream

partitions

protected final int partitions

lag

protected final long lag

end

protected Long end

latency

protected Duration latency

Constructor Details

ActiveComputationStreamBuilder

public ActiveComputationStreamBuilder(String stream,
 int partitions,
 long lag)

Method Details

end

public StreamIntrospectionToScaleActivity.ActiveComputationStreamBuilder end(Long end)

latency

public StreamIntrospectionToScaleActivity.ActiveComputationStreamBuilder latency(Duration latency)

build

public ScaleActivity.ActiveComputationStream build()