In [1]:
sc.getConf.toDebugString
Out[1]:
In [3]:
val rdd = sc.parallelize(List(1, 2, 3, 4, 5))
In [4]:
rdd.reduce(_+_)
Out[4]:
In [11]:
Out[11]:
In [6]:
kernel.comm
Out[6]:
In [ ]:
kernel