B D E G H L M O P R S T W

B

Broadcast - Class in org.apache.streams.pojo.json

object

Broadcast() - Constructor for class org.apache.streams.pojo.json.Broadcast

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() - 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

DatumStatusCounterBroadcast - Class in org.apache.streams.pojo.json

object

DatumStatusCounterBroadcast() - Constructor for class org.apache.streams.pojo.json.DatumStatusCounterBroadcast

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

E

equals(Object) - Method in class org.apache.streams.local.monitoring.MonitoringConfiguration

equals(Object) - Method in class org.apache.streams.pojo.json.Broadcast

equals(Object) - Method in class org.apache.streams.pojo.json.DatumStatusCounterBroadcast

equals(Object) - Method in class org.apache.streams.pojo.json.MemoryUsageBroadcast

equals(Object) - Method in class org.apache.streams.pojo.json.StreamsTaskCounterBroadcast

equals(Object) - Method in class org.apache.streams.pojo.json.ThroughputQueueBroadcast

G

getAdded() - Method in class org.apache.streams.pojo.json.ThroughputQueueBroadcast

Number of elements added to the queue

getAdditionalProperties() - Method in class org.apache.streams.local.monitoring.MonitoringConfiguration

getAdditionalProperties() - Method in class org.apache.streams.pojo.json.Broadcast

getAdditionalProperties() - Method in class org.apache.streams.pojo.json.DatumStatusCounterBroadcast

getAdditionalProperties() - Method in class org.apache.streams.pojo.json.MemoryUsageBroadcast

getAdditionalProperties() - Method in class org.apache.streams.pojo.json.StreamsTaskCounterBroadcast

getAdditionalProperties() - Method in class org.apache.streams.pojo.json.ThroughputQueueBroadcast

getAvgTime() - Method in class org.apache.streams.pojo.json.StreamsTaskCounterBroadcast

Average amount of time an item spent in this Task

getAvgWait() - Method in class org.apache.streams.pojo.json.ThroughputQueueBroadcast

Average wait time

getBroadcastURI() - Method in class org.apache.streams.local.monitoring.MonitoringConfiguration

URI for monitoring statistics

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

getCurrentSize() - Method in class org.apache.streams.pojo.json.ThroughputQueueBroadcast

Current size of the queue

getErrorRate() - Method in class org.apache.streams.pojo.json.StreamsTaskCounterBroadcast

Rate of failed items

getFailed() - Method in class org.apache.streams.pojo.json.DatumStatusCounterBroadcast

Number of objects that have faile

getHeapMemoryUsage() - Method in class org.apache.streams.pojo.json.MemoryUsageBroadcast

The amount of heap memory we are currently using

getMaxTime() - Method in class org.apache.streams.pojo.json.StreamsTaskCounterBroadcast

Longest amount of time an item spent in this Task

getMaxWait() - Method in class org.apache.streams.pojo.json.ThroughputQueueBroadcast

Maximum wait time

getMonitoringBroadcastIntervalMs() - Method in class org.apache.streams.local.monitoring.MonitoringConfiguration

Milliseconds between publish events

getName() - Method in class org.apache.streams.pojo.json.Broadcast

Name of the MBean

getName() - Method in class org.apache.streams.pojo.json.DatumStatusCounterBroadcast

Name of the MBean

getName() - Method in class org.apache.streams.pojo.json.MemoryUsageBroadcast

The name of this MBean

getName() - Method in class org.apache.streams.pojo.json.StreamsTaskCounterBroadcast

Name of the MBean

getName() - Method in class org.apache.streams.pojo.json.ThroughputQueueBroadcast

Name of the MBean

getNonHeapMemoryUsage() - Method in class org.apache.streams.pojo.json.MemoryUsageBroadcast

The amount of non-heap memory we are using

getNumEmitted() - Method in class org.apache.streams.pojo.json.StreamsTaskCounterBroadcast

Number of items that have been emitted

getNumReceived() - Method in class org.apache.streams.pojo.json.StreamsTaskCounterBroadcast

Number of items this Task has received

getNumUnhandledErrors() - Method in class org.apache.streams.pojo.json.StreamsTaskCounterBroadcast

Number of unhandled errors

getObjectPendingFinalizationCount() - Method in class org.apache.streams.pojo.json.MemoryUsageBroadcast

The number of objects that are pending finalization

getPassed() - Method in class org.apache.streams.pojo.json.DatumStatusCounterBroadcast

Number of objects that have passed

getRemoved() - Method in class org.apache.streams.pojo.json.ThroughputQueueBroadcast

Number of elements removed from the queue

getStartedAt() - Method in class org.apache.streams.pojo.json.Broadcast

Milliseconds since epoch when this Stream was started

getStreamIdentifier() - Method in class org.apache.streams.pojo.json.Broadcast

The name of the Stream that is currently executing

getThroughput() - Method in class org.apache.streams.pojo.json.ThroughputQueueBroadcast

Number of elements that have passed through the queue per second

getVerbose() - Method in class org.apache.streams.pojo.json.MemoryUsageBroadcast

Whether or not this is verbose

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

H

