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

Class StreamIntrospectionD2Writer

java.lang.Object

org.nuxeo.ecm.core.io.marshallers.d2.AbstractD2Writer<StreamIntrospection>

org.nuxeo.ecm.core.bulk.introspection.StreamIntrospectionD2Writer

All Implemented Interfaces:

Marshaller<StreamIntrospection>, Writer<StreamIntrospection>

@Setup(mode=SINGLETON,
       priority=2000)
public class StreamIntrospectionD2Writer
extends AbstractD2Writer<StreamIntrospection>

Converts stream introspection data to D2 diagram format.

Since:

2025.12

Field Summary

Fields

Modifier and Type	Field	Description
protected static final String	D2_HEADER_TEMPLATE
static final String	PARAMETER_EXCLUDE_FILTER
static final String	PARAMETER_EXCLUDE_INACTIVE
protected static final StreamIntrospectionToStreamFlattenMetrics	TO_STREAM_FLATTEN_METRICS

Fields inherited from class org.nuxeo.ecm.core.io.marshallers.d2.AbstractD2Writer

ctx

Constructor Summary

Constructors

Constructor	Description
StreamIntrospectionD2Writer()

Method Summary

Modifier and Type	Method	Description
protected List<org.apache.commons.lang3.tuple.Pair<StreamIntrospection.ProcessorComputation,StreamIntrospection.ProcessorMetadata>>	collectComputations(StreamIntrospection streamIntrospection, StreamFlattenMetrics streamMetrics)
protected String	getBatchInfo(StreamIntrospection.ProcessorComputation computation)
protected String	getComputationMetrics(String host, StreamIntrospection.ProcessorComputation computation, StreamFlattenMetrics streamMetrics)
protected long	getStreamEnd(StreamFlattenMetrics metrics, String name)
protected String	getTimerAsJson(String title, StreamFlattenMetrics.ComputationMetric computationMetric, StreamIntrospection.TimerMetric timerMetric)
protected boolean	shouldExcludeByInactivity(String name, String host, StreamFlattenMetrics metrics)	Checks if a computation should be excluded based on inactivity filter.
protected boolean	shouldExcludeByPattern(String name)	Checks if a name (stream or computation) should be excluded based on patterns.
protected boolean	shouldExcludeStreamByInactivity(String streamName, StreamFlattenMetrics metrics)	Checks if a stream should be excluded based on inactivity filter.
protected void	write(StreamIntrospection.ProcessorComputation computation, StreamIntrospection.ProcessorMetadata metadata, StreamFlattenMetrics streamMetrics, D2Printer d2Printer)
protected void	write(StreamIntrospection.ProcessorStreamConsumerTopology topology, StreamIntrospection.ProcessorMetadata metadata, StreamFlattenMetrics streamMetrics, D2Printer d2Printer)
protected void	write(StreamIntrospection.ProcessorStreamProducerTopology topology, StreamIntrospection.ProcessorMetadata metadata, D2Printer d2Printer)
protected void	write(StreamIntrospection entity, D2Printer d2Printer)

Methods inherited from class org.nuxeo.ecm.core.io.marshallers.d2.AbstractD2Writer

accept, getD2Printer, write

Methods inherited from class java.lang.Object

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

Field Details

PARAMETER_EXCLUDE_FILTER

public static final String PARAMETER_EXCLUDE_FILTER

Since:

2025.12

See Also:

• Constant Field Values

PARAMETER_EXCLUDE_INACTIVE

public static final String PARAMETER_EXCLUDE_INACTIVE

Since:

2025.12

See Also:

• Constant Field Values

TO_STREAM_FLATTEN_METRICS

protected static final StreamIntrospectionToStreamFlattenMetrics TO_STREAM_FLATTEN_METRICS

D2_HEADER_TEMPLATE

protected static final String D2_HEADER_TEMPLATE

See Also:

• Constant Field Values

Constructor Details

StreamIntrospectionD2Writer

public StreamIntrospectionD2Writer()

Method Details

write

protected void write(StreamIntrospection entity,
 D2Printer d2Printer)
              throws IOException

Specified by:

write in class AbstractD2Writer<StreamIntrospection>

Throws:

IOException

write

protected void write(StreamIntrospection.ProcessorStreamConsumerTopology topology,
 StreamIntrospection.ProcessorMetadata metadata,
 StreamFlattenMetrics streamMetrics,
 D2Printer d2Printer)
              throws IOException

Throws:

IOException

write

protected void write(StreamIntrospection.ProcessorStreamProducerTopology topology,
 StreamIntrospection.ProcessorMetadata metadata,
 D2Printer d2Printer)
              throws IOException

Throws:

IOException

shouldExcludeByPattern

protected boolean shouldExcludeByPattern(String name)

Checks if a name (stream or computation) should be excluded based on patterns.

shouldExcludeByInactivity

protected boolean shouldExcludeByInactivity(String name,
 String host,
 StreamFlattenMetrics metrics)

Checks if a computation should be excluded based on inactivity filter.

shouldExcludeStreamByInactivity

protected boolean shouldExcludeStreamByInactivity(String streamName,
 StreamFlattenMetrics metrics)

Checks if a stream should be excluded based on inactivity filter.

getStreamEnd

protected long getStreamEnd(StreamFlattenMetrics metrics,
 String name)

getComputationMetrics

protected String getComputationMetrics(String host,
 StreamIntrospection.ProcessorComputation computation,
 StreamFlattenMetrics streamMetrics)

getTimerAsJson

protected String getTimerAsJson(String title,
 StreamFlattenMetrics.ComputationMetric computationMetric,
 StreamIntrospection.TimerMetric timerMetric)

getBatchInfo

protected String getBatchInfo(StreamIntrospection.ProcessorComputation computation)

collectComputations

protected List<org.apache.commons.lang3.tuple.Pair<StreamIntrospection.ProcessorComputation,StreamIntrospection.ProcessorMetadata>> collectComputations(StreamIntrospection streamIntrospection,
 StreamFlattenMetrics streamMetrics)

write

protected void write(StreamIntrospection.ProcessorComputation computation,
 StreamIntrospection.ProcessorMetadata metadata,
 StreamFlattenMetrics streamMetrics,
 D2Printer d2Printer)