Class StreamIntrospectionConverter

java.lang.Object
org.nuxeo.ecm.core.bulk.introspection.StreamIntrospectionConverter

public class StreamIntrospectionConverter extends Object
Since:
11.5
  • Field Details

    • OBJECT_MAPPER

      protected static final com.fasterxml.jackson.databind.ObjectMapper OBJECT_MAPPER
    • ACTIVE_THRESHOLD_SECONDS

      protected static final long ACTIVE_THRESHOLD_SECONDS
      See Also:
    • EMPTY_JSON_ARRAY

      protected static final String EMPTY_JSON_ARRAY
      See Also:
    • json

      protected final String json
    • root

      protected final com.fasterxml.jackson.databind.JsonNode root
  • Constructor Details

    • StreamIntrospectionConverter

      public StreamIntrospectionConverter(String json)
  • Method Details

    • getStreams

      public String getStreams()
    • getConsumers

      public String getConsumers(String stream)
    • getPuml

      public String getPuml()
    • parseMetrics

      protected Map<String,String> parseMetrics()
    • getNiceDouble

      protected String getNiceDouble(Double number)
    • getNiceDouble3

      protected String getNiceDouble3(Double number)
    • getPumlHeader

      protected String getPumlHeader(String title)
    • getPumlIdentifierForHost

      protected String getPumlIdentifierForHost(String host, String id)
    • dumpStream

      protected void dumpStream(StringBuilder ret, com.fasterxml.jackson.databind.JsonNode item, Map<String,String> metrics)
    • getStreamEnd

      protected String getStreamEnd(Map<String,String> metrics, String name)
    • dumpComputation

      protected void dumpComputation(String host, StringBuilder ret, com.fasterxml.jackson.databind.JsonNode item, Map<String,String> metrics, String created)
    • getComputationMetrics

      protected String getComputationMetrics(String host, String name, com.fasterxml.jackson.databind.JsonNode item, Map<String,String> metrics)
    • getBatchInfo

      protected String getBatchInfo(com.fasterxml.jackson.databind.JsonNode item)
    • getActivity

      public String getActivity()
    • getActivity

      public String getActivity(long atTimestamp)
    • getScaleMetrics

      protected com.fasterxml.jackson.databind.JsonNode getScaleMetrics(int workerCount, com.fasterxml.jackson.databind.node.ArrayNode computations)
    • getActiveComputations

      protected com.fasterxml.jackson.databind.JsonNode getActiveComputations(long atTimestamp)
    • getClusterNodes

      protected com.fasterxml.jackson.databind.JsonNode getClusterNodes(long atTimestamp)
    • getPumlIdentifier

      protected String getPumlIdentifier(String name)