Class

com.datastax.spark.connector.japi.rdd

CassandraJavaPairRDD

Related Doc: package rdd

Permalink

class CassandraJavaPairRDD[K, V] extends JavaPairRDD[K, V]

Linear Supertypes
JavaPairRDD[K, V], AbstractJavaRDDLike[(K, V), JavaPairRDD[K, V]], JavaRDDLike[(K, V), JavaPairRDD[K, V]], Serializable, Serializable, AnyRef, Any
Known Subclasses
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. CassandraJavaPairRDD
  2. JavaPairRDD
  3. AbstractJavaRDDLike
  4. JavaRDDLike
  5. Serializable
  6. Serializable
  7. AnyRef
  8. Any
Implicitly
  1. by toRDD
  2. by any2stringadd
  3. by StringFormat
  4. by Ensuring
  5. by ArrowAssoc
  1. Hide All
  2. Show all
Visibility
  1. Public
  2. All

Instance Constructors

  1. new CassandraJavaPairRDD(rdd: CassandraRDD[(K, V)], keyClass: Class[K], valueClass: Class[V])

    Permalink
  2. new CassandraJavaPairRDD(rdd: CassandraRDD[(K, V)], keyClassTag: ClassTag[K], valueClassTag: ClassTag[V])

    Permalink

Value Members

  1. final def !=(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  3. def +(other: String): String

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to any2stringadd[CassandraJavaPairRDD[K, V]] performed by method any2stringadd in scala.Predef.
    Definition Classes
    any2stringadd
  4. def ++(other: RDD[(K, V)]): RDD[(K, V)]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Definition Classes
    RDD
  5. def ->[B](y: B): (CassandraJavaPairRDD[K, V], B)

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to ArrowAssoc[CassandraJavaPairRDD[K, V]] performed by method ArrowAssoc in scala.Predef.
    Definition Classes
    ArrowAssoc
    Annotations
    @inline()
  6. final def ==(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  7. def aggregate[U](zeroValue: U)(seqOp: Function2[U, (K, V), U], combOp: Function2[U, U, U]): U

    Permalink
    Definition Classes
    JavaRDDLike
  8. def aggregateByKey[U](zeroValue: U, seqFunc: Function2[U, V, U], combFunc: Function2[U, U, U]): JavaPairRDD[K, U]

    Permalink
    Definition Classes
    JavaPairRDD
  9. def aggregateByKey[U](zeroValue: U, numPartitions: Int, seqFunc: Function2[U, V, U], combFunc: Function2[U, U, U]): JavaPairRDD[K, U]

    Permalink
    Definition Classes
    JavaPairRDD
  10. def aggregateByKey[U](zeroValue: U, partitioner: Partitioner, seqFunc: Function2[U, V, U], combFunc: Function2[U, U, U]): JavaPairRDD[K, U]

    Permalink
    Definition Classes
    JavaPairRDD
  11. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any
  12. def barrier(): RDDBarrier[(K, V)]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Definition Classes
    RDD
    Annotations
    @Experimental() @Since( "2.4.0" )
  13. def cache(): JavaPairRDD[K, V]

    Permalink
    Definition Classes
    JavaPairRDD
  14. def cartesian[U](other: JavaRDDLike[U, _]): JavaPairRDD[(K, V), U]

    Permalink
    Definition Classes
    JavaRDDLike
  15. def cassandraCount(): Long

    Permalink
  16. def checkpoint(): Unit

    Permalink
    Definition Classes
    JavaRDDLike
  17. val classTag: ClassTag[(K, V)]

    Permalink
    Definition Classes
    JavaPairRDD → JavaRDDLike
  18. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  19. def coalesce(numPartitions: Int, shuffle: Boolean): JavaPairRDD[K, V]

    Permalink
    Definition Classes
    JavaPairRDD
  20. def coalesce(numPartitions: Int): JavaPairRDD[K, V]

    Permalink
    Definition Classes
    JavaPairRDD
  21. def cogroup[W1, W2, W3](other1: JavaPairRDD[K, W1], other2: JavaPairRDD[K, W2], other3: JavaPairRDD[K, W3], numPartitions: Int): JavaPairRDD[K, (Iterable[V], Iterable[W1], Iterable[W2], Iterable[W3])]

    Permalink
    Definition Classes
    JavaPairRDD
  22. def cogroup[W1, W2](other1: JavaPairRDD[K, W1], other2: JavaPairRDD[K, W2], numPartitions: Int): JavaPairRDD[K, (Iterable[V], Iterable[W1], Iterable[W2])]

    Permalink
    Definition Classes
    JavaPairRDD
  23. def cogroup[W](other: JavaPairRDD[K, W], numPartitions: Int): JavaPairRDD[K, (Iterable[V], Iterable[W])]

    Permalink
    Definition Classes
    JavaPairRDD
  24. def cogroup[W1, W2, W3](other1: JavaPairRDD[K, W1], other2: JavaPairRDD[K, W2], other3: JavaPairRDD[K, W3]): JavaPairRDD[K, (Iterable[V], Iterable[W1], Iterable[W2], Iterable[W3])]

    Permalink
    Definition Classes
    JavaPairRDD
  25. def cogroup[W1, W2](other1: JavaPairRDD[K, W1], other2: JavaPairRDD[K, W2]): JavaPairRDD[K, (Iterable[V], Iterable[W1], Iterable[W2])]

    Permalink
    Definition Classes
    JavaPairRDD
  26. def cogroup[W](other: JavaPairRDD[K, W]): JavaPairRDD[K, (Iterable[V], Iterable[W])]

    Permalink
    Definition Classes
    JavaPairRDD
  27. def cogroup[W1, W2, W3](other1: JavaPairRDD[K, W1], other2: JavaPairRDD[K, W2], other3: JavaPairRDD[K, W3], partitioner: Partitioner): JavaPairRDD[K, (Iterable[V], Iterable[W1], Iterable[W2], Iterable[W3])]

    Permalink
    Definition Classes
    JavaPairRDD
  28. def cogroup[W1, W2](other1: JavaPairRDD[K, W1], other2: JavaPairRDD[K, W2], partitioner: Partitioner): JavaPairRDD[K, (Iterable[V], Iterable[W1], Iterable[W2])]

    Permalink
    Definition Classes
    JavaPairRDD
  29. def cogroup[W](other: JavaPairRDD[K, W], partitioner: Partitioner): JavaPairRDD[K, (Iterable[V], Iterable[W])]

    Permalink
    Definition Classes
    JavaPairRDD
  30. def collect(): List[(K, V)]

    Permalink
    Definition Classes
    JavaRDDLike
  31. def collectAsMap(): Map[K, V]

    Permalink
    Definition Classes
    JavaPairRDD
  32. def collectAsync(): JavaFutureAction[List[(K, V)]]

    Permalink
    Definition Classes
    JavaRDDLike
  33. def collectPartitions(partitionIds: Array[Int]): Array[List[(K, V)]]

    Permalink
    Definition Classes
    JavaRDDLike
  34. def combineByKey[C](createCombiner: Function[V, C], mergeValue: Function2[C, V, C], mergeCombiners: Function2[C, C, C]): JavaPairRDD[K, C]

    Permalink
    Definition Classes
    JavaPairRDD
  35. def combineByKey[C](createCombiner: Function[V, C], mergeValue: Function2[C, V, C], mergeCombiners: Function2[C, C, C], numPartitions: Int): JavaPairRDD[K, C]

    Permalink
    Definition Classes
    JavaPairRDD
  36. def combineByKey[C](createCombiner: Function[V, C], mergeValue: Function2[C, V, C], mergeCombiners: Function2[C, C, C], partitioner: Partitioner): JavaPairRDD[K, C]

    Permalink
    Definition Classes
    JavaPairRDD
  37. def combineByKey[C](createCombiner: Function[V, C], mergeValue: Function2[C, V, C], mergeCombiners: Function2[C, C, C], partitioner: Partitioner, mapSideCombine: Boolean, serializer: Serializer): JavaPairRDD[K, C]

    Permalink
    Definition Classes
    JavaPairRDD
  38. def compute(split: Partition, context: TaskContext): Iterator[(K, V)]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Definition Classes
    RDD
    Annotations
    @DeveloperApi()
  39. def context: SparkContext

    Permalink
    Definition Classes
    JavaRDDLike
  40. def count(): Long

    Permalink
    Definition Classes
    JavaRDDLike
  41. def countApprox(timeout: Long): PartialResult[BoundedDouble]

    Permalink
    Definition Classes
    JavaRDDLike
  42. def countApprox(timeout: Long, confidence: Double): PartialResult[BoundedDouble]

    Permalink
    Definition Classes
    JavaRDDLike
  43. def countApproxDistinct(relativeSD: Double): Long

    Permalink
    Definition Classes
    JavaRDDLike
  44. def countApproxDistinctByKey(relativeSD: Double): JavaPairRDD[K, Long]

    Permalink
    Definition Classes
    JavaPairRDD
  45. def countApproxDistinctByKey(relativeSD: Double, numPartitions: Int): JavaPairRDD[K, Long]

    Permalink
    Definition Classes
    JavaPairRDD
  46. def countApproxDistinctByKey(relativeSD: Double, partitioner: Partitioner): JavaPairRDD[K, Long]

    Permalink
    Definition Classes
    JavaPairRDD
  47. def countAsync(): JavaFutureAction[Long]

    Permalink
    Definition Classes
    JavaRDDLike
  48. def countByKey(): Map[K, Long]

    Permalink
    Definition Classes
    JavaPairRDD
  49. def countByKeyApprox(timeout: Long, confidence: Double): PartialResult[Map[K, BoundedDouble]]

    Permalink
    Definition Classes
    JavaPairRDD
  50. def countByKeyApprox(timeout: Long): PartialResult[Map[K, BoundedDouble]]

    Permalink
    Definition Classes
    JavaPairRDD
  51. def countByValue(): Map[(K, V), Long]

    Permalink
    Definition Classes
    JavaRDDLike
  52. def countByValueApprox(timeout: Long): PartialResult[Map[(K, V), BoundedDouble]]

    Permalink
    Definition Classes
    JavaRDDLike
  53. def countByValueApprox(timeout: Long, confidence: Double): PartialResult[Map[(K, V), BoundedDouble]]

    Permalink
    Definition Classes
    JavaRDDLike
  54. final def dependencies: Seq[Dependency[_]]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Definition Classes
    RDD
  55. def distinct(numPartitions: Int): JavaPairRDD[K, V]

    Permalink
    Definition Classes
    JavaPairRDD
  56. def distinct(): JavaPairRDD[K, V]

    Permalink
    Definition Classes
    JavaPairRDD
  57. def ensuring(cond: (CassandraJavaPairRDD[K, V]) ⇒ Boolean, msg: ⇒ Any): CassandraJavaPairRDD[K, V]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to Ensuring[CassandraJavaPairRDD[K, V]] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  58. def ensuring(cond: (CassandraJavaPairRDD[K, V]) ⇒ Boolean): CassandraJavaPairRDD[K, V]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to Ensuring[CassandraJavaPairRDD[K, V]] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  59. def ensuring(cond: Boolean, msg: ⇒ Any): CassandraJavaPairRDD[K, V]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to Ensuring[CassandraJavaPairRDD[K, V]] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  60. def ensuring(cond: Boolean): CassandraJavaPairRDD[K, V]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to Ensuring[CassandraJavaPairRDD[K, V]] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  61. final def eq(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  62. def equals(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  63. def filter(f: Function[(K, V), Boolean]): JavaPairRDD[K, V]

    Permalink
    Definition Classes
    JavaPairRDD
  64. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  65. def first(): (K, V)

    Permalink
    Definition Classes
    JavaPairRDD → JavaRDDLike
  66. def flatMap[U](f: FlatMapFunction[(K, V), U]): JavaRDD[U]

    Permalink
    Definition Classes
    JavaRDDLike
  67. def flatMapToDouble(f: DoubleFlatMapFunction[(K, V)]): JavaDoubleRDD

    Permalink
    Definition Classes
    JavaRDDLike
  68. def flatMapToPair[K2, V2](f: PairFlatMapFunction[(K, V), K2, V2]): JavaPairRDD[K2, V2]

    Permalink
    Definition Classes
    JavaRDDLike
  69. def flatMapValues[U](f: Function[V, Iterable[U]]): JavaPairRDD[K, U]

    Permalink
    Definition Classes
    JavaPairRDD
  70. def fold(zeroValue: (K, V))(f: Function2[(K, V), (K, V), (K, V)]): (K, V)

    Permalink
    Definition Classes
    JavaRDDLike
  71. def foldByKey(zeroValue: V, func: Function2[V, V, V]): JavaPairRDD[K, V]

    Permalink
    Definition Classes
    JavaPairRDD
  72. def foldByKey(zeroValue: V, numPartitions: Int, func: Function2[V, V, V]): JavaPairRDD[K, V]

    Permalink
    Definition Classes
    JavaPairRDD
  73. def foldByKey(zeroValue: V, partitioner: Partitioner, func: Function2[V, V, V]): JavaPairRDD[K, V]

    Permalink
    Definition Classes
    JavaPairRDD
  74. def foreach(f: VoidFunction[(K, V)]): Unit

    Permalink
    Definition Classes
    JavaRDDLike
  75. def foreachAsync(f: VoidFunction[(K, V)]): JavaFutureAction[Void]

    Permalink
    Definition Classes
    JavaRDDLike
  76. def foreachPartition(f: VoidFunction[Iterator[(K, V)]]): Unit

    Permalink
    Definition Classes
    JavaRDDLike
  77. def foreachPartitionAsync(f: VoidFunction[Iterator[(K, V)]]): JavaFutureAction[Void]

    Permalink
    Definition Classes
    JavaRDDLike
  78. def formatted(fmtstr: String): String

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to StringFormat[CassandraJavaPairRDD[K, V]] performed by method StringFormat in scala.Predef.
    Definition Classes
    StringFormat
    Annotations
    @inline()
  79. def fullOuterJoin[W](other: JavaPairRDD[K, W], numPartitions: Int): JavaPairRDD[K, (Optional[V], Optional[W])]

    Permalink
    Definition Classes
    JavaPairRDD
  80. def fullOuterJoin[W](other: JavaPairRDD[K, W]): JavaPairRDD[K, (Optional[V], Optional[W])]

    Permalink
    Definition Classes
    JavaPairRDD
  81. def fullOuterJoin[W](other: JavaPairRDD[K, W], partitioner: Partitioner): JavaPairRDD[K, (Optional[V], Optional[W])]

    Permalink
    Definition Classes
    JavaPairRDD
  82. def getCheckpointFile(): Optional[String]

    Permalink
    Definition Classes
    JavaRDDLike
  83. final def getClass(): Class[_]

    Permalink
    Definition Classes
    AnyRef → Any
  84. def getNumPartitions: Int

    Permalink
    Definition Classes
    JavaRDDLike
    Annotations
    @Since( "1.6.0" )
  85. def getStorageLevel: StorageLevel

    Permalink
    Definition Classes
    JavaRDDLike
  86. def glom(): JavaRDD[List[(K, V)]]

    Permalink
    Definition Classes
    JavaRDDLike
  87. def groupBy[U](f: Function[(K, V), U], numPartitions: Int): JavaPairRDD[U, Iterable[(K, V)]]

    Permalink
    Definition Classes
    JavaRDDLike
  88. def groupBy[U](f: Function[(K, V), U]): JavaPairRDD[U, Iterable[(K, V)]]

    Permalink
    Definition Classes
    JavaRDDLike
  89. def groupByKey(): JavaPairRDD[K, Iterable[V]]

    Permalink
    Definition Classes
    JavaPairRDD
  90. def groupByKey(numPartitions: Int): JavaPairRDD[K, Iterable[V]]

    Permalink
    Definition Classes
    JavaPairRDD
  91. def groupByKey(partitioner: Partitioner): JavaPairRDD[K, Iterable[V]]

    Permalink
    Definition Classes
    JavaPairRDD
  92. def groupWith[W1, W2, W3](other1: JavaPairRDD[K, W1], other2: JavaPairRDD[K, W2], other3: JavaPairRDD[K, W3]): JavaPairRDD[K, (Iterable[V], Iterable[W1], Iterable[W2], Iterable[W3])]

    Permalink
    Definition Classes
    JavaPairRDD
  93. def groupWith[W1, W2](other1: JavaPairRDD[K, W1], other2: JavaPairRDD[K, W2]): JavaPairRDD[K, (Iterable[V], Iterable[W1], Iterable[W2])]

    Permalink
    Definition Classes
    JavaPairRDD
  94. def groupWith[W](other: JavaPairRDD[K, W]): JavaPairRDD[K, (Iterable[V], Iterable[W])]

    Permalink
    Definition Classes
    JavaPairRDD
  95. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  96. def id: Int

    Permalink
    Definition Classes
    JavaRDDLike
  97. def intersection(other: JavaPairRDD[K, V]): JavaPairRDD[K, V]

    Permalink
    Definition Classes
    JavaPairRDD
  98. def isCheckpointed: Boolean

    Permalink
    Definition Classes
    JavaRDDLike
  99. def isEmpty(): Boolean

    Permalink
    Definition Classes
    JavaRDDLike
  100. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any
  101. def iterator(split: Partition, taskContext: TaskContext): Iterator[(K, V)]

    Permalink
    Definition Classes
    JavaRDDLike
  102. def join[W](other: JavaPairRDD[K, W], numPartitions: Int): JavaPairRDD[K, (V, W)]

    Permalink
    Definition Classes
    JavaPairRDD
  103. def join[W](other: JavaPairRDD[K, W]): JavaPairRDD[K, (V, W)]

    Permalink
    Definition Classes
    JavaPairRDD
  104. def join[W](other: JavaPairRDD[K, W], partitioner: Partitioner): JavaPairRDD[K, (V, W)]

    Permalink
    Definition Classes
    JavaPairRDD
  105. implicit val kClassTag: ClassTag[K]

    Permalink
    Definition Classes
    JavaPairRDD
  106. def keyBy[U](f: Function[(K, V), U]): JavaPairRDD[U, (K, V)]

    Permalink
    Definition Classes
    JavaRDDLike
  107. def keys(): JavaRDD[K]

    Permalink
    Definition Classes
    JavaPairRDD
  108. def leftOuterJoin[W](other: JavaPairRDD[K, W], numPartitions: Int): JavaPairRDD[K, (V, Optional[W])]

    Permalink
    Definition Classes
    JavaPairRDD
  109. def leftOuterJoin[W](other: JavaPairRDD[K, W]): JavaPairRDD[K, (V, Optional[W])]

    Permalink
    Definition Classes
    JavaPairRDD
  110. def leftOuterJoin[W](other: JavaPairRDD[K, W], partitioner: Partitioner): JavaPairRDD[K, (V, Optional[W])]

    Permalink
    Definition Classes
    JavaPairRDD
  111. def limit(rowsNumber: Long): CassandraJavaPairRDD[K, V]

    Permalink
  112. def localCheckpoint(): RDD[(K, V)]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Definition Classes
    RDD
  113. def lookup(key: K): List[V]

    Permalink
    Definition Classes
    JavaPairRDD
  114. def map[R](f: Function[(K, V), R]): JavaRDD[R]

    Permalink
    Definition Classes
    JavaRDDLike
  115. def mapPartitions[U](f: FlatMapFunction[Iterator[(K, V)], U], preservesPartitioning: Boolean): JavaRDD[U]

    Permalink
    Definition Classes
    JavaRDDLike
  116. def mapPartitions[U](f: FlatMapFunction[Iterator[(K, V)], U]): JavaRDD[U]

    Permalink
    Definition Classes
    JavaRDDLike
  117. def mapPartitionsToDouble(f: DoubleFlatMapFunction[Iterator[(K, V)]], preservesPartitioning: Boolean): JavaDoubleRDD

    Permalink
    Definition Classes
    JavaRDDLike
  118. def mapPartitionsToDouble(f: DoubleFlatMapFunction[Iterator[(K, V)]]): JavaDoubleRDD

    Permalink
    Definition Classes
    JavaRDDLike
  119. def mapPartitionsToPair[K2, V2](f: PairFlatMapFunction[Iterator[(K, V)], K2, V2], preservesPartitioning: Boolean): JavaPairRDD[K2, V2]

    Permalink
    Definition Classes
    JavaRDDLike
  120. def mapPartitionsToPair[K2, V2](f: PairFlatMapFunction[Iterator[(K, V)], K2, V2]): JavaPairRDD[K2, V2]

    Permalink
    Definition Classes
    JavaRDDLike
  121. def mapPartitionsWithIndex[R](f: Function2[Integer, Iterator[(K, V)], Iterator[R]], preservesPartitioning: Boolean): JavaRDD[R]

    Permalink
    Definition Classes
    JavaRDDLike
  122. def mapToDouble[R](f: DoubleFunction[(K, V)]): JavaDoubleRDD

    Permalink
    Definition Classes
    JavaRDDLike
  123. def mapToPair[K2, V2](f: PairFunction[(K, V), K2, V2]): JavaPairRDD[K2, V2]

    Permalink
    Definition Classes
    JavaRDDLike
  124. def mapValues[U](f: Function[V, U]): JavaPairRDD[K, U]

    Permalink
    Definition Classes
    JavaPairRDD
  125. def max(comp: Comparator[(K, V)]): (K, V)

    Permalink
    Definition Classes
    JavaRDDLike
  126. def min(comp: Comparator[(K, V)]): (K, V)

    Permalink
    Definition Classes
    JavaRDDLike
  127. def name(): String

    Permalink
    Definition Classes
    JavaRDDLike
  128. final def ne(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  129. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef
  130. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef
  131. def partitionBy(partitioner: Partitioner): JavaPairRDD[K, V]

    Permalink
    Definition Classes
    JavaPairRDD
  132. def partitioner: Optional[Partitioner]

    Permalink
    Definition Classes
    JavaRDDLike
  133. def partitions: List[Partition]

    Permalink
    Definition Classes
    JavaRDDLike
  134. def perPartitionLimit(rowsNumber: Long): CassandraJavaPairRDD[K, V]

    Permalink
  135. def persist(newLevel: StorageLevel): JavaPairRDD[K, V]

    Permalink
    Definition Classes
    JavaPairRDD
  136. def pipe(command: List[String], env: Map[String, String], separateWorkingDir: Boolean, bufferSize: Int, encoding: String): JavaRDD[String]

    Permalink
    Definition Classes
    JavaRDDLike
  137. def pipe(command: List[String], env: Map[String, String], separateWorkingDir: Boolean, bufferSize: Int): JavaRDD[String]

    Permalink
    Definition Classes
    JavaRDDLike
  138. def pipe(command: List[String], env: Map[String, String]): JavaRDD[String]

    Permalink
    Definition Classes
    JavaRDDLike
  139. def pipe(command: List[String]): JavaRDD[String]

    Permalink
    Definition Classes
    JavaRDDLike
  140. def pipe(command: String): JavaRDD[String]

    Permalink
    Definition Classes
    JavaRDDLike
  141. final def preferredLocations(split: Partition): Seq[String]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Definition Classes
    RDD
  142. def randomSplit(weights: Array[Double], seed: Long): Array[RDD[(K, V)]]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Definition Classes
    RDD
  143. def rdd(): CassandraRDD[(K, V)]

    Permalink
    Definition Classes
    CassandraJavaPairRDD → JavaPairRDD → JavaRDDLike
  144. def reduce(f: Function2[(K, V), (K, V), (K, V)]): (K, V)

    Permalink
    Definition Classes
    JavaRDDLike
  145. def reduceByKey(func: Function2[V, V, V]): JavaPairRDD[K, V]

    Permalink
    Definition Classes
    JavaPairRDD
  146. def reduceByKey(func: Function2[V, V, V], numPartitions: Int): JavaPairRDD[K, V]

    Permalink
    Definition Classes
    JavaPairRDD
  147. def reduceByKey(partitioner: Partitioner, func: Function2[V, V, V]): JavaPairRDD[K, V]

    Permalink
    Definition Classes
    JavaPairRDD
  148. def reduceByKeyLocally(func: Function2[V, V, V]): Map[K, V]

    Permalink
    Definition Classes
    JavaPairRDD
  149. def repartition(numPartitions: Int): JavaPairRDD[K, V]

    Permalink
    Definition Classes
    JavaPairRDD
  150. def repartitionAndSortWithinPartitions(partitioner: Partitioner, comp: Comparator[K]): JavaPairRDD[K, V]

    Permalink
    Definition Classes
    JavaPairRDD
  151. def repartitionAndSortWithinPartitions(partitioner: Partitioner): JavaPairRDD[K, V]

    Permalink
    Definition Classes
    JavaPairRDD
  152. def rightOuterJoin[W](other: JavaPairRDD[K, W], numPartitions: Int): JavaPairRDD[K, (Optional[V], W)]

    Permalink
    Definition Classes
    JavaPairRDD
  153. def rightOuterJoin[W](other: JavaPairRDD[K, W]): JavaPairRDD[K, (Optional[V], W)]

    Permalink
    Definition Classes
    JavaPairRDD
  154. def rightOuterJoin[W](other: JavaPairRDD[K, W], partitioner: Partitioner): JavaPairRDD[K, (Optional[V], W)]

    Permalink
    Definition Classes
    JavaPairRDD
  155. def sample(withReplacement: Boolean, fraction: Double, seed: Long): JavaPairRDD[K, V]

    Permalink
    Definition Classes
    JavaPairRDD
  156. def sample(withReplacement: Boolean, fraction: Double): JavaPairRDD[K, V]

    Permalink
    Definition Classes
    JavaPairRDD
  157. def sampleByKey(withReplacement: Boolean, fractions: Map[K, Double]): JavaPairRDD[K, V]

    Permalink
    Definition Classes
    JavaPairRDD
  158. def sampleByKey(withReplacement: Boolean, fractions: Map[K, Double], seed: Long): JavaPairRDD[K, V]

    Permalink
    Definition Classes
    JavaPairRDD
  159. def sampleByKeyExact(withReplacement: Boolean, fractions: Map[K, Double]): JavaPairRDD[K, V]

    Permalink
    Definition Classes
    JavaPairRDD
  160. def sampleByKeyExact(withReplacement: Boolean, fractions: Map[K, Double], seed: Long): JavaPairRDD[K, V]

    Permalink
    Definition Classes
    JavaPairRDD
  161. def saveAsHadoopDataset(conf: JobConf): Unit

    Permalink
    Definition Classes
    JavaPairRDD
  162. def saveAsHadoopFile[F <: OutputFormat[_, _]](path: String, keyClass: Class[_], valueClass: Class[_], outputFormatClass: Class[F], codec: Class[_ <: CompressionCodec]): Unit

    Permalink
    Definition Classes
    JavaPairRDD
  163. def saveAsHadoopFile[F <: OutputFormat[_, _]](path: String, keyClass: Class[_], valueClass: Class[_], outputFormatClass: Class[F]): Unit

    Permalink
    Definition Classes
    JavaPairRDD
  164. def saveAsHadoopFile[F <: OutputFormat[_, _]](path: String, keyClass: Class[_], valueClass: Class[_], outputFormatClass: Class[F], conf: JobConf): Unit

    Permalink
    Definition Classes
    JavaPairRDD
  165. def saveAsNewAPIHadoopDataset(conf: Configuration): Unit

    Permalink
    Definition Classes
    JavaPairRDD
  166. def saveAsNewAPIHadoopFile[F <: OutputFormat[_, _]](path: String, keyClass: Class[_], valueClass: Class[_], outputFormatClass: Class[F]): Unit

    Permalink
    Definition Classes
    JavaPairRDD
  167. def saveAsNewAPIHadoopFile[F <: OutputFormat[_, _]](path: String, keyClass: Class[_], valueClass: Class[_], outputFormatClass: Class[F], conf: Configuration): Unit

    Permalink
    Definition Classes
    JavaPairRDD
  168. def saveAsObjectFile(path: String): Unit

    Permalink
    Definition Classes
    JavaRDDLike
  169. def saveAsTextFile(path: String, codec: Class[_ <: CompressionCodec]): Unit

    Permalink
    Definition Classes
    JavaRDDLike
  170. def saveAsTextFile(path: String): Unit

    Permalink
    Definition Classes
    JavaRDDLike
  171. def select(selectionColumns: <repeated...>[ColumnRef]): CassandraJavaPairRDD[K, V]

    Permalink
  172. def select(columnNames: <repeated...>[String]): CassandraJavaPairRDD[K, V]

    Permalink
  173. def selectedColumnNames(): Array[String]

    Permalink
  174. def selectedColumnRefs(): Array[ColumnRef]

    Permalink
  175. def setName(name: String): JavaPairRDD[K, V]

    Permalink
    Definition Classes
    JavaPairRDD
  176. def sortBy[K](f: ((K, V)) ⇒ K, ascending: Boolean, numPartitions: Int)(implicit ord: Ordering[K], ctag: ClassTag[K]): RDD[(K, V)]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Definition Classes
    RDD
  177. def sortByKey(comp: Comparator[K], ascending: Boolean, numPartitions: Int): JavaPairRDD[K, V]

    Permalink
    Definition Classes
    JavaPairRDD
  178. def sortByKey(comp: Comparator[K], ascending: Boolean): JavaPairRDD[K, V]

    Permalink
    Definition Classes
    JavaPairRDD
  179. def sortByKey(comp: Comparator[K]): JavaPairRDD[K, V]

    Permalink
    Definition Classes
    JavaPairRDD
  180. def sortByKey(ascending: Boolean, numPartitions: Int): JavaPairRDD[K, V]

    Permalink
    Definition Classes
    JavaPairRDD
  181. def sortByKey(ascending: Boolean): JavaPairRDD[K, V]

    Permalink
    Definition Classes
    JavaPairRDD
  182. def sortByKey(): JavaPairRDD[K, V]

    Permalink
    Definition Classes
    JavaPairRDD
  183. def spanBy[U](function: Function[(K, V), U], uClass: Class[U]): JavaPairRDD[U, Iterable[(K, V)]]

    Permalink
  184. def spanBy[U](function: Function[(K, V), U], uClassTag: ClassTag[U]): JavaPairRDD[U, Iterable[(K, V)]]

    Permalink
  185. def spanByKey(): JavaPairRDD[K, Collection[V]]

    Permalink
  186. def sparkContext: SparkContext

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Definition Classes
    RDD
  187. def subtract(other: JavaPairRDD[K, V], p: Partitioner): JavaPairRDD[K, V]

    Permalink
    Definition Classes
    JavaPairRDD
  188. def subtract(other: JavaPairRDD[K, V], numPartitions: Int): JavaPairRDD[K, V]

    Permalink
    Definition Classes
    JavaPairRDD
  189. def subtract(other: JavaPairRDD[K, V]): JavaPairRDD[K, V]

    Permalink
    Definition Classes
    JavaPairRDD
  190. def subtractByKey[W](other: JavaPairRDD[K, W], p: Partitioner): JavaPairRDD[K, V]

    Permalink
    Definition Classes
    JavaPairRDD
  191. def subtractByKey[W](other: JavaPairRDD[K, W], numPartitions: Int): JavaPairRDD[K, V]

    Permalink
    Definition Classes
    JavaPairRDD
  192. def subtractByKey[W](other: JavaPairRDD[K, W]): JavaPairRDD[K, V]

    Permalink
    Definition Classes
    JavaPairRDD
  193. final def synchronized[T0](arg0: ⇒ T0): T0

    Permalink
    Definition Classes
    AnyRef
  194. def take(num: Int): List[(K, V)]

    Permalink
    Definition Classes
    JavaRDDLike
  195. def takeAsync(num: Int): JavaFutureAction[List[(K, V)]]

    Permalink
    Definition Classes
    JavaRDDLike
  196. def takeOrdered(num: Int): List[(K, V)]

    Permalink
    Definition Classes
    JavaRDDLike
  197. def takeOrdered(num: Int, comp: Comparator[(K, V)]): List[(K, V)]

    Permalink
    Definition Classes
    JavaRDDLike
  198. def takeSample(withReplacement: Boolean, num: Int, seed: Long): List[(K, V)]

    Permalink
    Definition Classes
    JavaRDDLike
  199. def takeSample(withReplacement: Boolean, num: Int): List[(K, V)]

    Permalink
    Definition Classes
    JavaRDDLike
  200. def toDebugString(): String

    Permalink
    Definition Classes
    JavaRDDLike
  201. def toEmptyCassandraRDD(): CassandraJavaPairRDD[K, V]

    Permalink
  202. def toJavaRDD(): JavaRDD[(K, V)]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Definition Classes
    RDD
  203. def toLocalIterator(): Iterator[(K, V)]

    Permalink
    Definition Classes
    JavaRDDLike
  204. def toString(): String

    Permalink
    Definition Classes
    AnyRef → Any
  205. def top(num: Int): List[(K, V)]

    Permalink
    Definition Classes
    JavaRDDLike
  206. def top(num: Int, comp: Comparator[(K, V)]): List[(K, V)]

    Permalink
    Definition Classes
    JavaRDDLike
  207. def treeAggregate[U](zeroValue: U, seqOp: Function2[U, (K, V), U], combOp: Function2[U, U, U]): U

    Permalink
    Definition Classes
    JavaRDDLike
  208. def treeAggregate[U](zeroValue: U, seqOp: Function2[U, (K, V), U], combOp: Function2[U, U, U], depth: Int): U

    Permalink
    Definition Classes
    JavaRDDLike
  209. def treeReduce(f: Function2[(K, V), (K, V), (K, V)]): (K, V)

    Permalink
    Definition Classes
    JavaRDDLike
  210. def treeReduce(f: Function2[(K, V), (K, V), (K, V)], depth: Int): (K, V)

    Permalink
    Definition Classes
    JavaRDDLike
  211. def union(other: JavaPairRDD[K, V]): JavaPairRDD[K, V]

    Permalink
    Definition Classes
    JavaPairRDD
  212. def unpersist(blocking: Boolean): JavaPairRDD[K, V]

    Permalink
    Definition Classes
    JavaPairRDD
  213. def unpersist(): JavaPairRDD[K, V]

    Permalink
    Definition Classes
    JavaPairRDD
  214. implicit val vClassTag: ClassTag[V]

    Permalink
    Definition Classes
    JavaPairRDD
  215. def values(): JavaRDD[V]

    Permalink
    Definition Classes
    JavaPairRDD
  216. final def wait(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  217. final def wait(arg0: Long, arg1: Int): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  218. final def wait(arg0: Long): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  219. def where(cqlWhereClause: String, args: <repeated...>[AnyRef]): CassandraJavaPairRDD[K, V]

    Permalink
  220. def withAscOrder(): CassandraJavaPairRDD[K, V]

    Permalink
  221. def withConnector(connector: CassandraConnector): CassandraJavaPairRDD[K, V]

    Permalink
  222. def withDescOrder(): CassandraJavaPairRDD[K, V]

    Permalink
  223. def withReadConf(config: ReadConf): CassandraJavaPairRDD[K, V]

    Permalink
  224. def wrapRDD(rdd: RDD[(K, V)]): JavaPairRDD[K, V]

    Permalink
    Definition Classes
    JavaPairRDD → JavaRDDLike
  225. def zip[U](other: JavaRDDLike[U, _]): JavaPairRDD[(K, V), U]

    Permalink
    Definition Classes
    JavaRDDLike
  226. def zipPartitions[U, V](other: JavaRDDLike[U, _], f: FlatMapFunction2[Iterator[(K, V)], Iterator[U], V]): JavaRDD[V]

    Permalink
    Definition Classes
    JavaRDDLike
  227. def zipWithIndex(): JavaPairRDD[(K, V), Long]

    Permalink
    Definition Classes
    JavaRDDLike
  228. def zipWithUniqueId(): JavaPairRDD[(K, V), Long]

    Permalink
    Definition Classes
    JavaRDDLike
  229. def [B](y: B): (CassandraJavaPairRDD[K, V], B)

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to ArrowAssoc[CassandraJavaPairRDD[K, V]] performed by method ArrowAssoc in scala.Predef.
    Definition Classes
    ArrowAssoc

Shadowed Implicit Value Members

  1. def aggregate[U](zeroValue: U)(seqOp: (U, (K, V)) ⇒ U, combOp: (U, U) ⇒ U)(implicit arg0: ClassTag[U]): U

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).aggregate(zeroValue)(seqOp, combOp)(arg0)
    Definition Classes
    RDD
  2. def cache(): RDD[(K, V)]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).cache()
    Definition Classes
    RDD
  3. def cartesian[U](other: RDD[U])(implicit arg0: ClassTag[U]): RDD[((K, V), U)]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).cartesian(other)(arg0)
    Definition Classes
    RDD
  4. def checkpoint(): Unit

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).checkpoint()
    Definition Classes
    RDD
  5. def coalesce(numPartitions: Int, shuffle: Boolean, partitionCoalescer: Option[PartitionCoalescer])(implicit ord: Ordering[(K, V)]): RDD[(K, V)]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).coalesce(numPartitions, shuffle, partitionCoalescer)(ord)
    Definition Classes
    RDD
  6. def collect[U](f: PartialFunction[(K, V), U])(implicit arg0: ClassTag[U]): RDD[U]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).collect(f)(arg0)
    Definition Classes
    RDD
  7. def collect(): Array[(K, V)]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).collect()
    Definition Classes
    RDD
  8. def context: SparkContext

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).context
    Definition Classes
    RDD
  9. def count(): Long

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).count()
    Definition Classes
    RDD
  10. def countApprox(timeout: Long, confidence: Double): PartialResult[BoundedDouble]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).countApprox(timeout, confidence)
    Definition Classes
    RDD
  11. def countApproxDistinct(relativeSD: Double): Long

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).countApproxDistinct(relativeSD)
    Definition Classes
    RDD
  12. def countApproxDistinct(p: Int, sp: Int): Long

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).countApproxDistinct(p, sp)
    Definition Classes
    RDD
  13. def countByValue()(implicit ord: Ordering[(K, V)]): Map[(K, V), Long]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).countByValue()(ord)
    Definition Classes
    RDD
  14. def countByValueApprox(timeout: Long, confidence: Double)(implicit ord: Ordering[(K, V)]): PartialResult[Map[(K, V), BoundedDouble]]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).countByValueApprox(timeout, confidence)(ord)
    Definition Classes
    RDD
  15. def distinct(): RDD[(K, V)]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).distinct()
    Definition Classes
    RDD
  16. def distinct(numPartitions: Int)(implicit ord: Ordering[(K, V)]): RDD[(K, V)]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).distinct(numPartitions)(ord)
    Definition Classes
    RDD
  17. def filter(f: ((K, V)) ⇒ Boolean): RDD[(K, V)]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).filter(f)
    Definition Classes
    RDD
  18. def first(): (K, V)

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).first()
    Definition Classes
    RDD
  19. def flatMap[U](f: ((K, V)) ⇒ TraversableOnce[U])(implicit arg0: ClassTag[U]): RDD[U]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).flatMap(f)(arg0)
    Definition Classes
    RDD
  20. def fold(zeroValue: (K, V))(op: ((K, V), (K, V)) ⇒ (K, V)): (K, V)

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).fold(zeroValue)(op)
    Definition Classes
    RDD
  21. def foreach(f: ((K, V)) ⇒ Unit): Unit

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).foreach(f)
    Definition Classes
    RDD
  22. def foreachPartition(f: (Iterator[(K, V)]) ⇒ Unit): Unit

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).foreachPartition(f)
    Definition Classes
    RDD
  23. def getCheckpointFile: Option[String]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).getCheckpointFile
    Definition Classes
    RDD
  24. final def getNumPartitions: Int

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).getNumPartitions
    Definition Classes
    RDD
    Annotations
    @Since( "1.6.0" )
  25. def getStorageLevel: StorageLevel

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).getStorageLevel
    Definition Classes
    RDD
  26. def glom(): RDD[Array[(K, V)]]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).glom()
    Definition Classes
    RDD
  27. def groupBy[K](f: ((K, V)) ⇒ K, p: Partitioner)(implicit kt: ClassTag[K], ord: Ordering[K]): RDD[(K, Iterable[(K, V)])]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).groupBy(f, p)(kt, ord)
    Definition Classes
    RDD
  28. def groupBy[K](f: ((K, V)) ⇒ K, numPartitions: Int)(implicit kt: ClassTag[K]): RDD[(K, Iterable[(K, V)])]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).groupBy(f, numPartitions)(kt)
    Definition Classes
    RDD
  29. def groupBy[K](f: ((K, V)) ⇒ K)(implicit kt: ClassTag[K]): RDD[(K, Iterable[(K, V)])]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).groupBy(f)(kt)
    Definition Classes
    RDD
  30. val id: Int

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).id
    Definition Classes
    RDD
  31. def intersection(other: RDD[(K, V)], numPartitions: Int): RDD[(K, V)]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).intersection(other, numPartitions)
    Definition Classes
    RDD
  32. def intersection(other: RDD[(K, V)], partitioner: Partitioner)(implicit ord: Ordering[(K, V)]): RDD[(K, V)]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).intersection(other, partitioner)(ord)
    Definition Classes
    RDD
  33. def intersection(other: RDD[(K, V)]): RDD[(K, V)]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).intersection(other)
    Definition Classes
    RDD
  34. def isCheckpointed: Boolean

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).isCheckpointed
    Definition Classes
    RDD
  35. def isEmpty(): Boolean

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).isEmpty()
    Definition Classes
    RDD
  36. final def iterator(split: Partition, context: TaskContext): Iterator[(K, V)]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).iterator(split, context)
    Definition Classes
    RDD
  37. def keyBy[K](f: ((K, V)) ⇒ K): RDD[(K, (K, V))]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).keyBy(f)
    Definition Classes
    RDD
  38. def map[U](f: ((K, V)) ⇒ U)(implicit arg0: ClassTag[U]): RDD[U]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).map(f)(arg0)
    Definition Classes
    RDD
  39. def mapPartitions[U](f: (Iterator[(K, V)]) ⇒ Iterator[U], preservesPartitioning: Boolean)(implicit arg0: ClassTag[U]): RDD[U]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).mapPartitions(f, preservesPartitioning)(arg0)
    Definition Classes
    RDD
  40. def mapPartitionsWithIndex[U](f: (Int, Iterator[(K, V)]) ⇒ Iterator[U], preservesPartitioning: Boolean)(implicit arg0: ClassTag[U]): RDD[U]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).mapPartitionsWithIndex(f, preservesPartitioning)(arg0)
    Definition Classes
    RDD
  41. def max()(implicit ord: Ordering[(K, V)]): (K, V)

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).max()(ord)
    Definition Classes
    RDD
  42. def min()(implicit ord: Ordering[(K, V)]): (K, V)

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).min()(ord)
    Definition Classes
    RDD
  43. var name: String

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).name
    Definition Classes
    RDD
  44. val partitioner: Option[Partitioner]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).partitioner
    Definition Classes
    RDD
  45. final def partitions: Array[Partition]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).partitions
    Definition Classes
    RDD
  46. def persist(): RDD[(K, V)]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).persist()
    Definition Classes
    RDD
  47. def persist(newLevel: StorageLevel): RDD[(K, V)]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).persist(newLevel)
    Definition Classes
    RDD
  48. def pipe(command: Seq[String], env: Map[String, String], printPipeContext: ((String) ⇒ Unit) ⇒ Unit, printRDDElement: ((K, V), (String) ⇒ Unit) ⇒ Unit, separateWorkingDir: Boolean, bufferSize: Int, encoding: String): RDD[String]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).pipe(command, env, printPipeContext, printRDDElement, separateWorkingDir, bufferSize, encoding)
    Definition Classes
    RDD
  49. def pipe(command: String, env: Map[String, String]): RDD[String]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).pipe(command, env)
    Definition Classes
    RDD
  50. def pipe(command: String): RDD[String]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).pipe(command)
    Definition Classes
    RDD
  51. def reduce(f: ((K, V), (K, V)) ⇒ (K, V)): (K, V)

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).reduce(f)
    Definition Classes
    RDD
  52. def repartition(numPartitions: Int)(implicit ord: Ordering[(K, V)]): RDD[(K, V)]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).repartition(numPartitions)(ord)
    Definition Classes
    RDD
  53. def sample(withReplacement: Boolean, fraction: Double, seed: Long): RDD[(K, V)]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).sample(withReplacement, fraction, seed)
    Definition Classes
    RDD
  54. def saveAsObjectFile(path: String): Unit

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).saveAsObjectFile(path)
    Definition Classes
    RDD
  55. def saveAsTextFile(path: String, codec: Class[_ <: CompressionCodec]): Unit

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).saveAsTextFile(path, codec)
    Definition Classes
    RDD
  56. def saveAsTextFile(path: String): Unit

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).saveAsTextFile(path)
    Definition Classes
    RDD
  57. def setName(_name: String): RDD[(K, V)]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).setName(_name)
    Definition Classes
    RDD
  58. def subtract(other: RDD[(K, V)], p: Partitioner)(implicit ord: Ordering[(K, V)]): RDD[(K, V)]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).subtract(other, p)(ord)
    Definition Classes
    RDD
  59. def subtract(other: RDD[(K, V)], numPartitions: Int): RDD[(K, V)]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).subtract(other, numPartitions)
    Definition Classes
    RDD
  60. def subtract(other: RDD[(K, V)]): RDD[(K, V)]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).subtract(other)
    Definition Classes
    RDD
  61. def take(num: Int): Array[(K, V)]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).take(num)
    Definition Classes
    RDD
  62. def takeOrdered(num: Int)(implicit ord: Ordering[(K, V)]): Array[(K, V)]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).takeOrdered(num)(ord)
    Definition Classes
    RDD
  63. def takeSample(withReplacement: Boolean, num: Int, seed: Long): Array[(K, V)]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).takeSample(withReplacement, num, seed)
    Definition Classes
    RDD
  64. def toDebugString: String

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).toDebugString
    Definition Classes
    RDD
  65. def toLocalIterator: Iterator[(K, V)]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).toLocalIterator
    Definition Classes
    RDD
  66. def toString(): String

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).toString()
    Definition Classes
    RDD → AnyRef → Any
  67. def top(num: Int)(implicit ord: Ordering[(K, V)]): Array[(K, V)]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).top(num)(ord)
    Definition Classes
    RDD
  68. def treeAggregate[U](zeroValue: U)(seqOp: (U, (K, V)) ⇒ U, combOp: (U, U) ⇒ U, depth: Int)(implicit arg0: ClassTag[U]): U

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).treeAggregate(zeroValue)(seqOp, combOp, depth)(arg0)
    Definition Classes
    RDD
  69. def treeReduce(f: ((K, V), (K, V)) ⇒ (K, V), depth: Int): (K, V)

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).treeReduce(f, depth)
    Definition Classes
    RDD
  70. def union(other: RDD[(K, V)]): RDD[(K, V)]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).union(other)
    Definition Classes
    RDD
  71. def unpersist(blocking: Boolean): RDD[(K, V)]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).unpersist(blocking)
    Definition Classes
    RDD
  72. def zip[U](other: RDD[U])(implicit arg0: ClassTag[U]): RDD[((K, V), U)]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).zip(other)(arg0)
    Definition Classes
    RDD
  73. def zipPartitions[B, C, D, V](rdd2: RDD[B], rdd3: RDD[C], rdd4: RDD[D])(f: (Iterator[(K, V)], Iterator[B], Iterator[C], Iterator[D]) ⇒ Iterator[V])(implicit arg0: ClassTag[B], arg1: ClassTag[C], arg2: ClassTag[D], arg3: ClassTag[V]): RDD[V]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).zipPartitions(rdd2, rdd3, rdd4)(f)(arg0, arg1, arg2, arg3)
    Definition Classes
    RDD
  74. def zipPartitions[B, C, D, V](rdd2: RDD[B], rdd3: RDD[C], rdd4: RDD[D], preservesPartitioning: Boolean)(f: (Iterator[(K, V)], Iterator[B], Iterator[C], Iterator[D]) ⇒ Iterator[V])(implicit arg0: ClassTag[B], arg1: ClassTag[C], arg2: ClassTag[D], arg3: ClassTag[V]): RDD[V]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).zipPartitions(rdd2, rdd3, rdd4, preservesPartitioning)(f)(arg0, arg1, arg2, arg3)
    Definition Classes
    RDD
  75. def zipPartitions[B, C, V](rdd2: RDD[B], rdd3: RDD[C])(f: (Iterator[(K, V)], Iterator[B], Iterator[C]) ⇒ Iterator[V])(implicit arg0: ClassTag[B], arg1: ClassTag[C], arg2: ClassTag[V]): RDD[V]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).zipPartitions(rdd2, rdd3)(f)(arg0, arg1, arg2)
    Definition Classes
    RDD
  76. def zipPartitions[B, C, V](rdd2: RDD[B], rdd3: RDD[C], preservesPartitioning: Boolean)(f: (Iterator[(K, V)], Iterator[B], Iterator[C]) ⇒ Iterator[V])(implicit arg0: ClassTag[B], arg1: ClassTag[C], arg2: ClassTag[V]): RDD[V]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).zipPartitions(rdd2, rdd3, preservesPartitioning)(f)(arg0, arg1, arg2)
    Definition Classes
    RDD
  77. def zipPartitions[B, V](rdd2: RDD[B])(f: (Iterator[(K, V)], Iterator[B]) ⇒ Iterator[V])(implicit arg0: ClassTag[B], arg1: ClassTag[V]): RDD[V]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).zipPartitions(rdd2)(f)(arg0, arg1)
    Definition Classes
    RDD
  78. def zipPartitions[B, V](rdd2: RDD[B], preservesPartitioning: Boolean)(f: (Iterator[(K, V)], Iterator[B]) ⇒ Iterator[V])(implicit arg0: ClassTag[B], arg1: ClassTag[V]): RDD[V]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).zipPartitions(rdd2, preservesPartitioning)(f)(arg0, arg1)
    Definition Classes
    RDD
  79. def zipWithIndex(): RDD[((K, V), Long)]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).zipWithIndex()
    Definition Classes
    RDD
  80. def zipWithUniqueId(): RDD[((K, V), Long)]

    Permalink
    Implicit information
    This member is added by an implicit conversion from CassandraJavaPairRDD[K, V] to RDD[(K, V)] performed by method toRDD in org.apache.spark.api.java.JavaPairRDD.
    Shadowing
    This implicitly inherited member is shadowed by one or more members in this class.
    To access this member you can use a type ascription:
    (cassandraJavaPairRDD: RDD[(K, V)]).zipWithUniqueId()
    Definition Classes
    RDD

Inherited from JavaPairRDD[K, V]

Inherited from AbstractJavaRDDLike[(K, V), JavaPairRDD[K, V]]

Inherited from JavaRDDLike[(K, V), JavaPairRDD[K, V]]

Inherited from Serializable

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Inherited by implicit conversion toRDD from CassandraJavaPairRDD[K, V] to RDD[(K, V)]

Inherited by implicit conversion any2stringadd from CassandraJavaPairRDD[K, V] to any2stringadd[CassandraJavaPairRDD[K, V]]

Inherited by implicit conversion StringFormat from CassandraJavaPairRDD[K, V] to StringFormat[CassandraJavaPairRDD[K, V]]

Inherited by implicit conversion Ensuring from CassandraJavaPairRDD[K, V] to Ensuring[CassandraJavaPairRDD[K, V]]

Inherited by implicit conversion ArrowAssoc from CassandraJavaPairRDD[K, V] to ArrowAssoc[CassandraJavaPairRDD[K, V]]

Ungrouped