A B C D E F G H I L N O P R S T W

A

add(E) - Method in class org.apache.streams.local.queues.ThroughputQueue

addAll(Collection<? extends E>) - Method in class org.apache.streams.local.queues.ThroughputQueue

addInboundQueue(StreamComponent) - Method in class org.apache.streams.local.builders.StreamComponent

Add a component that supplies data through the inbound queue.

addInputQueue(BlockingQueue<StreamsDatum>) - Method in class org.apache.streams.local.tasks.BaseStreamsTask

addInputQueue(BlockingQueue<StreamsDatum>) - Method in class org.apache.streams.local.tasks.StreamsPersistWriterTask

addInputQueue(BlockingQueue<StreamsDatum>) - Method in class org.apache.streams.local.tasks.StreamsProcessorTask

addInputQueue(BlockingQueue<StreamsDatum>) - Method in class org.apache.streams.local.tasks.StreamsProviderTask

addInputQueue(BlockingQueue<StreamsDatum>) - Method in interface org.apache.streams.local.tasks.StreamsTask

Add an input Queue for this task.

addOutBoundQueue(StreamComponent, BlockingQueue<StreamsDatum>) - Method in class org.apache.streams.local.builders.StreamComponent

Add an outbound queue for this component.

addOutputQueue(BlockingQueue<StreamsDatum>) - Method in class org.apache.streams.local.tasks.BaseStreamsTask

addOutputQueue(BlockingQueue<StreamsDatum>) - Method in class org.apache.streams.local.tasks.StreamsPersistWriterTask

addOutputQueue(BlockingQueue<StreamsDatum>) - Method in interface org.apache.streams.local.tasks.StreamsTask

Add an output Queue for this task.

addStreamsPersistWriter(String, StreamsPersistWriter, int, String...) - Method in class org.apache.streams.local.builders.LocalStreamBuilder

addStreamsProcessor(String, StreamsProcessor, int, String...) - Method in class org.apache.streams.local.builders.LocalStreamBuilder

addTime(long) - Method in class org.apache.streams.local.counters.StreamsTaskCounter

Add the time it takes to process a single datum in milliseconds

addToOutgoingQueue(StreamsDatum) - Method in class org.apache.streams.local.tasks.BaseStreamsTask

Adds a StreamDatum to the outgoing queues.

afterExecute(Runnable, Throwable) - Method in class org.apache.streams.local.executors.ShutdownStreamOnUnhandleThrowableThreadPoolExecutor

B

BaseStreamsTask - Class in org.apache.streams.local.tasks

BaseStreamsTask is the primary abstract StreamsTask.

BaseStreamsTask(StreamsConfiguration) - Constructor for class org.apache.streams.local.tasks.BaseStreamsTask

BROADCAST_INTERVAL_KEY - Static variable in class org.apache.streams.local.builders.LocalStreamBuilder

BROADCAST_KEY - Static variable in class org.apache.streams.local.builders.LocalStreamBuilder

C

clear() - Method in class org.apache.streams.local.queues.ThroughputQueue

cloneStreamsDatum(StreamsDatum) - Method in class org.apache.streams.local.tasks.BaseStreamsTask

//TODO LOCAL MODE HACK.

contains(Object) - Method in class org.apache.streams.local.queues.ThroughputQueue

containsAll(Collection<?>) - Method in class org.apache.streams.local.queues.ThroughputQueue

createConnectedTask(int) - Method in class org.apache.streams.local.builders.StreamComponent

Creates a StreamsTask that is running a clone of this component whose inbound and outbound queues are appropriately connected to the parent and child nodes.

D

DatumStatusCounter - Class in org.apache.streams.local.counters

DatumStatusCounter(String) - Constructor for class org.apache.streams.local.counters.DatumStatusCounter

DatumStatusCounter(String, String, long) - Constructor for class org.apache.streams.local.counters.DatumStatusCounter

DatumStatusCounterMXBean - Interface in org.apache.streams.local.counters

DEFAULT_STARTED_AT_KEY - Static variable in class org.apache.streams.local.builders.LocalStreamBuilder

DEFAULT_STREAM_IDENTIFIER - Static variable in class org.apache.streams.local.builders.LocalStreamBuilder

drainTo(Collection<? super E>) - Method in class org.apache.streams.local.queues.ThroughputQueue

drainTo(Collection<? super E>, int) - Method in class org.apache.streams.local.queues.ThroughputQueue

E

element() - Method in class org.apache.streams.local.queues.ThroughputQueue

equals(Object) - Method in class org.apache.streams.local.builders.StreamComponent

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

F

flushResults(StreamsResultSet) - Method in class org.apache.streams.local.tasks.StreamsProviderTask

forceShutdown(Map<String, List<StreamsTask>>) - Method in class org.apache.streams.local.builders.LocalStreamBuilder

G

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

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

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.

getExecutorShutdownPauseMs() - Method in class org.apache.streams.local.LocalRuntimeConfiguration

Duration of pause before shutting down

getExecutorShutdownWaitMs() - Method in class org.apache.streams.local.LocalRuntimeConfiguration

Duration of wait for shut down

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.

getMonitoring() - Method in class org.apache.streams.local.LocalRuntimeConfiguration

object

getMonitorShutdownPauseMs() - Method in class org.apache.streams.local.LocalRuntimeConfiguration

Duration of pause before shutting down

getMonitorShutdownWaitMs() - Method in class org.apache.streams.local.LocalRuntimeConfiguration

Duration of wait for shut down

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 StreamsDatums 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 StreamsDatums 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

getShutdownPauseMs() - Method in class org.apache.streams.local.LocalRuntimeConfiguration

Duration of pause before shutting down

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

getTaskTimeoutMs() - Method in class org.apache.streams.local.LocalRuntimeConfiguration

Max duration to allow tasks to terminate

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)

H

hashCode() - Method in class org.apache.streams.local.builders.StreamComponent

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

humanReadableByteCount(long, boolean) - Method in class org.apache.streams.local.tasks.LocalStreamProcessMonitorThread

Deprecated.

I

incrementEmittedCount() - Method in class org.apache.streams.local.counters.StreamsTaskCounter

Increment emitted count

incrementEmittedCount(long) - Method in class org.apache.streams.local.counters.StreamsTaskCounter

Increment emitted count

incrementErrorCount() - Method in class org.apache.streams.local.counters.StreamsTaskCounter

Increment error count

incrementErrorCount(long) - Method in class org.apache.streams.local.counters.StreamsTaskCounter

Increment error count

incrementFailedCount() - Method in class org.apache.streams.local.counters.DatumStatusCounter

incrementFailedCount(long) - Method in class org.apache.streams.local.counters.DatumStatusCounter

incrementPassedCount() - Method in class org.apache.streams.local.counters.DatumStatusCounter

incrementPassedCount(long) - Method in class org.apache.streams.local.counters.DatumStatusCounter

incrementReceivedCount() - Method in class org.apache.streams.local.counters.StreamsTaskCounter

Increment received count

incrementReceivedCount(long) - Method in class org.apache.streams.local.counters.StreamsTaskCounter

Increment received count

InvalidStreamException - Exception in org.apache.streams.local.builders

Exception that indicates a malformed data stream in some way.

InvalidStreamException() - Constructor for exception org.apache.streams.local.builders.InvalidStreamException

InvalidStreamException(String) - Constructor for exception org.apache.streams.local.builders.InvalidStreamException

InvalidStreamException(String, Throwable) - Constructor for exception org.apache.streams.local.builders.InvalidStreamException

InvalidStreamException(Throwable) - Constructor for exception org.apache.streams.local.builders.InvalidStreamException

isEmpty() - Method in class org.apache.streams.local.queues.ThroughputQueue

isOperationCountable() - Method in class org.apache.streams.local.builders.StreamComponent

Deprecated.

isRunning() - Method in class org.apache.streams.local.tasks.LocalStreamProcessMonitorThread

Deprecated.

isRunning() - Method in interface org.apache.streams.local.tasks.StatusCounterMonitorRunnable

Deprecated.

isRunning() - Method in class org.apache.streams.local.tasks.StatusCounterMonitorThread

Deprecated.

isRunning() - Method in class org.apache.streams.local.tasks.StreamsMergeTask

Deprecated.

isRunning() - Method in class org.apache.streams.local.tasks.StreamsPersistWriterTask

