org.apache.spark.api.r
Class StringRRDD<T>

Object
  org.apache.spark.rdd.RDD<U>
      org.apache.spark.api.r.BaseRRDD<T,String>
          org.apache.spark.api.r.StringRRDD<T>

All Implemented Interfaces:

java.io.Serializable, Logging

public class StringRRDD<T>
extends BaseRRDD<T,String>

An RDD that stores R objects as Array[String].

See Also:

Serialized Form

Constructor Summary

StringRRDD(RDD<T> parent, byte[] func, String deserializer, byte[] packageNames, String rLibDir, Object[] broadcastVars, scala.reflect.ClassTag<T> evidence$5)

Method Summary

JavaRDD<String>

asJavaRDD()

Methods inherited from class org.apache.spark.api.r.BaseRRDD

compute, getPartitions

Methods inherited from class org.apache.spark.rdd.RDD

aggregate, cache, cartesian, checkpoint, checkpointData, coalesce, collect, collect, context, count, countApprox, countApproxDistinct, countApproxDistinct, countByValue, countByValueApprox, creationSite, dependencies, distinct, distinct, doubleRDDToDoubleRDDFunctions, filter, filterWith, first, flatMap, flatMapWith, fold, foreach, foreachPartition, foreachWith, getCheckpointFile, getStorageLevel, glom, groupBy, groupBy, groupBy, id, intersection, intersection, intersection, isCheckpointed, isEmpty, iterator, keyBy, map, mapPartitions, mapPartitionsWithContext, mapPartitionsWithIndex, mapPartitionsWithSplit, mapWith, max, min, name, numericRDDToDoubleRDDFunctions, partitioner, partitions, persist, persist, pipe, pipe, pipe, preferredLocations, randomSplit, rddToAsyncRDDActions, rddToOrderedRDDFunctions, rddToPairRDDFunctions, rddToSequenceFileRDDFunctions, reduce, repartition, sample, saveAsObjectFile, saveAsTextFile, saveAsTextFile, scope, setName, sortBy, sparkContext, subtract, subtract, subtract, take, takeOrdered, takeSample, toArray, toDebugString, toJavaRDD, toLocalIterator, top, toString, treeAggregate, treeReduce, union, unpersist, zip, zipPartitions, zipPartitions, zipPartitions, zipPartitions, zipPartitions, zipPartitions, zipWithIndex, zipWithUniqueId

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.spark.Logging

initializeIfNecessary, initializeLogging, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning

Constructor Detail

StringRRDD

public StringRRDD(RDD<T> parent,
                  byte[] func,
                  String deserializer,
                  byte[] packageNames,
                  String rLibDir,
                  Object[] broadcastVars,
                  scala.reflect.ClassTag<T> evidence$5)

Method Detail

asJavaRDD

public JavaRDD<String> asJavaRDD()