hashCode() - Method in class org.apache.streams.local.monitoring.MonitoringConfiguration

hashCode() - Method in class org.apache.streams.pojo.json.Broadcast

hashCode() - Method in class org.apache.streams.pojo.json.DatumStatusCounterBroadcast

hashCode() - Method in class org.apache.streams.pojo.json.MemoryUsageBroadcast

hashCode() - Method in class org.apache.streams.pojo.json.StreamsTaskCounterBroadcast

hashCode() - Method in class org.apache.streams.pojo.json.ThroughputQueueBroadcast

L

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

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

M

MemoryUsageBroadcast - Class in org.apache.streams.pojo.json

object

MemoryUsageBroadcast() - Constructor for class org.apache.streams.pojo.json.MemoryUsageBroadcast

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).

MonitoringConfiguration - Class in org.apache.streams.local.monitoring

object

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

O

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

org.apache.streams.local.monitoring - package org.apache.streams.local.monitoring

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

org.apache.streams.pojo.json - package org.apache.streams.pojo.json

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

setAdded(Long) - Method in class org.apache.streams.pojo.json.ThroughputQueueBroadcast

Number of elements added to the queue

setAdditionalProperty(String, Object) - Method in class org.apache.streams.local.monitoring.MonitoringConfiguration

setAdditionalProperty(String, Object) - Method in class org.apache.streams.pojo.json.Broadcast

setAdditionalProperty(String, Object) - Method in class org.apache.streams.pojo.json.DatumStatusCounterBroadcast

setAdditionalProperty(String, Object) - Method in class org.apache.streams.pojo.json.MemoryUsageBroadcast

setAdditionalProperty(String, Object) - Method in class org.apache.streams.pojo.json.StreamsTaskCounterBroadcast

setAdditionalProperty(String, Object) - Method in class org.apache.streams.pojo.json.ThroughputQueueBroadcast

setAvgTime(Object) - Method in class org.apache.streams.pojo.json.StreamsTaskCounterBroadcast

Average amount of time an item spent in this Task

setAvgWait(Object) - Method in class org.apache.streams.pojo.json.ThroughputQueueBroadcast

Average wait time

setBroadcastURI(String) - Method in class org.apache.streams.local.monitoring.MonitoringConfiguration

URI for monitoring statistics

setCurrentSize(Long) - Method in class org.apache.streams.pojo.json.ThroughputQueueBroadcast

Current size of the queue

setErrorRate(Object) - Method in class org.apache.streams.pojo.json.StreamsTaskCounterBroadcast

Rate of failed items

setFailed(Boolean) - Method in class org.apache.streams.pojo.json.DatumStatusCounterBroadcast

Number of objects that have faile

setHeapMemoryUsage(Long) - Method in class org.apache.streams.pojo.json.MemoryUsageBroadcast

The amount of heap memory we are currently using

setMaxTime(Long) - Method in class org.apache.streams.pojo.json.StreamsTaskCounterBroadcast

Longest amount of time an item spent in this Task

setMaxWait(Object) - Method in class org.apache.streams.pojo.json.ThroughputQueueBroadcast

Maximum wait time

setMonitoringBroadcastIntervalMs(Long) - Method in class org.apache.streams.local.monitoring.MonitoringConfiguration

Milliseconds between publish events

setName(String) - Method in class org.apache.streams.pojo.json.Broadcast

Name of the MBean

setName(String) - Method in class org.apache.streams.pojo.json.DatumStatusCounterBroadcast

Name of the MBean

setName(String) - Method in class org.apache.streams.pojo.json.MemoryUsageBroadcast

The name of this MBean

setName(String) - Method in class org.apache.streams.pojo.json.StreamsTaskCounterBroadcast

Name of the MBean

setName(String) - Method in class org.apache.streams.pojo.json.ThroughputQueueBroadcast

Name of the MBean

setNonHeapMemoryUsage(Long) - Method in class org.apache.streams.pojo.json.MemoryUsageBroadcast

The amount of non-heap memory we are using

setNumEmitted(Long) - Method in class org.apache.streams.pojo.json.StreamsTaskCounterBroadcast

Number of items that have been emitted

setNumReceived(Long) - Method in class org.apache.streams.pojo.json.StreamsTaskCounterBroadcast

Number of items this Task has received

setNumUnhandledErrors(Long) - Method in class org.apache.streams.pojo.json.StreamsTaskCounterBroadcast

Number of unhandled errors

setObjectPendingFinalizationCount(Long) - Method in class org.apache.streams.pojo.json.MemoryUsageBroadcast

The number of objects that are pending finalization

setPassed(Boolean) - Method in class org.apache.streams.pojo.json.DatumStatusCounterBroadcast

Number of objects that have passed

setRemoved(Long) - Method in class org.apache.streams.pojo.json.ThroughputQueueBroadcast

Number of elements removed from the queue

setStartedAt(Long) - Method in class org.apache.streams.pojo.json.Broadcast

Milliseconds since epoch when this Stream was started

setStreamIdentifier(String) - Method in class org.apache.streams.pojo.json.Broadcast

The name of the Stream that is currently executing

