Local Multithreading with delay between events (configured in bin/samoa-threads.properties)
Merge branch 'entranceprocessor' of https://github.com/caseyvu/samoa into entranceprocessor
First merge
Remove extra echo in bin/samoa
1. Add field comments
2. Change helper submitTopology to private
JUnit test cases and some refactoring as result of writing the tests.
Print number of threads and delay(ms) (from samoa-threads.properties file) before running task.
Fix a bug with thread indice and read numThreads,delay parameters from commandline
Move EventAllocationType enum to samoa-api utils
Rename {set/get}NumberThreads to {set/get}NumberOfThreads in ThreadsEngine
Number of threads and source delay are provided from cmd line. Source delay is an option for Task.
Previous commit misses out this testcase
a short javadoc comment for ThreadsEventRunnable class
Move the delay implementation from topology to entranceprocessor
fix bug: no delay case
Add short Javadoc for classes in multithreaded engine
Rename some classes, add comments, some minor refactoring:
1. Rename EventAllocationType to PartitioningScheme, DestinationPIWrapper to StreamDestination, ThreadsWorkerProcessingItem to ThreadsProcessingItemInstance
2. Use StreamDestination to represents a stream's destination. To add a destination, pass an object of StreamDestination to the stream.
Refactoring:
1. Local single thread mode: use PartitioningScheme enum, StreamDestination when connect PI to stream
2. Move StreamDestination to samoa-api utils
Fix bug with parallelism in SimpleStream
Add unit tests for simple mode
Init timer in onCreate() of PrequentialSourceProcessor