Modifications to use hdfs instead of local filesystem; Updated StreamQueueToHadoop to invoke sample data stream.
Replacing kafka consumer approach with Storm spout & corresponding Bolt to write to Hadoop.  Currently has issues with clojure core / storm namespace collision - working to resolve.