Refactor to implement Spark Streaming semantics
Refactor to implement Spark Streaming semantics