unsubscribe
unsubscribe
i would like to write a custom receiver to receive data from a Tibco RV subject
i found this scala example..
http://spark.incubator.apache.org/docs/0.8.0/streaming-custom-receivers.html
but i cant seem to find a java example
does anybody know of a good java example for creating a custom receiver
th
hello..
i am on my second day with spark.. and im having trouble getting the foreach
function to work with the network wordcount example.. i can see the the
"flatMap" and "map" methods are being invoked.. but i dont seem to be getting
into the foreach method... not sure if what i am doing even m
Hello
i just started working with spark today... and i am trying to run the wordcount
network example
i created a socket server and client.. and i am sending data to the server in
an infinite loop
when i run the spark class.. i see this output in the console...
---
