- getAdded() - Method in class org.apache.streams.local.queues.ThroughputQueue
-
- getAdded() - Method in interface org.apache.streams.local.queues.ThroughputQueueMXBean
-
Get the number of items that have been added to the queue
- getAvgTime() - Method in class org.apache.streams.local.counters.StreamsTaskCounter
-
- getAvgTime() - Method in interface org.apache.streams.local.counters.StreamsTaskCounterMXBean
-
Returns the average time in milliseconds it takes the task to readCurrent, process, or write to return.
- getAvgWait() - Method in class org.apache.streams.local.queues.ThroughputQueue
-
If elements have been removed from the queue or no elements have been added, it returns the average wait time
in milliseconds.
- getAvgWait() - Method in interface org.apache.streams.local.queues.ThroughputQueueMXBean
-
Get the average time an item spends in queue in milliseconds
- getCurrentSize() - Method in class org.apache.streams.local.queues.ThroughputQueue
-
- getCurrentSize() - Method in interface org.apache.streams.local.queues.ThroughputQueueMXBean
-
Returns the number of items on the queue.
- getDatumStatusCounter() - Method in class org.apache.streams.local.tasks.StreamsPersistWriterTask
-
- getDatumStatusCounter() - Method in class org.apache.streams.local.tasks.StreamsProcessorTask
-
- getDatumStatusCounter() - Method in class org.apache.streams.local.tasks.StreamsProviderTask
-
- getDownStreamComponents() - Method in class org.apache.streams.local.builders.StreamComponent
-
The components that are immediately downstream of this component (aka child nodes)
- getErrorRate() - Method in class org.apache.streams.local.counters.StreamsTaskCounter
-
- getErrorRate() - Method in interface org.apache.streams.local.counters.StreamsTaskCounterMXBean
-
Get the error rate of the streams process calculated by the number of errors not handled by the
StreamsTask
divided by the number of datums received.
- getFailRate() - Method in class org.apache.streams.local.counters.DatumStatusCounter
-
- getFailRate() - Method in interface org.apache.streams.local.counters.DatumStatusCounterMXBean
-
Get the failure rate.
- getId() - Method in class org.apache.streams.local.builders.StreamComponent
-
The unique of this component
- getInBoundQueue() - Method in class org.apache.streams.local.builders.StreamComponent
-
The inbound queue for this component
- getInputQueues() - Method in class org.apache.streams.local.tasks.BaseStreamsTask
-
- getInputQueues() - Method in class org.apache.streams.local.tasks.StreamsPersistWriterTask
-
- getInputQueues() - Method in class org.apache.streams.local.tasks.StreamsProcessorTask
-
- getInputQueues() - Method in interface org.apache.streams.local.tasks.StreamsTask
-
Returns the input queues that have been set for this task.
- getMaxTime() - Method in class org.apache.streams.local.counters.StreamsTaskCounter
-
- getMaxTime() - Method in interface org.apache.streams.local.counters.StreamsTaskCounterMXBean
-
Returns the max time in milliseconds it takes the task to readCurrent, process, or write to return.
- getMaxWait() - Method in class org.apache.streams.local.queues.ThroughputQueue
-
- getMaxWait() - Method in interface org.apache.streams.local.queues.ThroughputQueueMXBean
-
Get the maximum time an item has spent on the queue before being removed from the queue.
- getNextDatum() - Method in class org.apache.streams.local.tasks.BaseStreamsTask
-
Deprecated.
- getNumEmitted() - Method in class org.apache.streams.local.counters.StreamsTaskCounter
-
- getNumEmitted() - Method in interface org.apache.streams.local.counters.StreamsTaskCounterMXBean
-
Get the number of
StreamsDatum
s emitted by the streams process
- getNumFailed() - Method in class org.apache.streams.local.counters.DatumStatusCounter
-
- getNumFailed() - Method in interface org.apache.streams.local.counters.DatumStatusCounterMXBean
-
Get number of failed datums
- getNumPassed() - Method in class org.apache.streams.local.counters.DatumStatusCounter
-
- getNumPassed() - Method in interface org.apache.streams.local.counters.DatumStatusCounterMXBean
-
Get number of passed datums
- getNumReceived() - Method in class org.apache.streams.local.counters.StreamsTaskCounter
-
- getNumReceived() - Method in interface org.apache.streams.local.counters.StreamsTaskCounterMXBean
-
Get the number of
StreamsDatum
s received by the streams process
- getNumTasks() - Method in class org.apache.streams.local.builders.StreamComponent
-
The number of tasks this to run this component
- getNumUnhandledErrors() - Method in class org.apache.streams.local.counters.StreamsTaskCounter
-
- getNumUnhandledErrors() - Method in interface org.apache.streams.local.counters.StreamsTaskCounterMXBean
-
Get the number of errors that the process had to catch because the executing Provider/Processor/Writer did not
catch and handle the exception
- getOperation() - Method in class org.apache.streams.local.builders.StreamComponent
-
- getOutputQueues() - Method in class org.apache.streams.local.tasks.BaseStreamsTask
-
- getOutputQueues() - Method in interface org.apache.streams.local.tasks.StreamsTask
-
Returns the output queues that have been set for this task
- getRemoved() - Method in class org.apache.streams.local.queues.ThroughputQueue
-
- getRemoved() - Method in interface org.apache.streams.local.queues.ThroughputQueueMXBean
-
Get the number of items that have been removed from this queue
- getStartedAt() - Method in class org.apache.streams.local.tasks.BaseStreamsTask
-
- getStreamIdentifier() - Method in class org.apache.streams.local.tasks.BaseStreamsTask
-
- getStreamsConfiguration() - Method in class org.apache.streams.local.builders.LocalStreamBuilder
-
- getStreamsTasks() - Method in class org.apache.streams.local.builders.StreamComponent
-
- getThroughput() - Method in class org.apache.streams.local.queues.ThroughputQueue
-
- getThroughput() - Method in interface org.apache.streams.local.queues.ThroughputQueueMXBean
-
Get the the throughput of the queue measured by the number of items removed from the queue
dived by the time the queue has been active.
- getTimeout() - Method in class org.apache.streams.local.builders.LocalStreamBuilder
-
- getUpStreamComponents() - Method in class org.apache.streams.local.builders.StreamComponent
-
The components that are immediately upstream of this component (aka parent nodes)