isRunning() - Method in class org.apache.streams.local.tasks.StreamsProcessorTask

isRunning() - Method in class org.apache.streams.local.tasks.StreamsProviderTask

isRunning() - Method in interface org.apache.streams.local.tasks.StreamsTask

Returns true when the task has not completed.

isWaiting() - Method in class org.apache.streams.local.tasks.BaseStreamsTask

isWaiting() - Method in class org.apache.streams.local.tasks.StreamsPersistWriterTask

isWaiting() - Method in class org.apache.streams.local.tasks.StreamsProcessorTask

isWaiting() - Method in class org.apache.streams.local.tasks.StreamsProviderTask

isWaiting() - Method in interface org.apache.streams.local.tasks.StreamsTask

Returns true if the task is waiting on more data to process

iterator() - Method in class org.apache.streams.local.queues.ThroughputQueue

L

LocalRuntimeConfiguration - Class in org.apache.streams.local

LocalRuntimeConfiguration() - Constructor for class org.apache.streams.local.LocalRuntimeConfiguration

LocalStreamBuilder - Class in org.apache.streams.local.builders

LocalStreamBuilder implementation to run a data processing stream in a single JVM across many threads.

LocalStreamBuilder() - Constructor for class org.apache.streams.local.builders.LocalStreamBuilder

Creates a local stream builder with all configuration resolved by typesafe

LocalStreamBuilder(Map<String, Object>) - Constructor for class org.apache.streams.local.builders.LocalStreamBuilder

Deprecated.

use LocalRuntimeConfiguration constructor instead

LocalStreamBuilder(int) - Constructor for class org.apache.streams.local.builders.LocalStreamBuilder

Deprecated.

use LocalRuntimeConfiguration constructor instead

LocalStreamBuilder(int, Map<String, Object>) - Constructor for class org.apache.streams.local.builders.LocalStreamBuilder

Deprecated.

use LocalRuntimeConfiguration constructor instead

LocalStreamBuilder(LocalRuntimeConfiguration) - Constructor for class org.apache.streams.local.builders.LocalStreamBuilder

LocalStreamProcessMonitorThread - Class in org.apache.streams.local.tasks

Deprecated.

LocalStreamProcessMonitorThread(Executor, int) - Constructor for class org.apache.streams.local.tasks.LocalStreamProcessMonitorThread

Deprecated.

N

NAME_TEMPLATE - Static variable in class org.apache.streams.local.counters.DatumStatusCounter

NAME_TEMPLATE - Static variable in class org.apache.streams.local.counters.StreamsTaskCounter

NAME_TEMPLATE - Static variable in class org.apache.streams.local.queues.ThroughputQueue

newPerpetualStream(String, StreamsProvider) - Method in class org.apache.streams.local.builders.LocalStreamBuilder

newReadCurrentStream(String, StreamsProvider) - Method in class org.apache.streams.local.builders.LocalStreamBuilder

newReadNewStream(String, StreamsProvider, BigInteger) - Method in class org.apache.streams.local.builders.LocalStreamBuilder

newReadRangeStream(String, StreamsProvider, DateTime, DateTime) - Method in class org.apache.streams.local.builders.LocalStreamBuilder

O

offer(E) - Method in class org.apache.streams.local.queues.ThroughputQueue

offer(E, long, TimeUnit) - Method in class org.apache.streams.local.queues.ThroughputQueue

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

org.apache.streams.local.builders - package org.apache.streams.local.builders

org.apache.streams.local.counters - package org.apache.streams.local.counters

org.apache.streams.local.executors - package org.apache.streams.local.executors

org.apache.streams.local.queues - package org.apache.streams.local.queues

org.apache.streams.local.tasks - package org.apache.streams.local.tasks

P

peek() - Method in class org.apache.streams.local.queues.ThroughputQueue

poll(long, TimeUnit) - Method in class org.apache.streams.local.queues.ThroughputQueue

poll() - Method in class org.apache.streams.local.queues.ThroughputQueue

prepare() - Method in class org.apache.streams.local.builders.LocalStreamBuilder

put(E) - Method in class org.apache.streams.local.queues.ThroughputQueue

R

remainingCapacity() - Method in class org.apache.streams.local.queues.ThroughputQueue

remove(Object) - Method in class org.apache.streams.local.queues.ThroughputQueue

remove() - Method in class org.apache.streams.local.queues.ThroughputQueue

removeAll(Collection<?>) - Method in class org.apache.streams.local.queues.ThroughputQueue

retainAll(Collection<?>) - Method in class org.apache.streams.local.queues.ThroughputQueue

run() - Method in class org.apache.streams.local.tasks.LocalStreamProcessMonitorThread

Deprecated.

run() - Method in class org.apache.streams.local.tasks.StatusCounterMonitorThread

Deprecated.

run() - Method in class org.apache.streams.local.tasks.StreamsMergeTask

Deprecated.

run() - Method in class org.apache.streams.local.tasks.StreamsPersistWriterTask

run() - Method in class org.apache.streams.local.tasks.StreamsProcessorTask

run() - Method in class org.apache.streams.local.tasks.StreamsProviderTask

S

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

setExecutorShutdownPauseMs(Long) - Method in class org.apache.streams.local.LocalRuntimeConfiguration

Duration of pause before shutting down

setExecutorShutdownWaitMs(Long) - Method in class org.apache.streams.local.LocalRuntimeConfiguration

Duration of wait for shut down

setMonitoring(MonitoringConfiguration) - Method in class org.apache.streams.local.LocalRuntimeConfiguration

object

setMonitorShutdownPauseMs(Long) - Method in class org.apache.streams.local.LocalRuntimeConfiguration

Duration of pause before shutting down

setMonitorShutdownWaitMs(Long) - Method in class org.apache.streams.local.LocalRuntimeConfiguration

Duration of wait for shut down

setShutdownPauseMs(Long) - Method in class org.apache.streams.local.LocalRuntimeConfiguration

Duration of pause before shutting down

setSleepTime(long) - Method in class org.apache.streams.local.tasks.StreamsProviderTask

setStartedAt() - Method in class org.apache.streams.local.tasks.BaseStreamsTask

setStreamConfig(StreamsConfiguration) - Method in class org.apache.streams.local.tasks.StreamsMergeTask

Deprecated.

setStreamConfig(StreamsConfiguration) - Method in class org.apache.streams.local.tasks.StreamsPersistWriterTask

setStreamConfig(StreamsConfiguration) - Method in class org.apache.streams.local.tasks.StreamsProcessorTask

setStreamConfig(StreamsConfiguration) - Method in class org.apache.streams.local.tasks.StreamsProviderTask

setStreamConfig(StreamsConfiguration) - Method in interface org.apache.streams.local.tasks.StreamsTask

Set the configuration object that will shared and passed to all instances of StreamsTask.

setStreamsConfiguration(StreamsConfiguration) - Method in class org.apache.streams.local.builders.LocalStreamBuilder

setStreamsTaskCounter(StreamsTaskCounter) - Method in class org.apache.streams.local.tasks.StreamsMergeTask

Deprecated.

setStreamsTaskCounter(StreamsTaskCounter) - Method in class org.apache.streams.local.tasks.StreamsPersistWriterTask

setStreamsTaskCounter(StreamsTaskCounter) - Method in class org.apache.streams.local.tasks.StreamsProcessorTask

setStreamsTaskCounter(StreamsTaskCounter) - Method in class org.apache.streams.local.tasks.StreamsProviderTask

setStreamsTaskCounter(StreamsTaskCounter) - Method in interface org.apache.streams.local.tasks.StreamsTask

setTaskTimeoutMs(Long) - Method in class org.apache.streams.local.LocalRuntimeConfiguration

Max duration to allow tasks to terminate

setTimeout(int) - Method in class org.apache.streams.local.tasks.StreamsProviderTask

setupComponentTasks(Map<String, List<StreamsTask>>) - Method in class org.apache.streams.local.builders.LocalStreamBuilder

setupProviderTasks(Map<String, StreamsProviderTask>) - Method in class org.apache.streams.local.builders.LocalStreamBuilder

setUseDeprecatedMonitors(boolean) - Method in class org.apache.streams.local.builders.LocalStreamBuilder

shutdown(Map<String, List<StreamsTask>>) - Method in class org.apache.streams.local.builders.LocalStreamBuilder

shutdown() - Method in class org.apache.streams.local.tasks.LocalStreamProcessMonitorThread

