Initial commit
Initial commit. Modify .gitignore.
Maven-ize the project. Add codes for skeleton
Implement simple word counter using twitter
Use Twitter sample stream. Run on Storm local cluster for 10 seconds.
Add exponential forgetting word count.
Time is not taken into account
Add exponential forgetting word count.
Rename previous exponential forgetting word count as EWMA
Correct implementation of exponential forgetting
Change the bolt name to ForwardDecayCountWord
This implementation is based on Forward Decay technique in Cormode's
paper titled "Forward Decay: A Practical Time Decay Model for Streaming
Systems. The chosen decay function is exponential decay to count the
occurence of certain words in Twitter's sample stream
Add more application details in README.md
Modify pom.xml to produce cluster-executable jar
Modify ForwardDecayCountWord bolt and TwitterWordCountTopology
ForwardDecayCountWord has new constructor to accept output frequency and
decay-alpha value.
Cluster-executable means the jar file is ready to be executed in Storm
cluster (fully distributed mode).
Add more details on program execution