B C D E F G I L M N O P R S T U V W

B

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

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

C

CLAIMED_ID - Static variable in class org.apache.streams.local.test.processors.PassthroughDatumCounterProcessor

Set of all ids that have been claimed.

CLAIMED_ID - Static variable in class org.apache.streams.local.test.writer.DatumCounterWriter

Set of all ids that have been claimed.

cleanUp() - Method in class org.apache.streams.local.test.processors.DoNothingProcessor

cleanUp() - Method in class org.apache.streams.local.test.processors.PassthroughDatumCounterProcessor

cleanUp() - Method in class org.apache.streams.local.test.processors.SlowProcessor

cleanUp() - Method in class org.apache.streams.local.test.providers.EmptyResultSetProvider

cleanUp() - Method in class org.apache.streams.local.test.providers.NumericMessageProvider

cleanUp() - Method in class org.apache.streams.local.test.writer.DatumCounterWriter

cleanUp() - Method in class org.apache.streams.local.test.writer.DoNothingWriter

cleanUp() - Method in class org.apache.streams.local.test.writer.SystemOutWriter

cleanUp() - Method in class org.apache.streams.test.component.ExpectedDatumsPersistWriter

cleanUp() - Method in class org.apache.streams.test.component.FileReaderProvider

convert(String) - Method in interface org.apache.streams.test.component.StreamsDatumConverter

convert(String) - Method in class org.apache.streams.test.component.StringToDocumentConverter

COUNTS - Static variable in class org.apache.streams.local.test.processors.PassthroughDatumCounterProcessor

The total count of data seen by a all instances of a processor.

COUNTS - Static variable in class org.apache.streams.local.test.writer.DatumCounterWriter

The total count of data seen by a all instances of a processor.

D

DatumCounterWriter - Class in org.apache.streams.local.test.writer

DatumCounterWriter(String) - Constructor for class org.apache.streams.local.test.writer.DatumCounterWriter

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

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

DoNothingProcessor - Class in org.apache.streams.local.test.processors

Created by rebanks on 2/20/14.

DoNothingProcessor() - Constructor for class org.apache.streams.local.test.processors.DoNothingProcessor

DoNothingWriter - Class in org.apache.streams.local.test.writer

Created by rebanks on 2/20/14.

DoNothingWriter() - Constructor for class org.apache.streams.local.test.writer.DoNothingWriter

E

earlyException() - Method in class org.apache.streams.local.tasks.StreamsProviderTaskTest

EmptyResultSetProvider - Class in org.apache.streams.local.test.providers

Provides new, empty instances of result set.

EmptyResultSetProvider() - Constructor for class org.apache.streams.local.test.providers.EmptyResultSetProvider

ensureShutdownWithBlockedQueue() - Method in class org.apache.streams.local.builders.LocalStreamBuilderTest

ExpectedDatumsPersistWriter - Class in org.apache.streams.test.component

Created by rebanks on 2/27/14.

ExpectedDatumsPersistWriter(StreamsDatumConverter, String) - Constructor for class org.apache.streams.test.component.ExpectedDatumsPersistWriter

F

FileReaderProvider - Class in org.apache.streams.test.component

FOR TESTING PURPOSES ONLY.

FileReaderProvider(String, StreamsDatumConverter) - Constructor for class org.apache.streams.test.component.FileReaderProvider

flushes() - Method in class org.apache.streams.local.tasks.StreamsProviderTaskTest

G

getDatumsCounted() - Method in class org.apache.streams.local.test.writer.DatumCounterWriter

getId() - Method in class org.apache.streams.local.test.processors.DoNothingProcessor

getId() - Method in class org.apache.streams.local.test.processors.PassthroughDatumCounterProcessor

getId() - Method in class org.apache.streams.local.test.processors.SlowProcessor

getId() - Method in class org.apache.streams.local.test.providers.EmptyResultSetProvider

getId() - Method in class org.apache.streams.local.test.providers.NumericMessageProvider

getId() - Method in class org.apache.streams.local.test.writer.DatumCounterWriter

getId() - Method in class org.apache.streams.local.test.writer.DoNothingWriter

getId() - Method in class org.apache.streams.local.test.writer.SystemOutWriter

getId() - Method in class org.apache.streams.test.component.ExpectedDatumsPersistWriter

getId() - Method in class org.apache.streams.test.component.FileReaderProvider

getMessageCount() - Method in class org.apache.streams.local.test.processors.PassthroughDatumCounterProcessor

getQueue(int) - Method in class org.apache.streams.local.tasks.StreamsProviderTaskTest

I

isRunning() - Method in class org.apache.streams.local.test.providers.EmptyResultSetProvider

isRunning() - Method in class org.apache.streams.local.test.providers.NumericMessageProvider

