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

Class StreamIntrospectionConverter

java.lang.Object

org.nuxeo.ecm.core.bulk.introspection.StreamIntrospectionConverter

public class StreamIntrospectionConverter
extends Object

Since:

11.5

Field Summary

Fields

Modifier and Type	Field	Description
protected static final long	ACTIVE_THRESHOLD_SECONDS
protected static final int	BEST_ETA_THRESHOLD_SECONDS
protected static final String	EMPTY_JSON_ARRAY
protected static final int	ETA_THRESHOLD_SECONDS
protected final String	json
protected static final com.fasterxml.jackson.databind.ObjectMapper	OBJECT_MAPPER
protected final com.fasterxml.jackson.databind.JsonNode	root

Constructor Summary

Constructors

Constructor	Description
StreamIntrospectionConverter(String json)

Method Summary

Modifier and Type	Method	Description
protected 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)
String	getActivity()
String	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)
String	getConsumers(String stream)
protected String	getNiceDouble(Double number)
protected String	getNiceDouble3(Double number)
String	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)
String	getStreams()
protected com.fasterxml.jackson.databind.node.ObjectNode	initComputation(com.fasterxml.jackson.databind.JsonNode key)
protected Map<String,String>	parseMetrics()

Methods inherited from class java.lang.Object

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

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:

• Constant Field Values

ETA_THRESHOLD_SECONDS

protected static final int ETA_THRESHOLD_SECONDS

See Also:

• Constant Field Values

BEST_ETA_THRESHOLD_SECONDS

protected static final int BEST_ETA_THRESHOLD_SECONDS

See Also:

• Constant Field Values

EMPTY_JSON_ARRAY

protected static final String EMPTY_JSON_ARRAY

See Also:

• Constant Field Values

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)

initComputation

protected com.fasterxml.jackson.databind.node.ObjectNode initComputation(com.fasterxml.jackson.databind.JsonNode key)

getClusterNodes

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

getPumlIdentifier

protected String getPumlIdentifier(String name)