Home > other >  The spark small demo in the cluster process
The spark small demo in the cluster process

Time:09-26

A word count of the spark program, the following

The main () {
Val a=...
Val sparkConf=new sparkConf ()...
Val SSC=new StreamingContext...

//business code
.
SSC. Start ()
SSC. AwaitTermination ()
}

What was it in the cluster process,
My understanding is:
A value assignment and initialization of SSC is executed only once, but with the relevant business code of SSC is with SSC. AwaitTermination () again and again, is that so
  • Related