Class

com.datastax.spark.connector.japi.rdd

CassandraTableScanJavaRDD

Related Doc: package rdd

Permalink

class CassandraTableScanJavaRDD[R] extends CassandraJavaRDD[R]

Linear Supertypes
CassandraJavaRDD[R], JavaRDD[R], AbstractJavaRDDLike[R, JavaRDD[R]], JavaRDDLike[R, JavaRDD[R]], Serializable, Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. CassandraTableScanJavaRDD
  2. CassandraJavaRDD
  3. JavaRDD
  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 CassandraTableScanJavaRDD(rdd: CassandraTableScanRDD[R], classTag: ClassTag[R])

    Permalink
  2. new CassandraTableScanJavaRDD(rdd: CassandraTableScanRDD[R], clazz: Class[R])

    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, R, U], combOp: Function2[U, U, U]): U

    Permalink
    Definition Classes
    JavaRDDLike
  5. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any
  6. def cache(): JavaRDD[R]

    Permalink
    Definition Classes
    JavaRDD
  7. def cartesian[U](other: JavaRDDLike[U, _]): JavaPairRDD[R, U]

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

    Permalink
    Definition Classes
    CassandraJavaRDD
  9. def checkpoint(): Unit

    Permalink
    Definition Classes
    JavaRDDLike
  10. implicit val classTag: ClassTag[R]

    Permalink
    Definition Classes
    JavaRDD → JavaRDDLike
  11. def clone(): AnyRef

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

    Permalink
    Definition Classes
    JavaRDD
  13. def coalesce(numPartitions: Int): JavaRDD[R]

    Permalink
    Definition Classes
    JavaRDD
  14. def collect(): List[R]

    Permalink
    Definition Classes
    JavaRDDLike
  15. def collectAsync(): JavaFutureAction[List[R]]

    Permalink
    Definition Classes
    JavaRDDLike
  16. def collectPartitions(partitionIds: Array[Int]): Array[List[R]]

    Permalink
    Definition Classes
    JavaRDDLike
  17. def context: SparkContext

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

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

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

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

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

    Permalink
    Definition Classes
    JavaRDDLike
  23. def countByValue(): Map[R, Long]

    Permalink
    Definition Classes
    JavaRDDLike
  24. def countByValueApprox(timeout: Long): PartialResult[Map[R, BoundedDouble]]

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

    Permalink
    Definition Classes
    JavaRDDLike
  26. def distinct(numPartitions: Int): JavaRDD[R]

    Permalink
    Definition Classes
    JavaRDD
  27. def distinct(): JavaRDD[R]

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

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

    Permalink
    Definition Classes
    AnyRef → Any
  30. def filter(f: Function[R, Boolean]): JavaRDD[R]

    Permalink
    Definition Classes
    JavaRDD
  31. def finalize(): Unit

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

    Permalink
    Definition Classes
    JavaRDDLike
  33. def flatMap[U](f: FlatMapFunction[R, U]): JavaRDD[U]

    Permalink
    Definition Classes
    JavaRDDLike
  34. def flatMapToDouble(f: DoubleFlatMapFunction[R]): JavaDoubleRDD

    Permalink
    Definition Classes
    JavaRDDLike
  35. def flatMapToPair[K2, V2](f: PairFlatMapFunction[R, K2, V2]): JavaPairRDD[K2, V2]

    Permalink
    Definition Classes
    JavaRDDLike
  36. def fold(zeroValue: R)(f: Function2[R, R, R]): R

    Permalink
    Definition Classes
    JavaRDDLike
  37. def foreach(f: VoidFunction[R]): Unit

    Permalink
    Definition Classes
    JavaRDDLike
  38. def foreachAsync(f: VoidFunction[R]): JavaFutureAction[Void]

    Permalink
    Definition Classes
    JavaRDDLike
  39. def foreachPartition(f: VoidFunction[Iterator[R]]): Unit

    Permalink
    Definition Classes
    JavaRDDLike
  40. def foreachPartitionAsync(f: VoidFunction[Iterator[R]]): JavaFutureAction[Void]

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

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

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

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

    Permalink
    Definition Classes
    JavaRDDLike
  45. def glom(): JavaRDD[List[R]]

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

    Permalink
    Definition Classes
    JavaRDDLike
  47. def groupBy[U](f: Function[R, U]): JavaPairRDD[U, Iterable[R]]

    Permalink
    Definition Classes
    JavaRDDLike
  48. def hashCode(): Int

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

    Permalink
    Definition Classes
    JavaRDDLike
  50. def intersection(other: JavaRDD[R]): JavaRDD[R]

    Permalink
    Definition Classes
    JavaRDD
  51. def isCheckpointed: Boolean

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

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

    Permalink
    Definition Classes
    Any
  54. def iterator(split: Partition, taskContext: TaskContext): Iterator[R]

    Permalink
    Definition Classes
    JavaRDDLike
  55. def keyAndApplyPartitionerFrom[K](rrf: RowReaderFactory[K], rwf: RowWriterFactory[K], keyClass: Class[K], otherRDD: CassandraJavaPairRDD[K, _]): CassandraJavaPairRDD[K, R]

    Permalink
  56. def keyBy[K](rrf: RowReaderFactory[K], rwf: RowWriterFactory[K], keyClass: Class[K]): CassandraJavaPairRDD[K, R]

    Permalink
  57. def keyBy[K](rrf: RowReaderFactory[K], rwf: RowWriterFactory[K], keyClass: Class[K], columnNames: <repeated...>[String]): CassandraJavaPairRDD[K, R]

    Permalink
  58. def keyBy[K](rrf: RowReaderFactory[K], rwf: RowWriterFactory[K], keyClass: Class[K], columns: <repeated...>[ColumnRef]): CassandraJavaPairRDD[K, R]

    Permalink
  59. def keyBy[K](keyClassTag: ClassTag[K], rrf: RowReaderFactory[K], rwf: RowWriterFactory[K], columns: <repeated...>[ColumnRef]): CassandraJavaPairRDD[K, R]

    Permalink
  60. def keyBy[U](f: Function[R, U]): JavaPairRDD[U, R]

    Permalink
    Definition Classes
    JavaRDDLike
  61. def limit(rowsNumber: Long): CassandraTableScanJavaRDD[R]

    Permalink
  62. def map[R](f: Function[R, R]): JavaRDD[R]

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

    Permalink
    Definition Classes
    JavaRDDLike
  64. def mapPartitions[U](f: FlatMapFunction[Iterator[R], U]): JavaRDD[U]

    Permalink
    Definition Classes
    JavaRDDLike
  65. def mapPartitionsToDouble(f: DoubleFlatMapFunction[Iterator[R]], preservesPartitioning: Boolean): JavaDoubleRDD

    Permalink
    Definition Classes
    JavaRDDLike
  66. def mapPartitionsToDouble(f: DoubleFlatMapFunction[Iterator[R]]): JavaDoubleRDD

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

    Permalink
    Definition Classes
    JavaRDDLike
  68. def mapPartitionsToPair[K2, V2](f: PairFlatMapFunction[Iterator[R], K2, V2]): JavaPairRDD[K2, V2]

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

    Permalink
    Definition Classes
    JavaRDDLike
  70. def mapToDouble[R](f: DoubleFunction[R]): JavaDoubleRDD

    Permalink
    Definition Classes
    JavaRDDLike
  71. def mapToPair[K2, V2](f: PairFunction[R, K2, V2]): JavaPairRDD[K2, V2]

    Permalink
    Definition Classes
    JavaRDDLike
  72. def max(comp: Comparator[R]): R

    Permalink
    Definition Classes
    JavaRDDLike
  73. def min(comp: Comparator[R]): R

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

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

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

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

    Permalink
    Definition Classes
    AnyRef
  78. def partitioner: Optional[Partitioner]

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

    Permalink
    Definition Classes
    JavaRDDLike
  80. def perPartitionLimit(rowsNumber: Long): CassandraJavaRDD[R]

    Permalink
    Definition Classes
    CassandraJavaRDD
  81. def persist(newLevel: StorageLevel): JavaRDD[R]

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

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

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

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

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

    Permalink
    Definition Classes
    JavaRDDLike
  87. def randomSplit(weights: Array[Double], seed: Long): Array[JavaRDD[R]]

    Permalink
    Definition Classes
    JavaRDD
  88. def randomSplit(weights: Array[Double]): Array[JavaRDD[R]]

    Permalink
    Definition Classes
    JavaRDD
  89. def rdd(): CassandraTableScanRDD[R]

    Permalink
    Definition Classes
    CassandraTableScanJavaRDDCassandraJavaRDD → JavaRDD → JavaRDDLike
  90. def reduce(f: Function2[R, R, R]): R

    Permalink
    Definition Classes
    JavaRDDLike
  91. def repartition(numPartitions: Int): JavaRDD[R]

    Permalink
    Definition Classes
    JavaRDD
  92. def sample(withReplacement: Boolean, fraction: Double, seed: Long): JavaRDD[R]

    Permalink
    Definition Classes
    JavaRDD
  93. def sample(withReplacement: Boolean, fraction: Double): JavaRDD[R]

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

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

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

    Permalink
    Definition Classes
    JavaRDDLike
  97. def select(columns: <repeated...>[ColumnRef]): CassandraTableScanJavaRDD[R]

    Permalink
  98. def select(columnNames: <repeated...>[String]): CassandraTableScanJavaRDD[R]

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

    Permalink
    Definition Classes
    CassandraJavaRDD
  100. def selectedColumnRefs(): Array[ColumnRef]

    Permalink
    Definition Classes
    CassandraJavaRDD
  101. def setName(name: String): JavaRDD[R]

    Permalink
    Definition Classes
    JavaRDD
  102. def sortBy[S](f: Function[R, S], ascending: Boolean, numPartitions: Int): JavaRDD[R]

    Permalink
    Definition Classes
    JavaRDD
  103. def spanBy[K](f: Function[R, K], keyClass: Class[K]): JavaPairRDD[K, Iterable[R]]

    Permalink
    Definition Classes
    CassandraJavaRDD
  104. def spanBy[K](f: Function[R, K], keyClassTag: ClassTag[K]): JavaPairRDD[K, Iterable[R]]

    Permalink
    Definition Classes
    CassandraJavaRDD
  105. def subtract(other: JavaRDD[R], p: Partitioner): JavaRDD[R]

    Permalink
    Definition Classes
    JavaRDD
  106. def subtract(other: JavaRDD[R], numPartitions: Int): JavaRDD[R]

    Permalink
    Definition Classes
    JavaRDD
  107. def subtract(other: JavaRDD[R]): JavaRDD[R]

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

    Permalink
    Definition Classes
    AnyRef
  109. def take(num: Int): List[R]

    Permalink
    Definition Classes
    JavaRDDLike
  110. def takeAsync(num: Int): JavaFutureAction[List[R]]

    Permalink
    Definition Classes
    JavaRDDLike
  111. def takeOrdered(num: Int): List[R]

    Permalink
    Definition Classes
    JavaRDDLike
  112. def takeOrdered(num: Int, comp: Comparator[R]): List[R]

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

    Permalink
    Definition Classes
    JavaRDDLike
  114. def takeSample(withReplacement: Boolean, num: Int): List[R]

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

    Permalink
    Definition Classes
    JavaRDDLike
  116. def toEmptyCassandraRDD(): CassandraJavaRDD[R]

    Permalink
    Definition Classes
    CassandraJavaRDD
  117. def toLocalIterator(): Iterator[R]

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

    Permalink
    Definition Classes
    JavaRDD → AnyRef → Any
  119. def top(num: Int): List[R]

    Permalink
    Definition Classes
    JavaRDDLike
  120. def top(num: Int, comp: Comparator[R]): List[R]

    Permalink
    Definition Classes
    JavaRDDLike
  121. def treeAggregate[U](zeroValue: U, seqOp: Function2[U, R, U], combOp: Function2[U, U, U]): U

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

    Permalink
    Definition Classes
    JavaRDDLike
  123. def treeReduce(f: Function2[R, R, R]): R

    Permalink
    Definition Classes
    JavaRDDLike
  124. def treeReduce(f: Function2[R, R, R], depth: Int): R

    Permalink
    Definition Classes
    JavaRDDLike
  125. def union(other: JavaRDD[R]): JavaRDD[R]

    Permalink
    Definition Classes
    JavaRDD
  126. def unpersist(blocking: Boolean): JavaRDD[R]

    Permalink
    Definition Classes
    JavaRDD
  127. def unpersist(): JavaRDD[R]

    Permalink
    Definition Classes
    JavaRDD
  128. final def wait(): Unit

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

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

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  131. def where(cqlWhereClause: String, args: <repeated...>[AnyRef]): CassandraTableScanJavaRDD[R]

    Permalink
  132. def withAscOrder(): CassandraTableScanJavaRDD[R]

    Permalink
  133. def withConnector(connector: CassandraConnector): CassandraTableScanJavaRDD[R]

    Permalink
  134. def withDescOrder(): CassandraTableScanJavaRDD[R]

    Permalink
  135. def withReadConf(config: ReadConf): CassandraTableScanJavaRDD[R]

    Permalink
  136. def wrap(newRDD: CassandraRDD[R]): CassandraTableScanJavaRDD[R]

    Permalink
  137. def wrapRDD(rdd: RDD[R]): JavaRDD[R]

    Permalink
    Definition Classes
    JavaRDD → JavaRDDLike
  138. def zip[U](other: JavaRDDLike[U, _]): JavaPairRDD[R, U]

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

    Permalink
    Definition Classes
    JavaRDDLike
  140. def zipWithIndex(): JavaPairRDD[R, Long]

    Permalink
    Definition Classes
    JavaRDDLike
  141. def zipWithUniqueId(): JavaPairRDD[R, Long]

    Permalink
    Definition Classes
    JavaRDDLike

Inherited from CassandraJavaRDD[R]

Inherited from JavaRDD[R]

Inherited from AbstractJavaRDDLike[R, JavaRDD[R]]

Inherited from JavaRDDLike[R, JavaRDD[R]]

Inherited from Serializable

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped