Local Multithreading with delay between events (configured in bin/samoa-threads.properties)
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
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
Add unit tests for simple mode
Fixed bug with negative hashcode value
Implementation of SAMOA on Samza
Include hadoop common and hdfs jars in the package
Add some comments, clean up some parts