Class

com.datastax.spark.connector.japi.rdd

CassandraJoinJavaRDD

Related Doc: package rdd

Permalink

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

Linear Supertypes
CassandraJavaPairRDD[K, V], JavaPairRDD[K, V], AbstractJavaRDDLike[(K, V), JavaPairRDD[K, V]], JavaRDDLike[(K, V), JavaPairRDD[K, V]], Serializable, Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. CassandraJoinJavaRDD
  2. CassandraJavaPairRDD
  3. JavaPairRDD
  4. AbstractJavaRDDLike
  5. JavaRDDLike
  6. Serializable
  7. Serializable
  8. AnyRef
  9. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new CassandraJoinJavaRDD(rdd: CassandraJoinRDD[K, V], keyClass: Class[K], valueClass: Class[V])

    Permalink
  2. new CassandraJoinJavaRDD(rdd: CassandraJoinRDD[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. final def ==(arg0: Any): Boolean

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

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

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

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

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

    Permalink
    Definition Classes
    Any
  9. def cache(): JavaPairRDD[K, V]

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

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

    Permalink
    Definition Classes
    CassandraJavaPairRDD
  12. def checkpoint(): Unit

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

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

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

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

    Permalink
    Definition Classes
    JavaPairRDD
  17. 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
  18. 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
  19. def cogroup[W](other: JavaPairRDD[K, W], numPartitions: Int): JavaPairRDD[K, (Iterable[V], Iterable[W])]

    Permalink
    Definition Classes
    JavaPairRDD
  20. 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
  21. def cogroup[W1, W2](other1: JavaPairRDD[K, W1], other2: JavaPairRDD[K, W2]): JavaPairRDD[K, (Iterable[V], Iterable[W1], Iterable[W2])]

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

    Permalink
    Definition Classes
    JavaPairRDD
  23. 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
  24. 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
  25. def cogroup[W](other: JavaPairRDD[K, W], partitioner: Partitioner): JavaPairRDD[K, (Iterable[V], Iterable[W])]

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

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

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

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

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

    Permalink
    Definition Classes
    JavaPairRDD
  31. 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
  32. 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
  33. 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
  34. def context: SparkContext

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

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

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

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

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

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

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

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

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

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

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

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

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

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

    Permalink
    Definition Classes
    JavaRDDLike
  49. def distinct(numPartitions: Int): JavaPairRDD[K, V]

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

    Permalink
    Definition Classes
    JavaPairRDD
  51. final def eq(arg0: AnyRef): Boolean

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

    Permalink
    Definition Classes
    JavaRDDLike
  68. def fullOuterJoin[W](other: JavaPairRDD[K, W], numPartitions: Int): JavaPairRDD[K, (Optional[V], Optional[W])]

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

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

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

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

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

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

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

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

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

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

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

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

    Permalink
    Definition Classes
    JavaPairRDD
  81. 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
  82. def groupWith[W1, W2](other1: JavaPairRDD[K, W1], other2: JavaPairRDD[K, W2]): JavaPairRDD[K, (Iterable[V], Iterable[W1], Iterable[W2])]

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

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

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

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

    Permalink
    Definition Classes
    JavaPairRDD
  87. def isCheckpointed: Boolean

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

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

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

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

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

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

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

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

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

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

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

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

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

    Permalink
    Definition Classes
    CassandraJavaPairRDD
  101. def lookup(key: K): List[V]

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

    Permalink
    Definition Classes
    AnyRef
  119. def on(joinColumns: ColumnSelector): CassandraJoinJavaRDD[K, V]

    Permalink
  120. def partitionBy(partitioner: Partitioner): JavaPairRDD[K, V]

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

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

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

    Permalink
    Definition Classes
    CassandraJavaPairRDD
  124. def persist(newLevel: StorageLevel): JavaPairRDD[K, V]

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

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

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

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

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

    Permalink
    Definition Classes
    JavaRDDLike
  130. def rdd(): CassandraJoinRDD[K, V]

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

    Permalink
    Definition Classes
    CassandraJavaPairRDD
  160. def selectedColumnNames(): Array[String]

    Permalink
    Definition Classes
    CassandraJavaPairRDD
  161. def selectedColumnRefs(): Array[ColumnRef]

    Permalink
    Definition Classes
    CassandraJavaPairRDD
  162. def setName(name: String): JavaPairRDD[K, V]

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

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

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

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

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

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

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

    Permalink
    Definition Classes
    CassandraJavaPairRDD
  170. def spanBy[U](function: Function[(K, V), U], uClassTag: ClassTag[U]): JavaPairRDD[U, Iterable[(K, V)]]

    Permalink
    Definition Classes
    CassandraJavaPairRDD
  171. def spanByKey(): JavaPairRDD[K, Collection[V]]

    Permalink
    Definition Classes
    CassandraJavaPairRDD
  172. def subtract(other: JavaPairRDD[K, V], p: Partitioner): JavaPairRDD[K, V]

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

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

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

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

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

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

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

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

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

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

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

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

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

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

    Permalink
    Definition Classes
    CassandraJavaPairRDD
  187. def toLocalIterator(): Iterator[(K, V)]

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

    Permalink
    Definition Classes
    CassandraJavaPairRDD
  204. def withAscOrder(): CassandraJavaPairRDD[K, V]

    Permalink
    Definition Classes
    CassandraJavaPairRDD
  205. def withConnector(connector: CassandraConnector): CassandraJavaPairRDD[K, V]

    Permalink
    Definition Classes
    CassandraJavaPairRDD
  206. def withDescOrder(): CassandraJavaPairRDD[K, V]

    Permalink
    Definition Classes
    CassandraJavaPairRDD
  207. def withReadConf(config: ReadConf): CassandraJavaPairRDD[K, V]

    Permalink
    Definition Classes
    CassandraJavaPairRDD
  208. def wrapRDD(rdd: RDD[(K, V)]): JavaPairRDD[K, V]

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

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

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

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

    Permalink
    Definition Classes
    JavaRDDLike

Inherited from CassandraJavaPairRDD[K, V]

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

Ungrouped