B D G L M O P R S T

B

BroadcastMessagePersister - Class in org.apache.streams.monitoring.persist.impl

BroadcastMessagePersister(String) - Constructor for class org.apache.streams.monitoring.persist.impl.BroadcastMessagePersister

BroadcastMonitorThread - Class in org.apache.streams.monitoring.tasks

This thread runs inside of a Streams runtime and periodically persists information from relevant JMX beans.

BroadcastMonitorThread(Map<String, Object>) - Constructor for class org.apache.streams.monitoring.tasks.BroadcastMonitorThread

Deprecated.

BroadcastMonitorThread(StreamsConfiguration) - Constructor for class org.apache.streams.monitoring.tasks.BroadcastMonitorThread

BroadcastMonitorThread(MonitoringConfiguration) - Constructor for class org.apache.streams.monitoring.tasks.BroadcastMonitorThread

BroadcastMonitorThread constructor - uses supplied MonitoringConfiguration.

D

DatumStatusCounterDeserializer - Class in org.apache.streams.jackson

DatumStatusCounterDeserializer() - Constructor for class org.apache.streams.jackson.DatumStatusCounterDeserializer

deserialize(JsonParser, DeserializationContext) - Method in class org.apache.streams.jackson.DatumStatusCounterDeserializer

deserialize(JsonParser, DeserializationContext) - Method in class org.apache.streams.jackson.MemoryUsageDeserializer

deserialize(JsonParser, DeserializationContext) - Method in class org.apache.streams.jackson.StreamsTaskCounterDeserializer

deserialize(JsonParser, DeserializationContext) - Method in class org.apache.streams.jackson.ThroughputQueueDeserializer

G

getBroadcastUri() - Method in class org.apache.streams.monitoring.tasks.BroadcastMonitorThread

getWaitTime() - Method in class org.apache.streams.monitoring.tasks.BroadcastMonitorThread

L

LogstashUdpMessagePersister - Class in org.apache.streams.monitoring.persist.impl

LogstashUdpMessagePersister(String) - Constructor for class org.apache.streams.monitoring.persist.impl.LogstashUdpMessagePersister

M

MemoryUsageDeserializer - Class in org.apache.streams.jackson

MemoryUsageDeserializer() - Constructor for class org.apache.streams.jackson.MemoryUsageDeserializer

MessagePersister - Interface in org.apache.streams.monitoring.persist

Interface to define how we persist messages (JMX/monitoring related).

O

org.apache.streams.jackson - package org.apache.streams.jackson

org.apache.streams.monitoring.persist - package org.apache.streams.monitoring.persist

org.apache.streams.monitoring.persist.impl - package org.apache.streams.monitoring.persist.impl

org.apache.streams.monitoring.tasks - package org.apache.streams.monitoring.tasks

P

persistMessages(List<String>) - Method in class org.apache.streams.monitoring.persist.impl.BroadcastMessagePersister

persistMessages(List<String>) - Method in class org.apache.streams.monitoring.persist.impl.LogstashUdpMessagePersister

persistMessages(List<String>) - Method in class org.apache.streams.monitoring.persist.impl.Slf4jMessagePersister

persistMessages(List<String>) - Method in interface org.apache.streams.monitoring.persist.MessagePersister

Given a list of messages, persist them out through whatever appropriate broadcast mechanism (HTTP request, SLF4J log, etc.).

prepare() - Method in class org.apache.streams.monitoring.tasks.BroadcastMonitorThread

prepare for execution.

R

run() - Method in class org.apache.streams.monitoring.tasks.BroadcastMonitorThread

Get all relevant JMX beans, convert their values to strings, and then persist them.

S

setup() - Method in class org.apache.streams.monitoring.persist.impl.LogstashUdpMessagePersister

setup.

shutdown() - Method in class org.apache.streams.monitoring.tasks.BroadcastMonitorThread

Slf4jMessagePersister - Class in org.apache.streams.monitoring.persist.impl

Persist montoring messages to SLF4J.

Slf4jMessagePersister() - Constructor for class org.apache.streams.monitoring.persist.impl.Slf4jMessagePersister

StreamsTaskCounterDeserializer - Class in org.apache.streams.jackson

StreamsTaskCounterDeserializer: a JsonDeserializer for StreamsTaskCounterBroadcast.

StreamsTaskCounterDeserializer() - Constructor for class org.apache.streams.jackson.StreamsTaskCounterDeserializer

T

ThroughputQueueDeserializer - Class in org.apache.streams.jackson

ThroughputQueueDeserializer() - Constructor for class org.apache.streams.jackson.ThroughputQueueDeserializer

B D G L M O P R S T