- 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
-
- ThroughputQueueMultiThreadTest() - Constructor for class org.apache.streams.local.queues.ThroughputQueueMultiThreadTest
-
- ThroughputQueueSingleThreadTest - Class in org.apache.streams.local.queues
-
- 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
-