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

Class StreamIntrospectionJsonReader

java.lang.Object

org.nuxeo.ecm.core.io.marshallers.json.AbstractJsonReader<StreamIntrospection>

org.nuxeo.ecm.core.bulk.introspection.StreamIntrospectionJsonReader

All Implemented Interfaces:

Marshaller<StreamIntrospection>, Reader<StreamIntrospection>

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

Since:

2025.11

Field Summary

Fields inherited from class org.nuxeo.ecm.core.io.marshallers.json.AbstractJsonReader

ctx, registry

Constructor Summary

Constructors

Constructor	Description
StreamIntrospectionJsonReader()

Method Summary

Modifier and Type	Method	Description
StreamIntrospection	read(com.fasterxml.jackson.databind.JsonNode jn)	Implement this method, read the entity data in the provided JsonNode and return corresponding java object.
protected StreamIntrospection.Metric	readInnerMetric(com.fasterxml.jackson.databind.JsonNode innerMetricJn)
protected StreamIntrospection.ProcessorTopology	readInnerTopology(com.fasterxml.jackson.databind.JsonNode innerTopologyJn)
protected List<StreamIntrospection.Metrics>	readMetrics(com.fasterxml.jackson.databind.node.ArrayNode metricsJn)
protected List<StreamIntrospection.ProcessorComputation>	readProcessorComputations(com.fasterxml.jackson.databind.node.ArrayNode computationsJn)
protected StreamIntrospection.ProcessorMetadata	readProcessorMetadata(com.fasterxml.jackson.databind.node.ObjectNode metadataJn)
protected List<StreamIntrospection.Processor>	readProcessors(com.fasterxml.jackson.databind.node.ArrayNode processorsJn)
protected List<StreamIntrospection.ProcessorTopology>	readProcessorTopology(com.fasterxml.jackson.databind.node.ArrayNode topologyJn)
protected List<StreamIntrospection.Stream>	readStreams(com.fasterxml.jackson.databind.node.ArrayNode streamsJn)
protected Map<String,String>	valuesJsonNodeToString(Map<String,com.fasterxml.jackson.databind.JsonNode> innerMetricsByProperty)

Methods inherited from class org.nuxeo.ecm.core.io.marshallers.json.AbstractJsonReader

accept, getBooleanField, getLongField, getNode, getStringField, getStringListField, read, readEntity

Methods inherited from class java.lang.Object

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

Constructor Details

StreamIntrospectionJsonReader

public StreamIntrospectionJsonReader()

Method Details

read

public StreamIntrospection read(com.fasterxml.jackson.databind.JsonNode jn)
                         throws IOException

Description copied from class: AbstractJsonReader

Implement this method, read the entity data in the provided JsonNode and return corresponding java object.

Specified by:

read in class AbstractJsonReader<StreamIntrospection>

Parameters:

jn - A ready to use JsonNode.

Returns:

The unmarshalled entity.

Throws:

IOException

readStreams

protected List<StreamIntrospection.Stream> readStreams(@Nonnull
 com.fasterxml.jackson.databind.node.ArrayNode streamsJn)

readProcessors

protected List<StreamIntrospection.Processor> readProcessors(com.fasterxml.jackson.databind.node.ArrayNode processorsJn)

readProcessorMetadata

protected StreamIntrospection.ProcessorMetadata readProcessorMetadata(com.fasterxml.jackson.databind.node.ObjectNode metadataJn)

readProcessorComputations

protected List<StreamIntrospection.ProcessorComputation> readProcessorComputations(com.fasterxml.jackson.databind.node.ArrayNode computationsJn)

readProcessorTopology

protected List<StreamIntrospection.ProcessorTopology> readProcessorTopology(com.fasterxml.jackson.databind.node.ArrayNode topologyJn)

readInnerTopology

protected StreamIntrospection.ProcessorTopology readInnerTopology(com.fasterxml.jackson.databind.JsonNode innerTopologyJn)

readMetrics

protected List<StreamIntrospection.Metrics> readMetrics(com.fasterxml.jackson.databind.node.ArrayNode metricsJn)

readInnerMetric

protected StreamIntrospection.Metric readInnerMetric(com.fasterxml.jackson.databind.JsonNode innerMetricJn)

valuesJsonNodeToString

protected Map<String,String> valuesJsonNodeToString(Map<String,com.fasterxml.jackson.databind.JsonNode> innerMetricsByProperty)