com.couchbase.spark.japi

CouchbaseRDD

class CouchbaseRDD[T] extends JavaRDD[T]

Linear Supertypes
JavaRDD[T], AbstractJavaRDDLike[T, JavaRDD[T]], JavaRDDLike[T, JavaRDD[T]], Serializable, Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. CouchbaseRDD
  2. JavaRDD
  3. AbstractJavaRDDLike
  4. JavaRDDLike
  5. Serializable
  6. Serializable
  7. AnyRef
  8. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Value Members

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

    Definition Classes
    AnyRef
  2. final def !=(arg0: Any): Boolean

    Definition Classes
    Any
  3. final def ##(): Int

    Definition Classes
    AnyRef → Any
  4. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  5. final def ==(arg0: Any): Boolean

    Definition Classes
    Any
  6. def aggregate[U](zeroValue: U)(seqOp: Function2[U, T, U], combOp: Function2[U, U, U]): U

    Definition Classes
    JavaRDDLike
  7. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  8. def cache(): JavaRDD[T]

    Definition Classes
    JavaRDD
  9. def cartesian[U](other: JavaRDDLike[U, _]): JavaPairRDD[T, U]

    Definition Classes
    JavaRDDLike
  10. def checkpoint(): Unit

    Definition Classes
    JavaRDDLike
  11. def classTag(): ClassTag[T]

    Definition Classes
    CouchbaseRDD → JavaRDD → JavaRDDLike
  12. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  13. def coalesce(numPartitions: Int, shuffle: Boolean): JavaRDD[T]

    Definition Classes
    JavaRDD
  14. def coalesce(numPartitions: Int): JavaRDD[T]

    Definition Classes
    JavaRDD
  15. def collect(): List[T]

    Definition Classes
    JavaRDDLike
  16. def collectAsync(): JavaFutureAction[List[T]]

    Definition Classes
    JavaRDDLike
  17. def collectPartitions(partitionIds: Array[Int]): Array[List[T]]

    Definition Classes
    JavaRDDLike
  18. def context: SparkContext

    Definition Classes
    JavaRDDLike
  19. def couchbaseGet[D <: Document](bucket: String, clazz: Class[D]): JavaRDD[D]

  20. def couchbaseGet[D <: Document](clazz: Class[D]): JavaRDD[D]

  21. def couchbaseGet(bucket: String): JavaRDD[JsonDocument]

  22. def couchbaseGet(): JavaRDD[JsonDocument]

  23. def couchbaseQuery(bucket: String): JavaRDD[CouchbaseQueryRow]

  24. def couchbaseQuery(): JavaRDD[CouchbaseQueryRow]

  25. def couchbaseSpatialView(bucket: String): JavaRDD[CouchbaseSpatialViewRow]

  26. def couchbaseSpatialView(): JavaRDD[CouchbaseSpatialViewRow]

  27. def couchbaseSubdocLookup(get: List[String], exists: List[String], bucket: String): JavaRDD[SubdocLookupResult]

  28. def couchbaseSubdocLookup(get: List[String], exists: List[String]): JavaRDD[SubdocLookupResult]

  29. def couchbaseSubdocLookup(get: List[String]): JavaRDD[SubdocLookupResult]

  30. def couchbaseView(bucket: String): JavaRDD[CouchbaseViewRow]

  31. def couchbaseView(): JavaRDD[CouchbaseViewRow]

  32. def count(): Long

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

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

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

    Definition Classes
    JavaRDDLike
  36. def countAsync(): JavaFutureAction[Long]

    Definition Classes
    JavaRDDLike
  37. def countByValue(): Map[T, Long]

    Definition Classes
    JavaRDDLike
  38. def countByValueApprox(timeout: Long): PartialResult[Map[T, BoundedDouble]]

    Definition Classes
    JavaRDDLike
  39. def countByValueApprox(timeout: Long, confidence: Double): PartialResult[Map[T, BoundedDouble]]

    Definition Classes
    JavaRDDLike
  40. def distinct(numPartitions: Int): JavaRDD[T]

    Definition Classes
    JavaRDD
  41. def distinct(): JavaRDD[T]

    Definition Classes
    JavaRDD
  42. final def eq(arg0: AnyRef): Boolean

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

    Definition Classes
    AnyRef → Any
  44. def filter(f: Function[T, Boolean]): JavaRDD[T]

    Definition Classes
    JavaRDD
  45. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  46. def first(): T

    Definition Classes
    JavaRDDLike
  47. def flatMap[U](f: FlatMapFunction[T, U]): JavaRDD[U]

    Definition Classes
    JavaRDDLike
  48. def flatMapToDouble(f: DoubleFlatMapFunction[T]): JavaDoubleRDD

    Definition Classes
    JavaRDDLike
  49. def flatMapToPair[K2, V2](f: PairFlatMapFunction[T, K2, V2]): JavaPairRDD[K2, V2]

    Definition Classes
    JavaRDDLike
  50. def fold(zeroValue: T)(f: Function2[T, T, T]): T

    Definition Classes
    JavaRDDLike
  51. def foreach(f: VoidFunction[T]): Unit

    Definition Classes
    JavaRDDLike
  52. def foreachAsync(f: VoidFunction[T]): JavaFutureAction[Void]

    Definition Classes
    JavaRDDLike
  53. def foreachPartition(f: VoidFunction[Iterator[T]]): Unit

    Definition Classes
    JavaRDDLike
  54. def foreachPartitionAsync(f: VoidFunction[Iterator[T]]): JavaFutureAction[Void]

    Definition Classes
    JavaRDDLike
  55. def getCheckpointFile(): Optional[String]

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

    Definition Classes
    AnyRef → Any
  57. def getNumPartitions: Int

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

    Definition Classes
    JavaRDDLike
  59. def glom(): JavaRDD[List[T]]

    Definition Classes
    JavaRDDLike
  60. def groupBy[U](f: Function[T, U], numPartitions: Int): JavaPairRDD[U, Iterable[T]]

    Definition Classes
    JavaRDDLike
  61. def groupBy[U](f: Function[T, U]): JavaPairRDD[U, Iterable[T]]

    Definition Classes
    JavaRDDLike
  62. def hashCode(): Int

    Definition Classes
    AnyRef → Any
  63. def id: Int

    Definition Classes
    JavaRDDLike
  64. def intersection(other: JavaRDD[T]): JavaRDD[T]

    Definition Classes
    JavaRDD
  65. def isCheckpointed: Boolean

    Definition Classes
    JavaRDDLike
  66. def isEmpty(): Boolean

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

    Definition Classes
    Any
  68. def iterator(split: Partition, taskContext: TaskContext): Iterator[T]

    Definition Classes
    JavaRDDLike
  69. def keyBy[U](f: Function[T, U]): JavaPairRDD[U, T]

    Definition Classes
    JavaRDDLike
  70. def map[R](f: Function[T, R]): JavaRDD[R]

    Definition Classes
    JavaRDDLike
  71. def mapPartitions[U](f: FlatMapFunction[Iterator[T], U], preservesPartitioning: Boolean): JavaRDD[U]

    Definition Classes
    JavaRDDLike
  72. def mapPartitions[U](f: FlatMapFunction[Iterator[T], U]): JavaRDD[U]

    Definition Classes
    JavaRDDLike
  73. def mapPartitionsToDouble(f: DoubleFlatMapFunction[Iterator[T]], preservesPartitioning: Boolean): JavaDoubleRDD

    Definition Classes
    JavaRDDLike
  74. def mapPartitionsToDouble(f: DoubleFlatMapFunction[Iterator[T]]): JavaDoubleRDD

    Definition Classes
    JavaRDDLike
  75. def mapPartitionsToPair[K2, V2](f: PairFlatMapFunction[Iterator[T], K2, V2], preservesPartitioning: Boolean): JavaPairRDD[K2, V2]

    Definition Classes
    JavaRDDLike
  76. def mapPartitionsToPair[K2, V2](f: PairFlatMapFunction[Iterator[T], K2, V2]): JavaPairRDD[K2, V2]

    Definition Classes
    JavaRDDLike
  77. def mapPartitionsWithIndex[R](f: Function2[Integer, Iterator[T], Iterator[R]], preservesPartitioning: Boolean): JavaRDD[R]

    Definition Classes
    JavaRDDLike
  78. def mapToDouble[R](f: DoubleFunction[T]): JavaDoubleRDD

    Definition Classes
    JavaRDDLike
  79. def mapToPair[K2, V2](f: PairFunction[T, K2, V2]): JavaPairRDD[K2, V2]

    Definition Classes
    JavaRDDLike
  80. def max(comp: Comparator[T]): T

    Definition Classes
    JavaRDDLike
  81. def min(comp: Comparator[T]): T

    Definition Classes
    JavaRDDLike
  82. def name(): String

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

    Definition Classes
    AnyRef
  84. final def notify(): Unit

    Definition Classes
    AnyRef
  85. final def notifyAll(): Unit

    Definition Classes
    AnyRef
  86. def partitioner: Optional[Partitioner]

    Definition Classes
    JavaRDDLike
  87. def partitions: List[Partition]

    Definition Classes
    JavaRDDLike
  88. def persist(newLevel: StorageLevel): JavaRDD[T]

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

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

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

    Definition Classes
    JavaRDDLike
  92. def randomSplit(weights: Array[Double], seed: Long): Array[JavaRDD[T]]

    Definition Classes
    JavaRDD
  93. def randomSplit(weights: Array[Double]): Array[JavaRDD[T]]

    Definition Classes
    JavaRDD
  94. def rdd(): RDD[T]

    Definition Classes
    CouchbaseRDD → JavaRDD → JavaRDDLike
  95. def reduce(f: Function2[T, T, T]): T

    Definition Classes
    JavaRDDLike
  96. def repartition(numPartitions: Int): JavaRDD[T]

    Definition Classes
    JavaRDD
  97. def sample(withReplacement: Boolean, fraction: Double, seed: Long): JavaRDD[T]

    Definition Classes
    JavaRDD
  98. def sample(withReplacement: Boolean, fraction: Double): JavaRDD[T]

    Definition Classes
    JavaRDD
  99. def saveAsObjectFile(path: String): Unit

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

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

    Definition Classes
    JavaRDDLike
  102. def setName(name: String): JavaRDD[T]

    Definition Classes
    JavaRDD
  103. def sortBy[S](f: Function[T, S], ascending: Boolean, numPartitions: Int): JavaRDD[T]

    Definition Classes
    JavaRDD
  104. def subtract(other: JavaRDD[T], p: Partitioner): JavaRDD[T]

    Definition Classes
    JavaRDD
  105. def subtract(other: JavaRDD[T], numPartitions: Int): JavaRDD[T]

    Definition Classes
    JavaRDD
  106. def subtract(other: JavaRDD[T]): JavaRDD[T]

    Definition Classes
    JavaRDD
  107. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  108. def take(num: Int): List[T]

    Definition Classes
    JavaRDDLike
  109. def takeAsync(num: Int): JavaFutureAction[List[T]]

    Definition Classes
    JavaRDDLike
  110. def takeOrdered(num: Int): List[T]

    Definition Classes
    JavaRDDLike
  111. def takeOrdered(num: Int, comp: Comparator[T]): List[T]

    Definition Classes
    JavaRDDLike
  112. def takeSample(withReplacement: Boolean, num: Int, seed: Long): List[T]

    Definition Classes
    JavaRDDLike
  113. def takeSample(withReplacement: Boolean, num: Int): List[T]

    Definition Classes
    JavaRDDLike
  114. def toDebugString(): String

    Definition Classes
    JavaRDDLike
  115. def toLocalIterator(): Iterator[T]

    Definition Classes
    JavaRDDLike
  116. def toString(): String

    Definition Classes
    JavaRDD → AnyRef → Any
  117. def top(num: Int): List[T]

    Definition Classes
    JavaRDDLike
  118. def top(num: Int, comp: Comparator[T]): List[T]

    Definition Classes
    JavaRDDLike
  119. def treeAggregate[U](zeroValue: U, seqOp: Function2[U, T, U], combOp: Function2[U, U, U]): U

    Definition Classes
    JavaRDDLike
  120. def treeAggregate[U](zeroValue: U, seqOp: Function2[U, T, U], combOp: Function2[U, U, U], depth: Int): U

    Definition Classes
    JavaRDDLike
  121. def treeReduce(f: Function2[T, T, T]): T

    Definition Classes
    JavaRDDLike
  122. def treeReduce(f: Function2[T, T, T], depth: Int): T

    Definition Classes
    JavaRDDLike
  123. def union(other: JavaRDD[T]): JavaRDD[T]

    Definition Classes
    JavaRDD
  124. def unpersist(blocking: Boolean): JavaRDD[T]

    Definition Classes
    JavaRDD
  125. def unpersist(): JavaRDD[T]

    Definition Classes
    JavaRDD
  126. final def wait(): Unit

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

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

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  129. def wrapRDD(rdd: RDD[T]): JavaRDD[T]

    Definition Classes
    JavaRDD → JavaRDDLike
  130. def zip[U](other: JavaRDDLike[U, _]): JavaPairRDD[T, U]

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

    Definition Classes
    JavaRDDLike
  132. def zipWithIndex(): JavaPairRDD[T, Long]

    Definition Classes
    JavaRDDLike
  133. def zipWithUniqueId(): JavaPairRDD[T, Long]

    Definition Classes
    JavaRDDLike

Deprecated Value Members

  1. def splits: List[Partition]

    Definition Classes
    JavaRDDLike
    Annotations
    @deprecated
    Deprecated

    (Since version 1.1.0) Use partitions() instead.

  2. def toArray(): List[T]

    Definition Classes
    JavaRDDLike
    Annotations
    @deprecated
    Deprecated

    (Since version 1.0.0) use collect()

Inherited from JavaRDD[T]

Inherited from AbstractJavaRDDLike[T, JavaRDD[T]]

Inherited from JavaRDDLike[T, JavaRDD[T]]

Inherited from Serializable

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped