Hello,
I tried to use sparkSQL to analyse json data streams within a standalone
application.
here the code snippet that receive the streaming data:
*final JavaReceiverInputDStream lines =
streamCtx.socketTextStream("localhost", Integer.parseInt(args[0]),
StorageLevel.MEMORY_AND_DISK_SER_2());*
Hi,
I installed a standalone spark cluster with two workers. I developed a Java
Application that use the maven dependency of spark (same version as the
spark cluster).
In my class Spark jobs I have only two methods considered as two different
jobs:
the first one is the example of spark word