Hi,
Thank you for the response.
Regards,
Madhukara Phatak
http://datamantra.io/
On Tue, Mar 17, 2015 at 5:50 AM, Tathagata Das t...@databricks.com wrote:
It was not really meant to be pubic and overridden. Because anything you
want to do to generate jobs from RDDs can be done using
It was not really meant to be pubic and overridden. Because anything you
want to do to generate jobs from RDDs can be done using DStream.foreachRDD
On Sun, Mar 15, 2015 at 11:14 PM, madhu phatak phatak@gmail.com wrote:
Hi,
I am trying to create a simple subclass of DStream. If I
Hi,
I am trying to create a simple subclass of DStream. If I understand
correctly, I should override *compute *lazy operations and *generateJob*
for actions. But when I try to override, generateJob it gives error saying
method is private to the streaming package. Is my approach is correct or am
