package
sparkbindings
Type Members
-
type
BlockifiedDrmRdd[K] = RDD[(Array[K], Matrix)]
-
type
DrmRdd[K] = RDD[(K, Vector)]
Value Members
-
implicit
def
cpDrm2cpDrmSparkOps[K](drm: CheckpointedDrm[K])(implicit arg0: ClassTag[K]): CheckpointedDrmSparkOps[K]
-
implicit
def
dc2sc(dc: DistributedContext): SparkContext
-
implicit
def
drm2cpDrmSparkOps[K](drm: DrmLike[K])(implicit arg0: ClassTag[K]): CheckpointedDrmSparkOps[K]
-
def
drmWrap[K](rdd: DrmRdd[K], nrow: Int, ncol: Int, cacheHint: CacheHint, canHaveMissingRows: Boolean)(implicit arg0: ClassTag[K]): CheckpointedDrm[K]
-
def
mahoutSparkContext(masterUrl: String, appName: String, customJars: TraversableOnce[String], sparkConf: SparkConf, addMahoutJars: Boolean): SparkDistributedContext
-
implicit
def
sb2bc[T](b: Broadcast[T]): BCast[T]
-
implicit
def
sc2sdc(sc: SparkContext): SparkDistributedContext
-
implicit
def
sdc2sc(sdc: SparkDistributedContext): SparkContext
-