isRunning() - Method in class org.apache.streams.test.component.FileReaderProvider

L

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

Basic Tests for the LocalStreamBuilder.

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

M

main(String[]) - Static method in class org.apache.streams.local.builders.ToyLocalBuilderExample

A simple example of how to run a stream in local mode.

mockProvider - Variable in class org.apache.streams.local.tasks.StreamsProviderTaskTest

N

NumericMessageProvider - Class in org.apache.streams.local.test.providers

Test StreamsProvider that sends out StreamsDatums numbered from 0 to numMessages.

NumericMessageProvider(int) - Constructor for class org.apache.streams.local.test.providers.NumericMessageProvider

O

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

org.apache.streams.local.test.processors - package org.apache.streams.local.test.processors

org.apache.streams.local.test.providers - package org.apache.streams.local.test.providers

org.apache.streams.local.test.writer - package org.apache.streams.local.test.writer

org.apache.streams.test.component - package org.apache.streams.test.component

org.apache.streams.test.component.tests - package org.apache.streams.test.component.tests

P

PassthroughDatumCounterProcessor - Class in org.apache.streams.local.test.processors

PassthroughDatumCounterProcessor(String) - Constructor for class org.apache.streams.local.test.processors.PassthroughDatumCounterProcessor

pool - Variable in class org.apache.streams.local.tasks.StreamsProviderTaskTest

prepare(Object) - Method in class org.apache.streams.local.test.processors.DoNothingProcessor

prepare(Object) - Method in class org.apache.streams.local.test.processors.PassthroughDatumCounterProcessor

prepare(Object) - Method in class org.apache.streams.local.test.processors.SlowProcessor

prepare(Object) - Method in class org.apache.streams.local.test.providers.EmptyResultSetProvider

prepare(Object) - Method in class org.apache.streams.local.test.providers.NumericMessageProvider

prepare(Object) - Method in class org.apache.streams.local.test.writer.DatumCounterWriter

prepare(Object) - Method in class org.apache.streams.local.test.writer.DoNothingWriter

prepare(Object) - Method in class org.apache.streams.local.test.writer.SystemOutWriter

prepare(Object) - Method in class org.apache.streams.test.component.ExpectedDatumsPersistWriter

prepare(Object) - Method in class org.apache.streams.test.component.FileReaderProvider

process(StreamsDatum) - Method in class org.apache.streams.local.test.processors.DoNothingProcessor

process(StreamsDatum) - Method in class org.apache.streams.local.test.processors.PassthroughDatumCounterProcessor

process(StreamsDatum) - Method in class org.apache.streams.local.test.processors.SlowProcessor

R

RAND - Static variable in class org.apache.streams.local.test.processors.PassthroughDatumCounterProcessor

Random instance to generate ids

RAND - Static variable in class org.apache.streams.local.test.writer.DatumCounterWriter

Random instance to generate ids

readCurrent() - Method in class org.apache.streams.local.test.providers.EmptyResultSetProvider

readCurrent() - Method in class org.apache.streams.local.test.providers.NumericMessageProvider

readCurrent() - Method in class org.apache.streams.test.component.FileReaderProvider

readNew(BigInteger) - Method in class org.apache.streams.local.test.providers.EmptyResultSetProvider

readNew(BigInteger) - Method in class org.apache.streams.local.test.providers.NumericMessageProvider

readNew(BigInteger) - Method in class org.apache.streams.test.component.FileReaderProvider

readRange(DateTime, DateTime) - Method in class org.apache.streams.local.test.providers.EmptyResultSetProvider

readRange(DateTime, DateTime) - Method in class org.apache.streams.local.test.providers.NumericMessageProvider

readRange(DateTime, DateTime) - Method in class org.apache.streams.test.component.FileReaderProvider

RECEIVED - Static variable in class org.apache.streams.local.test.writer.DatumCounterWriter

The documents received

removeLocalMBeans() - Method in class org.apache.streams.local.builders.LocalStreamBuilderTest

removeLocalMBeans() - Method in class org.apache.streams.local.executors.ShutdownStreamOnUnhandledThrowableThreadPoolExecutorTest

removeLocalMBeans() - Method in class org.apache.streams.local.queues.ThroughputQueueMultiThreadTest

removeLocalMBeans() - Method in class org.apache.streams.local.queues.ThroughputQueueSingleThreadTest

removeLocalMBeans() - Method in class org.apache.streams.local.tasks.BasicTasksTest

removeLocalMBeans() - Method in class org.apache.streams.local.tasks.StreamsProviderTaskTest

removeLocalMBeans() - Method in class org.apache.streams.test.component.tests.TestComponentsLocalStream

removeLocalMBeans() - Method in class org.apache.streams.test.component.tests.TestExpectedDatumsPersitWriter

removeLocalMBeans() - Method in class org.apache.streams.test.component.tests.TestFileReaderProvider

removeRegisteredMBeans(String...) - Method in class org.apache.streams.local.builders.LocalStreamBuilderTest

runNonPerpetual() - Method in class org.apache.streams.local.tasks.StreamsProviderTaskTest

runPerpetual() - Method in class org.apache.streams.local.tasks.StreamsProviderTaskTest

S

SEEN_DATA - Static variable in class org.apache.streams.local.test.processors.PassthroughDatumCounterProcessor

Set of instance ids that received data.

SEEN_DATA - Static variable in class org.apache.streams.local.test.writer.DatumCounterWriter

Set of instance ids that received data.

setup() - Method in class org.apache.streams.local.tasks.StreamsProviderTaskTest

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

ShutdownStreamOnUnhandledThrowableThreadPoolExecutorTest() - Constructor for class org.apache.streams.local.executors.ShutdownStreamOnUnhandledThrowableThreadPoolExecutorTest

SlowProcessor - Class in org.apache.streams.local.test.processors

SlowProcessor() - Constructor for class org.apache.streams.local.test.processors.SlowProcessor

startStream() - Method in class org.apache.streams.local.test.providers.EmptyResultSetProvider

startStream() - Method in class org.apache.streams.local.test.providers.NumericMessageProvider

startStream() - Method in class org.apache.streams.test.component.FileReaderProvider

stoppable() - Method in class org.apache.streams.local.tasks.StreamsProviderTaskTest

STREAMS_ID - Static variable in class org.apache.streams.local.test.processors.DoNothingProcessor

STREAMS_ID - Static variable in class org.apache.streams.local.test.processors.PassthroughDatumCounterProcessor

STREAMS_ID - Static variable in class org.apache.streams.local.test.processors.SlowProcessor

StreamsDatumConverter - Interface in org.apache.streams.test.component

Created by rebanks on 2/27/14.

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

Tests the StreamsProviderTask.

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

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

Unit tests for StreamsTaskCounter

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

StringToDocumentConverter - Class in org.apache.streams.test.component

Created by rebanks on 2/28/14.

StringToDocumentConverter() - Constructor for class org.apache.streams.test.component.StringToDocumentConverter

SystemOutWriter - Class in org.apache.streams.local.test.writer

Created by rebanks on 2/20/14.

SystemOutWriter() - Constructor for class org.apache.streams.local.test.writer.SystemOutWriter

T

testAddAndRemove() - Method in class org.apache.streams.local.queues.ThroughputQueueSingleThreadTest

Test that add and remove queue and dequeue data as expected and all measurements from the queue are returning data

testBasicBranch() - Method in class org.apache.streams.local.builders.LocalStreamBuilderTest

testBasicLinearStream1() - Method in class org.apache.streams.local.builders.LocalStreamBuilderTest

testBasicLinearStream2() - Method in class org.apache.streams.local.builders.LocalStreamBuilderTest

testBasicLinearStream3() - Method in class org.apache.streams.local.builders.LocalStreamBuilderTest

testBasicLinearStreamRandom() - Method in class org.apache.streams.local.builders.LocalStreamBuilderTest

testBasicMergeStream() - Method in class org.apache.streams.local.builders.LocalStreamBuilderTest

testBlockOnEmptyQueue() - Method in class org.apache.streams.local.queues.ThroughputQueueMultiThreadTest

Test that queue will block on Take when queue is empty

testBlockOnFullQueue() - Method in class org.apache.streams.local.queues.ThroughputQueueMultiThreadTest

Test that queue will block on puts when the queue is full

testBranching() - Method in class org.apache.streams.local.tasks.BasicTasksTest

testBranchingSerialization() - Method in class org.apache.streams.local.tasks.BasicTasksTest

TestComponentsLocalStream - Class in org.apache.streams.test.component.tests

TestComponentsLocalStream() - Constructor for class org.apache.streams.test.component.tests.TestComponentsLocalStream

testConfiguredProviderTimeout() - Method in class org.apache.streams.local.builders.LocalStreamBuilderTest

testConstructor() - Method in class org.apache.streams.local.counters.DatumStatusCounterTest

Test Constructor can register the counter as an mxbean with throwing an exception.

testConstructor() - Method in class org.apache.streams.local.counters.StreamsTaskCounterTest

Test constructor does not throw errors

testEmitted() - Method in class org.apache.streams.local.counters.StreamsTaskCounterTest

Test emitted increments correctly and returns expected value

testError() - Method in class org.apache.streams.local.counters.StreamsTaskCounterTest

Test errors increments correctly and returns expected value

testErrorRate() - Method in class org.apache.streams.local.counters.StreamsTaskCounterTest

Test error rate returns expected value

