org.apache.spark.TaskContext.addOnCompleteCallback(Function0) |
org.apache.spark.api.java.StorageLevels.create(boolean, boolean, boolean, int) |
org.apache.spark.api.java.JavaSparkContext.defaultMinSplits()
|
org.apache.spark.streaming.api.java.JavaDStreamLike.foreach(Function)
As of release 0.9.0, replaced by foreachRDD
|
org.apache.spark.streaming.api.java.JavaDStreamLike.foreach(Function2)
As of release 0.9.0, replaced by foreachRDD
|
org.apache.spark.mllib.util.MLUtils.loadLabeledData(SparkContext, String)
|
org.apache.spark.TaskContext.runningLocally() |
org.apache.spark.mllib.util.MLUtils.saveLabeledData(RDD, String)
|
org.apache.spark.mllib.optimization.LBFGS.setMaxNumIterations(int)
|
org.apache.spark.api.java.JavaRDDLike.toArray()
|