I tried to count individual words using spark streaming. Here I am using Netcat for providing input using socket concept.But I am not able to get the output, though it is not showing any error.
Can someone tell me the error?
Seems like master and worker are not ...READ MORE
I found 2 links on github where ...READ MORE
You lose the files because by default, ...READ MORE
you can access task information using TaskContext:
sc.parallelize(Seq[Int](), ...READ MORE
You can get the configuration details through ...READ MORE
In your test class you passed empid ...READ MORE
Instead of spliting on '\n'. You should ...READ MORE
Though Spark and Hadoop were the frameworks designed ...READ MORE
Dstreams are the basic abstraction that is ...READ MORE
Yes, Spark streaming uses checkpoint. Checkpoint is ...READ MORE
Already have an account? Sign in.