testExpectedDatumsPersistWriterFileName() - Method in class org.apache.streams.test.component.tests.TestExpectedDatumsPersitWriter

TestExpectedDatumsPersitWriter - Class in org.apache.streams.test.component.tests

TestExpectedDatumsPersitWriter() - Constructor for class org.apache.streams.test.component.tests.TestExpectedDatumsPersitWriter

testFailed() - Method in class org.apache.streams.local.counters.DatumStatusCounterTest

Test that you can increment failed and it returns the correct count

testFailureRate() - Method in class org.apache.streams.local.counters.DatumStatusCounterTest

Test failure rate returns expected values

TestFileReaderProvider - Class in org.apache.streams.test.component.tests

TestFileReaderProvider() - Constructor for class org.apache.streams.test.component.tests.TestFileReaderProvider

testFileReaderProviderFileName() - Method in class org.apache.streams.test.component.tests.TestFileReaderProvider

testLocalStreamWithComponent() - Method in class org.apache.streams.test.component.tests.TestComponentsLocalStream

testMBeanRegistration() - Method in class org.apache.streams.local.queues.ThroughputQueueSingleThreadTest

Test that the mbean registers

testMergeTask() - Method in class org.apache.streams.local.tasks.BasicTasksTest

testMultipleMBeanRegistrations() - Method in class org.apache.streams.local.queues.ThroughputQueueSingleThreadTest

Test that mulitple mbeans of the same type with a different name can be registered

testMultiThreadAccessAndInteruptResponse() - Method in class org.apache.streams.local.queues.ThroughputQueueMultiThreadTest

Test multiple threads putting and taking from the queue while this thread repeatedly calls the MXBean measurement methods.

testNormalExecution() - Method in class org.apache.streams.local.executors.ShutdownStreamOnUnhandledThrowableThreadPoolExecutorTest

testOfferAndPoll() - Method in class org.apache.streams.local.queues.ThroughputQueueSingleThreadTest

Test that offer and poll queue and dequeue data as expected and all measurements from the queue are returning data

testParallelLinearStream1() - Method in class org.apache.streams.local.builders.LocalStreamBuilderTest

testPassed() - Method in class org.apache.streams.local.counters.DatumStatusCounterTest

Test that you can increment passes and it returns the correct count

testProcessorTask() - Method in class org.apache.streams.local.tasks.BasicTasksTest

testProviderTask() - Method in class org.apache.streams.local.tasks.BasicTasksTest

testReceived() - Method in class org.apache.streams.local.counters.StreamsTaskCounterTest

Test received increments correctly and returns expected value

testShutDownOnException() - Method in class org.apache.streams.local.executors.ShutdownStreamOnUnhandledThrowableThreadPoolExecutorTest

testSlowProcessorBranch() - Method in class org.apache.streams.local.builders.LocalStreamBuilderTest

testStreamIdValidations() - Method in class org.apache.streams.local.builders.LocalStreamBuilderTest

testTakeAndPut() - Method in class org.apache.streams.local.queues.ThroughputQueueSingleThreadTest

Test that take and put queue and dequeue data as expected and all measurements form the queue are returning data.

testThroughput() - Method in class org.apache.streams.local.queues.ThroughputQueueSingleThreadTest

Test that throughput returns expected values.

testWait() - Method in class org.apache.streams.local.queues.ThroughputQueueSingleThreadTest

Test that max wait and avg wait return expected values

testWriterTask() - Method in class org.apache.streams.local.tasks.BasicTasksTest

ThroughputQueueMultiThreadTest - Class in org.apache.streams.local.queues

MultiThread unit tests for ThroughputQueue

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

ThroughputQueueSingleThreadTest - Class in org.apache.streams.local.queues

Single thread unit tests for ThroughputQueue

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

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

Created by rebanks on 2/20/14.

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

U

unregisterMXBean() - Method in class org.apache.streams.local.counters.DatumStatusCounterTest

Remove registered mbeans from previous tests

unregisterMXBean() - Method in class org.apache.streams.local.counters.StreamsTaskCounterTest

Remove registered mbeans from previous tests

unregisterMXBean() - Method in class org.apache.streams.local.queues.ThroughputQueueMultiThreadTest

Remove registered mbeans from previous tests

V

verifyNotRunning(StreamsProviderTask, Future<?>) - Method in class org.apache.streams.local.tasks.StreamsProviderTaskTest

W

write(StreamsDatum) - Method in class org.apache.streams.local.test.writer.DatumCounterWriter

write(StreamsDatum) - Method in class org.apache.streams.local.test.writer.DoNothingWriter

write(StreamsDatum) - Method in class org.apache.streams.local.test.writer.SystemOutWriter

write(StreamsDatum) - Method in class org.apache.streams.test.component.ExpectedDatumsPersistWriter

B C D E F G I L M N O P R S T U V W