Class StreamIntrospectionConverter
java.lang.Object
org.nuxeo.ecm.core.bulk.introspection.StreamIntrospectionConverter
- Since:
- 11.5
-
Field Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionprotected void
dumpComputation
(String host, StringBuilder ret, com.fasterxml.jackson.databind.JsonNode item, Map<String, String> metrics, String created) protected void
dumpStream
(StringBuilder ret, com.fasterxml.jackson.databind.JsonNode item, Map<String, String> metrics) protected com.fasterxml.jackson.databind.JsonNode
getActiveComputations
(long atTimestamp) getActivity
(long atTimestamp) protected String
getBatchInfo
(com.fasterxml.jackson.databind.JsonNode item) protected com.fasterxml.jackson.databind.JsonNode
getClusterNodes
(long atTimestamp) protected String
getComputationMetrics
(String host, String name, com.fasterxml.jackson.databind.JsonNode item, Map<String, String> metrics) getConsumers
(String stream) protected String
getNiceDouble
(Double number) protected String
getNiceDouble3
(Double number) getPuml()
protected String
getPumlHeader
(String title) protected String
getPumlIdentifier
(String name) protected String
getPumlIdentifierForHost
(String host, String id) protected com.fasterxml.jackson.databind.JsonNode
getScaleMetrics
(int workerCount, com.fasterxml.jackson.databind.node.ArrayNode computations) protected String
getStreamEnd
(Map<String, String> metrics, String name)
-
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
- See Also:
-
json
-
root
protected final com.fasterxml.jackson.databind.JsonNode root
-
-
Constructor Details
-
StreamIntrospectionConverter
-
-
Method Details
-
getStreams
-
getConsumers
-
getPuml
-
parseMetrics
-
getNiceDouble
-
getNiceDouble3
-
getPumlHeader
-
getPumlIdentifierForHost
-
dumpStream
protected void dumpStream(StringBuilder ret, com.fasterxml.jackson.databind.JsonNode item, Map<String, String> metrics) -
getStreamEnd
-
dumpComputation
-
getComputationMetrics
-
getBatchInfo
-
getActivity
-
getActivity
-
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
-