Packages

class QueryRDD[T] extends RDD[T] with Logging

Linear Supertypes
RDD[T], Logging, Serializable, Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. QueryRDD
  2. RDD
  3. Logging
  4. Serializable
  5. Serializable
  6. AnyRef
  7. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new QueryRDD(sc: SparkContext, statement: String, queryOptions: QueryOptions = null, keyspace: Keyspace = null, connectionIdentifier: Option[String] = None)(implicit arg0: ClassTag[T], deserializer: JsonDeserializer[T])

Value Members

  1. def ++(other: RDD[T]): RDD[T]
    Definition Classes
    RDD
  2. def aggregate[U](zeroValue: U)(seqOp: (U, T) ⇒ U, combOp: (U, U) ⇒ U)(implicit arg0: ClassTag[U]): U
    Definition Classes
    RDD
  3. def barrier(): RDDBarrier[T]
    Definition Classes
    RDD
    Annotations
    @Experimental() @Since( "2.4.0" )
  4. def cache(): QueryRDD.this.type
    Definition Classes
    RDD
  5. def cartesian[U](other: RDD[U])(implicit arg0: ClassTag[U]): RDD[(T, U)]
    Definition Classes
    RDD
  6. def checkpoint(): Unit
    Definition Classes
    RDD
  7. def cleanShuffleDependencies(blocking: Boolean): Unit
    Definition Classes
    RDD
    Annotations
    @DeveloperApi() @Since( "3.1.0" )
  8. def coalesce(numPartitions: Int, shuffle: Boolean, partitionCoalescer: Option[PartitionCoalescer])(implicit ord: Ordering[T]): RDD[T]
    Definition Classes
    RDD
  9. def collect[U](f: PartialFunction[T, U])(implicit arg0: ClassTag[U]): RDD[U]
    Definition Classes
    RDD
  10. def collect(): Array[T]
    Definition Classes
    RDD
  11. def compute(split: Partition, context: TaskContext): Iterator[T]
    Definition Classes
    QueryRDD → RDD
  12. val connectionIdentifier: Option[String]
  13. def context: SparkContext
    Definition Classes
    RDD
  14. def count(): Long
    Definition Classes
    RDD
  15. def countApprox(timeout: Long, confidence: Double): PartialResult[BoundedDouble]
    Definition Classes
    RDD
  16. def countApproxDistinct(relativeSD: Double): Long
    Definition Classes
    RDD
  17. def countApproxDistinct(p: Int, sp: Int): Long
    Definition Classes
    RDD
  18. def countByValue()(implicit ord: Ordering[T]): Map[T, Long]
    Definition Classes
    RDD
  19. def countByValueApprox(timeout: Long, confidence: Double)(implicit ord: Ordering[T]): PartialResult[Map[T, BoundedDouble]]
    Definition Classes
    RDD
  20. final def dependencies: Seq[Dependency[_]]
    Definition Classes
    RDD
  21. def distinct(): RDD[T]
    Definition Classes
    RDD
  22. def distinct(numPartitions: Int)(implicit ord: Ordering[T]): RDD[T]
    Definition Classes
    RDD
  23. def filter(f: (T) ⇒ Boolean): RDD[T]
    Definition Classes
    RDD
  24. def first(): T
    Definition Classes
    RDD
  25. def flatMap[U](f: (T) ⇒ TraversableOnce[U])(implicit arg0: ClassTag[U]): RDD[U]
    Definition Classes
    RDD
  26. def fold(zeroValue: T)(op: (T, T) ⇒ T): T
    Definition Classes
    RDD
  27. def foreach(f: (T) ⇒ Unit): Unit
    Definition Classes
    RDD
  28. def foreachPartition(f: (Iterator[T]) ⇒ Unit): Unit
    Definition Classes
    RDD
  29. def getCheckpointFile: Option[String]
    Definition Classes
    RDD
  30. final def getNumPartitions: Int
    Definition Classes
    RDD
    Annotations
    @Since( "1.6.0" )
  31. def getResourceProfile(): ResourceProfile
    Definition Classes
    RDD
    Annotations
    @Experimental() @Since( "3.1.0" )
  32. def getStorageLevel: StorageLevel
    Definition Classes
    RDD
  33. def glom(): RDD[Array[T]]
    Definition Classes
    RDD
  34. def groupBy[K](f: (T) ⇒ K, p: Partitioner)(implicit kt: ClassTag[K], ord: Ordering[K]): RDD[(K, Iterable[T])]
    Definition Classes
    RDD
  35. def groupBy[K](f: (T) ⇒ K, numPartitions: Int)(implicit kt: ClassTag[K]): RDD[(K, Iterable[T])]
    Definition Classes
    RDD
  36. def groupBy[K](f: (T) ⇒ K)(implicit kt: ClassTag[K]): RDD[(K, Iterable[T])]
    Definition Classes
    RDD
  37. val id: Int
    Definition Classes
    RDD
  38. def intersection(other: RDD[T], numPartitions: Int): RDD[T]
    Definition Classes
    RDD
  39. def intersection(other: RDD[T], partitioner: Partitioner)(implicit ord: Ordering[T]): RDD[T]
    Definition Classes
    RDD
  40. def intersection(other: RDD[T]): RDD[T]
    Definition Classes
    RDD
  41. def isCheckpointed: Boolean
    Definition Classes
    RDD
  42. def isEmpty(): Boolean
    Definition Classes
    RDD
  43. final def iterator(split: Partition, context: TaskContext): Iterator[T]
    Definition Classes
    RDD
  44. def keyBy[K](f: (T) ⇒ K): RDD[(K, T)]
    Definition Classes
    RDD
  45. val keyspace: Keyspace
  46. def localCheckpoint(): QueryRDD.this.type
    Definition Classes
    RDD
  47. def map[U](f: (T) ⇒ U)(implicit arg0: ClassTag[U]): RDD[U]
    Definition Classes
    RDD
  48. def mapPartitions[U](f: (Iterator[T]) ⇒ Iterator[U], preservesPartitioning: Boolean)(implicit arg0: ClassTag[U]): RDD[U]
    Definition Classes
    RDD
  49. def mapPartitionsWithEvaluator[U](evaluatorFactory: PartitionEvaluatorFactory[T, U])(implicit arg0: ClassTag[U]): RDD[U]
    Definition Classes
    RDD
    Annotations
    @DeveloperApi() @Since( "3.5.0" )
  50. def mapPartitionsWithIndex[U](f: (Int, Iterator[T]) ⇒ Iterator[U], preservesPartitioning: Boolean)(implicit arg0: ClassTag[U]): RDD[U]
    Definition Classes
    RDD
  51. def max()(implicit ord: Ordering[T]): T
    Definition Classes
    RDD
  52. def min()(implicit ord: Ordering[T]): T
    Definition Classes
    RDD
  53. var name: String
    Definition Classes
    RDD
  54. val partitioner: Option[Partitioner]
    Definition Classes
    RDD
  55. final def partitions: Array[Partition]
    Definition Classes
    RDD
  56. def persist(): QueryRDD.this.type
    Definition Classes
    RDD
  57. def persist(newLevel: StorageLevel): QueryRDD.this.type
    Definition Classes
    RDD
  58. def pipe(command: Seq[String], env: Map[String, String], printPipeContext: ((String) ⇒ Unit) ⇒ Unit, printRDDElement: (T, (String) ⇒ Unit) ⇒ Unit, separateWorkingDir: Boolean, bufferSize: Int, encoding: String): RDD[String]
    Definition Classes
    RDD
  59. def pipe(command: String, env: Map[String, String]): RDD[String]
    Definition Classes
    RDD
  60. def pipe(command: String): RDD[String]
    Definition Classes
    RDD
  61. final def preferredLocations(split: Partition): Seq[String]
    Definition Classes
    RDD
  62. val queryOptions: QueryOptions
  63. def randomSplit(weights: Array[Double], seed: Long): Array[RDD[T]]
    Definition Classes
    RDD
  64. def reduce(f: (T, T) ⇒ T): T
    Definition Classes
    RDD
  65. def repartition(numPartitions: Int)(implicit ord: Ordering[T]): RDD[T]
    Definition Classes
    RDD
  66. def sample(withReplacement: Boolean, fraction: Double, seed: Long): RDD[T]
    Definition Classes
    RDD
  67. def saveAsObjectFile(path: String): Unit
    Definition Classes
    RDD
  68. def saveAsTextFile(path: String, codec: Class[_ <: CompressionCodec]): Unit
    Definition Classes
    RDD
  69. def saveAsTextFile(path: String): Unit
    Definition Classes
    RDD
  70. def setName(_name: String): QueryRDD.this.type
    Definition Classes
    RDD
  71. def sortBy[K](f: (T) ⇒ K, ascending: Boolean, numPartitions: Int)(implicit ord: Ordering[K], ctag: ClassTag[K]): RDD[T]
    Definition Classes
    RDD
  72. def sparkContext: SparkContext
    Definition Classes
    RDD
  73. val statement: String
  74. def subtract(other: RDD[T], p: Partitioner)(implicit ord: Ordering[T]): RDD[T]
    Definition Classes
    RDD
  75. def subtract(other: RDD[T], numPartitions: Int): RDD[T]
    Definition Classes
    RDD
  76. def subtract(other: RDD[T]): RDD[T]
    Definition Classes
    RDD
  77. def take(num: Int): Array[T]
    Definition Classes
    RDD
  78. def takeOrdered(num: Int)(implicit ord: Ordering[T]): Array[T]
    Definition Classes
    RDD
  79. def takeSample(withReplacement: Boolean, num: Int, seed: Long): Array[T]
    Definition Classes
    RDD
  80. def toDebugString: String
    Definition Classes
    RDD
  81. def toJavaRDD(): JavaRDD[T]
    Definition Classes
    RDD
  82. def toLocalIterator: Iterator[T]
    Definition Classes
    RDD
  83. def toString(): String
    Definition Classes
    RDD → AnyRef → Any
  84. def top(num: Int)(implicit ord: Ordering[T]): Array[T]
    Definition Classes
    RDD
  85. def treeAggregate[U](zeroValue: U, seqOp: (U, T) ⇒ U, combOp: (U, U) ⇒ U, depth: Int, finalAggregateOnExecutor: Boolean)(implicit arg0: ClassTag[U]): U
    Definition Classes
    RDD
  86. def treeAggregate[U](zeroValue: U)(seqOp: (U, T) ⇒ U, combOp: (U, U) ⇒ U, depth: Int)(implicit arg0: ClassTag[U]): U
    Definition Classes
    RDD
  87. def treeReduce(f: (T, T) ⇒ T, depth: Int): T
    Definition Classes
    RDD
  88. def union(other: RDD[T]): RDD[T]
    Definition Classes
    RDD
  89. def unpersist(blocking: Boolean): QueryRDD.this.type
    Definition Classes
    RDD
  90. def withResources(rp: ResourceProfile): QueryRDD.this.type
    Definition Classes
    RDD
    Annotations
    @Experimental() @Since( "3.1.0" )
  91. def zip[U](other: RDD[U])(implicit arg0: ClassTag[U]): RDD[(T, U)]
    Definition Classes
    RDD
  92. def zipPartitions[B, C, D, V](rdd2: RDD[B], rdd3: RDD[C], rdd4: RDD[D])(f: (Iterator[T], Iterator[B], Iterator[C], Iterator[D]) ⇒ Iterator[V])(implicit arg0: ClassTag[B], arg1: ClassTag[C], arg2: ClassTag[D], arg3: ClassTag[V]): RDD[V]
    Definition Classes
    RDD
  93. def zipPartitions[B, C, D, V](rdd2: RDD[B], rdd3: RDD[C], rdd4: RDD[D], preservesPartitioning: Boolean)(f: (Iterator[T], Iterator[B], Iterator[C], Iterator[D]) ⇒ Iterator[V])(implicit arg0: ClassTag[B], arg1: ClassTag[C], arg2: ClassTag[D], arg3: ClassTag[V]): RDD[V]
    Definition Classes
    RDD
  94. def zipPartitions[B, C, V](rdd2: RDD[B], rdd3: RDD[C])(f: (Iterator[T], Iterator[B], Iterator[C]) ⇒ Iterator[V])(implicit arg0: ClassTag[B], arg1: ClassTag[C], arg2: ClassTag[V]): RDD[V]
    Definition Classes
    RDD
  95. def zipPartitions[B, C, V](rdd2: RDD[B], rdd3: RDD[C], preservesPartitioning: Boolean)(f: (Iterator[T], Iterator[B], Iterator[C]) ⇒ Iterator[V])(implicit arg0: ClassTag[B], arg1: ClassTag[C], arg2: ClassTag[V]): RDD[V]
    Definition Classes
    RDD
  96. def zipPartitions[B, V](rdd2: RDD[B])(f: (Iterator[T], Iterator[B]) ⇒ Iterator[V])(implicit arg0: ClassTag[B], arg1: ClassTag[V]): RDD[V]
    Definition Classes
    RDD
  97. def zipPartitions[B, V](rdd2: RDD[B], preservesPartitioning: Boolean)(f: (Iterator[T], Iterator[B]) ⇒ Iterator[V])(implicit arg0: ClassTag[B], arg1: ClassTag[V]): RDD[V]
    Definition Classes
    RDD
  98. def zipPartitionsWithEvaluator[U](rdd2: RDD[T], evaluatorFactory: PartitionEvaluatorFactory[T, U])(implicit arg0: ClassTag[U]): RDD[U]
    Definition Classes
    RDD
    Annotations
    @DeveloperApi() @Since( "3.5.0" )
  99. def zipWithIndex(): RDD[(T, Long)]
    Definition Classes
    RDD
  100. def zipWithUniqueId(): RDD[(T, Long)]
    Definition Classes
    RDD