Removing offset management code that is non-existent in kafka 0.7.0+
StateDStream changes to give updateStateByKey consistent behavior
Merge branch 'streaming' into sm-updateStateByKey
kafka jar wasn't being included by run script
further KafkaInputDStream cleanup (removing unused and commented out code relating to offset management)
kafkaStream API cleanup. A quorum of zookeepers can now be specified
Changed method name of createReceiver to getReceiver as it is not intended to be a factory.
Plug in actor as stream receiver API
adding updateStateByKey object lifecycle test
Splitting StreamingContext.queueStream into two methods
Changed method name of createReceiver to getReceiver as it is not intended to be a factory.
add ensime
actor as receiver
Refactored DStreamCheckpointData.
Added support for saving input files of FileInputDStream to graph checkpoints. Modified 'file input stream with checkpoint' testcase to test recovery of pre-master-failure input files.
Added support for rescheduling unprocessed batches on master failure.
Fixed checkpoint testcases
Merge branch 'mesos'
Improved document comment in example
Update spark_ec2.py to use new spark-ec2 scripts