Deprecated.

shutdown() - Method in interface org.apache.streams.local.tasks.StatusCounterMonitorRunnable

Deprecated.

shutdown() - Method in class org.apache.streams.local.tasks.StatusCounterMonitorThread

Deprecated.

ShutdownStreamOnUnhandleThrowableThreadPoolExecutor - Class in org.apache.streams.local.executors

A fixed ThreadPoolExecutor that will shutdown a stream upon a thread ending execution due to an unhandled throwable.

ShutdownStreamOnUnhandleThrowableThreadPoolExecutor(int, LocalStreamBuilder) - Constructor for class org.apache.streams.local.executors.ShutdownStreamOnUnhandleThrowableThreadPoolExecutor

Creates a fixed size thread pool where corePoolSize & maximumPoolSize equal numThreads with an unbounded queue.

size() - Method in class org.apache.streams.local.queues.ThroughputQueue

start() - Method in class org.apache.streams.local.builders.LocalStreamBuilder

Runs the data stream in the this JVM and blocks till completion.

StatusCounterMonitorRunnable - Interface in org.apache.streams.local.tasks

Deprecated.

StatusCounterMonitorThread - Class in org.apache.streams.local.tasks

Deprecated.

StatusCounterMonitorThread(DatumStatusCountable, int) - Constructor for class org.apache.streams.local.tasks.StatusCounterMonitorThread

Deprecated.

stop() - Method in class org.apache.streams.local.builders.LocalStreamBuilder

NOT IMPLEMENTED.

stopInternal(boolean) - Method in class org.apache.streams.local.builders.LocalStreamBuilder

stopTask() - Method in class org.apache.streams.local.tasks.StreamsMergeTask

Deprecated.

stopTask() - Method in class org.apache.streams.local.tasks.StreamsPersistWriterTask

stopTask() - Method in class org.apache.streams.local.tasks.StreamsProcessorTask

stopTask() - Method in class org.apache.streams.local.tasks.StreamsProviderTask

stopTask() - Method in interface org.apache.streams.local.tasks.StreamsTask

Informs the task to stop.

STREAM_IDENTIFIER_KEY - Static variable in class org.apache.streams.local.builders.LocalStreamBuilder

StreamComponent - Class in org.apache.streams.local.builders

Stores the implementations of StreamsOperation, the StreamsOperations it is connected to and the necessary metadata to construct a data stream.

StreamComponent(String, StreamsProvider, boolean, StreamsConfiguration) - Constructor for class org.apache.streams.local.builders.StreamComponent

StreamComponent(String, StreamsProvider, DateTime, DateTime, StreamsConfiguration) - Constructor for class org.apache.streams.local.builders.StreamComponent

StreamComponent(String, StreamsProvider, BigInteger, StreamsConfiguration) - Constructor for class org.apache.streams.local.builders.StreamComponent

StreamComponent(String, StreamsProcessor, BlockingQueue<StreamsDatum>, int, StreamsConfiguration) - Constructor for class org.apache.streams.local.builders.StreamComponent

StreamComponent(String, StreamsPersistWriter, BlockingQueue<StreamsDatum>, int, StreamsConfiguration) - Constructor for class org.apache.streams.local.builders.StreamComponent

streamConfig - Variable in class org.apache.streams.local.tasks.BaseStreamsTask

StreamsMergeTask - Class in org.apache.streams.local.tasks

Deprecated.

StreamsMergeTask() - Constructor for class org.apache.streams.local.tasks.StreamsMergeTask

Deprecated.

StreamsMergeTask(StreamsConfiguration) - Constructor for class org.apache.streams.local.tasks.StreamsMergeTask

Deprecated.

StreamsPersistWriterTask - Class in org.apache.streams.local.tasks

StreamsPersistWriterTask(StreamsPersistWriter) - Constructor for class org.apache.streams.local.tasks.StreamsPersistWriterTask

Default constructor.

StreamsPersistWriterTask(StreamsPersistWriter, StreamsConfiguration) - Constructor for class org.apache.streams.local.tasks.StreamsPersistWriterTask

StreamsProcessorTask - Class in org.apache.streams.local.tasks

StreamsProcessorTask(StreamsProcessor) - Constructor for class org.apache.streams.local.tasks.StreamsProcessorTask

