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

Constructors

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

Method Summary

Modifier and Type	Method and Description
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, coalesce, collect, collect, context, count, countApprox, countApproxDistinct, countApproxDistinct, countByValue, countByValueApprox, dependencies, distinct, distinct, doubleRDDToDoubleRDDFunctions, filter, first, flatMap, fold, foreach, foreachPartition, getCheckpointFile, getNumPartitions, getStorageLevel, glom, groupBy, groupBy, groupBy, id, intersection, intersection, intersection, isCheckpointed, isEmpty, iterator, keyBy, localCheckpoint, map, mapPartitions, mapPartitionsWithIndex, max, min, name, numericRDDToDoubleRDDFunctions, partitioner, partitions, persist, persist, pipe, pipe, pipe, preferredLocations, randomSplit, rddToAsyncRDDActions, rddToOrderedRDDFunctions, rddToPairRDDFunctions, rddToSequenceFileRDDFunctions, reduce, repartition, sample, saveAsObjectFile, saveAsTextFile, saveAsTextFile, setName, sortBy, sparkContext, subtract, subtract, subtract, take, takeOrdered, takeSample, 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.internal.Logging

initializeLogging, initializeLogIfNecessary, initializeLogIfNecessary, 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,
                  Object[] broadcastVars,
                  scala.reflect.ClassTag<T> evidence$5)

Method Detail

asJavaRDD

public JavaRDD<String> asJavaRDD()