setThroughput(Object) - Method in class org.apache.streams.pojo.json.ThroughputQueueBroadcast

Number of elements that have passed through the queue per second

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

setup.

setVerbose(Boolean) - Method in class org.apache.streams.pojo.json.MemoryUsageBroadcast

Whether or not this is verbose

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

StreamsTaskCounterBroadcast - Class in org.apache.streams.pojo.json

object

StreamsTaskCounterBroadcast() - Constructor for class org.apache.streams.pojo.json.StreamsTaskCounterBroadcast

StreamsTaskCounterDeserializer - Class in org.apache.streams.jackson

StreamsTaskCounterDeserializer: a JsonDeserializer for StreamsTaskCounterBroadcast.

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

T

ThroughputQueueBroadcast - Class in org.apache.streams.pojo.json

object

ThroughputQueueBroadcast() - Constructor for class org.apache.streams.pojo.json.ThroughputQueueBroadcast

ThroughputQueueDeserializer - Class in org.apache.streams.jackson

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

toString() - Method in class org.apache.streams.local.monitoring.MonitoringConfiguration

toString() - Method in class org.apache.streams.pojo.json.Broadcast

toString() - Method in class org.apache.streams.pojo.json.DatumStatusCounterBroadcast

toString() - Method in class org.apache.streams.pojo.json.MemoryUsageBroadcast

toString() - Method in class org.apache.streams.pojo.json.StreamsTaskCounterBroadcast

toString() - Method in class org.apache.streams.pojo.json.ThroughputQueueBroadcast

W

withAdded(Long) - Method in class org.apache.streams.pojo.json.ThroughputQueueBroadcast

withAdditionalProperty(String, Object) - Method in class org.apache.streams.local.monitoring.MonitoringConfiguration

withAdditionalProperty(String, Object) - Method in class org.apache.streams.pojo.json.Broadcast

withAdditionalProperty(String, Object) - Method in class org.apache.streams.pojo.json.DatumStatusCounterBroadcast

withAdditionalProperty(String, Object) - Method in class org.apache.streams.pojo.json.MemoryUsageBroadcast

withAdditionalProperty(String, Object) - Method in class org.apache.streams.pojo.json.StreamsTaskCounterBroadcast

withAdditionalProperty(String, Object) - Method in class org.apache.streams.pojo.json.ThroughputQueueBroadcast

withAvgTime(Object) - Method in class org.apache.streams.pojo.json.StreamsTaskCounterBroadcast

withAvgWait(Object) - Method in class org.apache.streams.pojo.json.ThroughputQueueBroadcast

withBroadcastURI(String) - Method in class org.apache.streams.local.monitoring.MonitoringConfiguration

withCurrentSize(Long) - Method in class org.apache.streams.pojo.json.ThroughputQueueBroadcast

withErrorRate(Object) - Method in class org.apache.streams.pojo.json.StreamsTaskCounterBroadcast

withFailed(Boolean) - Method in class org.apache.streams.pojo.json.DatumStatusCounterBroadcast

withHeapMemoryUsage(Long) - Method in class org.apache.streams.pojo.json.MemoryUsageBroadcast

withMaxTime(Long) - Method in class org.apache.streams.pojo.json.StreamsTaskCounterBroadcast

withMaxWait(Object) - Method in class org.apache.streams.pojo.json.ThroughputQueueBroadcast

withMonitoringBroadcastIntervalMs(Long) - Method in class org.apache.streams.local.monitoring.MonitoringConfiguration

withName(String) - Method in class org.apache.streams.pojo.json.Broadcast

withName(String) - Method in class org.apache.streams.pojo.json.DatumStatusCounterBroadcast

withName(String) - Method in class org.apache.streams.pojo.json.MemoryUsageBroadcast

withName(String) - Method in class org.apache.streams.pojo.json.StreamsTaskCounterBroadcast

withName(String) - Method in class org.apache.streams.pojo.json.ThroughputQueueBroadcast

withNonHeapMemoryUsage(Long) - Method in class org.apache.streams.pojo.json.MemoryUsageBroadcast

withNumEmitted(Long) - Method in class org.apache.streams.pojo.json.StreamsTaskCounterBroadcast

withNumReceived(Long) - Method in class org.apache.streams.pojo.json.StreamsTaskCounterBroadcast

withNumUnhandledErrors(Long) - Method in class org.apache.streams.pojo.json.StreamsTaskCounterBroadcast

withObjectPendingFinalizationCount(Long) - Method in class org.apache.streams.pojo.json.MemoryUsageBroadcast

withPassed(Boolean) - Method in class org.apache.streams.pojo.json.DatumStatusCounterBroadcast

withRemoved(Long) - Method in class org.apache.streams.pojo.json.ThroughputQueueBroadcast

withStartedAt(Long) - Method in class org.apache.streams.pojo.json.Broadcast

withStreamIdentifier(String) - Method in class org.apache.streams.pojo.json.Broadcast

withThroughput(Object) - Method in class org.apache.streams.pojo.json.ThroughputQueueBroadcast

withVerbose(Boolean) - Method in class org.apache.streams.pojo.json.MemoryUsageBroadcast

B D E G H L M O P R S T W