Default constructor, uses default sleep time of 500ms when inbound queue is empty

StreamsProcessorTask(StreamsProcessor, StreamsConfiguration) - Constructor for class org.apache.streams.local.tasks.StreamsProcessorTask

StreamsProviderTask - Class in org.apache.streams.local.tasks

StreamsProviderTask(StreamsProvider, boolean, StreamsConfiguration) - Constructor for class org.apache.streams.local.tasks.StreamsProviderTask

Constructor for a StreamsProvider to execute org.apache.streams.core.StreamsProvider:readCurrent()

StreamsProviderTask(StreamsProvider, BigInteger, StreamsConfiguration) - Constructor for class org.apache.streams.local.tasks.StreamsProviderTask

Constructor for a StreamsProvider to execute org.apache.streams.core.StreamsProvider:readNew(BigInteger)

StreamsProviderTask(StreamsProvider, DateTime, DateTime, StreamsConfiguration) - Constructor for class org.apache.streams.local.tasks.StreamsProviderTask

Constructor for a StreamsProvider to execute org.apache.streams.core.StreamsProvider:readRange(DateTime,DateTime)

StreamsTask - Interface in org.apache.streams.local.tasks

Interface for all task that will be used to execute instances of StreamsOperation in local mode.

StreamsTaskCounter - Class in org.apache.streams.local.counters

StreamsTaskCounter(String) - Constructor for class org.apache.streams.local.counters.StreamsTaskCounter

StreamsTaskCounter(String, String, long) - Constructor for class org.apache.streams.local.counters.StreamsTaskCounter

StreamsTaskCounterMXBean - Interface in org.apache.streams.local.counters

T

take() - Method in class org.apache.streams.local.queues.ThroughputQueue

ThroughputQueue<E> - Class in org.apache.streams.local.queues

A BlockingQueue implementation that allows the measure measurement of how data flows through the queue.

ThroughputQueue() - Constructor for class org.apache.streams.local.queues.ThroughputQueue

Creates an unbounded, unregistered ThroughputQueue

ThroughputQueue(String, long) - Constructor for class org.apache.streams.local.queues.ThroughputQueue

ThroughputQueue(int) - Constructor for class org.apache.streams.local.queues.ThroughputQueue

Creates a bounded, unregistered ThroughputQueue

ThroughputQueue(int, String, long) - Constructor for class org.apache.streams.local.queues.ThroughputQueue

ThroughputQueue(String) - Constructor for class org.apache.streams.local.queues.ThroughputQueue

Creates an unbounded, registered ThroughputQueue

ThroughputQueue(String, String, long) - Constructor for class org.apache.streams.local.queues.ThroughputQueue

ThroughputQueue(int, String) - Constructor for class org.apache.streams.local.queues.ThroughputQueue

ThroughputQueue(int, String, String, long) - Constructor for class org.apache.streams.local.queues.ThroughputQueue

Creates a bounded, registered ThroughputQueue

ThroughputQueueMXBean - Interface in org.apache.streams.local.queues

MXBean capable queue that monitors the throughput of the queue

TIMEOUT_KEY - Static variable in class org.apache.streams.local.builders.LocalStreamBuilder

toArray() - Method in class org.apache.streams.local.queues.ThroughputQueue

toArray(T[]) - Method in class org.apache.streams.local.queues.ThroughputQueue

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

W

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

withExecutorShutdownPauseMs(Long) - Method in class org.apache.streams.local.LocalRuntimeConfiguration

withExecutorShutdownWaitMs(Long) - Method in class org.apache.streams.local.LocalRuntimeConfiguration

withMonitoring(MonitoringConfiguration) - Method in class org.apache.streams.local.LocalRuntimeConfiguration

withMonitorShutdownPauseMs(Long) - Method in class org.apache.streams.local.LocalRuntimeConfiguration

withMonitorShutdownWaitMs(Long) - Method in class org.apache.streams.local.LocalRuntimeConfiguration

withShutdownPauseMs(Long) - Method in class org.apache.streams.local.LocalRuntimeConfiguration

withTaskTimeoutMs(Long) - Method in class org.apache.streams.local.LocalRuntimeConfiguration

A B C D E F G H I L N O P R S T W