public class StringRRDD<T> extends BaseRRDD<T,java.lang.String>
Constructor and Description |
---|
StringRRDD(RDD<T> parent,
byte[] func,
java.lang.String deserializer,
byte[] packageNames,
java.lang.Object[] broadcastVars,
scala.reflect.ClassTag<T> evidence$5) |
Modifier and Type | Method and Description |
---|---|
JavaRDD<java.lang.String> |
asJavaRDD() |
compute, getPartitions
aggregate, cache, cartesian, checkpoint, clearDependencies, coalesce, collect, collect, context, count, countApprox, countApproxDistinct, countApproxDistinct, countByValue, countByValueApprox, dependencies, distinct, distinct, doubleRDDToDoubleRDDFunctions, filter, first, firstParent, flatMap, fold, foreach, foreachPartition, getCheckpointFile, getDependencies, getNumPartitions, getPreferredLocations, getStorageLevel, glom, groupBy, groupBy, groupBy, id, initializeLogIfNecessary, intersection, intersection, intersection, isCheckpointed, isEmpty, isTraceEnabled, iterator, keyBy, localCheckpoint, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning, map, mapPartitions, mapPartitionsWithIndex, max, min, name, numericRDDToDoubleRDDFunctions, parent, 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