userstream now writing to ES in real-time
Updated Persist writer to have a configurable background flush thread
Updated termination process
Fixed deadlock issue
Fixed issue where exception terminated thread and it wouldn't start again
Added user information and made some other modifications to increase the readability.
S3 Reader / Writer for apache streams
https://issues.apache.org/jira/browse/STREAMS-73
Resolves https://issues.apache.org/jira/browse/STREAMS-70
Sorry, this isn't even being used.
Changes based on feedback.
That was a debugging statement, pardon.
Added licenses, and more code formatting to comply with styles.
Switched everything over to ComponentUtils.offerUntilSuccess per @mFranklin's request.
resolves https://issues.apache.org/jira/browse/STREAMS-60
Changes necessary to satisfy JIRA issues STREAMS-75,76,77 for Streams' URL Unwinder
sorry, changed the delay time to 1 second.
merging fixes and addressing serialization problems to get twitter streams-examples working.
fixes to get streams-examples working
Changed this test for speed, has no effect on the outcome.