CassandraJavaRDD

Instance Constructors

new CassandraJavaRDD(rdd: CassandraRDD[R], classTag: ClassTag[R])
new CassandraJavaRDD(rdd: CassandraRDD[R], clazz: Class[R])

Value Members

final def !=(arg0: Any): Boolean

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

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

Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to any2stringadd[CassandraJavaRDD[R]] performed by method any2stringadd in scala.Predef.
Definition Classes
any2stringadd
def ++(other: RDD[R]): RDD[R]

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

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

Definition Classes
AnyRef → Any
def aggregate[U](zeroValue: U)(seqOp: Function2[U, R, U], combOp: Function2[U, U, U]): U

Definition Classes
JavaRDDLike
final def asInstanceOf[T0]: T0

Definition Classes
Any
def barrier(): RDDBarrier[R]

Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
Definition Classes
RDD
Annotations
@Experimental() @Since( "2.4.0" )
def cache(): JavaRDD[R]

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

Definition Classes
JavaRDDLike
def cassandraCount(): Long
def checkpoint(): Unit

Definition Classes
JavaRDDLike
implicit val classTag: ClassTag[R]

Definition Classes
JavaRDD → JavaRDDLike
def clone(): AnyRef

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

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

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

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

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

Definition Classes
JavaRDDLike
def compute(split: Partition, context: TaskContext): Iterator[R]

Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
Definition Classes
RDD
Annotations
@DeveloperApi()
def context: SparkContext

Definition Classes
JavaRDDLike
def count(): Long

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

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

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

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

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

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

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

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

Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
Definition Classes
RDD
def distinct(numPartitions: Int): JavaRDD[R]

Definition Classes
JavaRDD
def distinct(): JavaRDD[R]

Definition Classes
JavaRDD
def ensuring(cond: (CassandraJavaRDD[R]) ⇒ Boolean, msg: ⇒ Any): CassandraJavaRDD[R]

Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to Ensuring[CassandraJavaRDD[R]] performed by method Ensuring in scala.Predef.
Definition Classes
Ensuring
def ensuring(cond: (CassandraJavaRDD[R]) ⇒ Boolean): CassandraJavaRDD[R]

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

Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to Ensuring[CassandraJavaRDD[R]] performed by method Ensuring in scala.Predef.
Definition Classes
Ensuring
def ensuring(cond: Boolean): CassandraJavaRDD[R]

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

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

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

Definition Classes
JavaRDD
def finalize(): Unit

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

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

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

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

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

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

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

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

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

Definition Classes
JavaRDDLike
def formatted(fmtstr: String): String

Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to StringFormat[CassandraJavaRDD[R]] performed by method StringFormat in scala.Predef.
Definition Classes
StringFormat
Annotations
@inline()
def getCheckpointFile(): Optional[String]

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

Definition Classes
AnyRef → Any
def getNumPartitions: Int

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

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

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

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

Definition Classes
JavaRDDLike
def hashCode(): Int

Definition Classes
AnyRef → Any
def id: Int

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

Definition Classes
JavaRDD
def isCheckpointed: Boolean

Definition Classes
JavaRDDLike
def isEmpty(): Boolean

Definition Classes
JavaRDDLike
final def isInstanceOf[T0]: Boolean

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

Definition Classes
JavaRDDLike
def keyBy[U](f: Function[R, U]): JavaPairRDD[U, R]

Definition Classes
JavaRDDLike
def limit(rowsNumber: Long): CassandraJavaRDD[R]
def localCheckpoint(): RDD[R]

Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
Definition Classes
RDD
def map[R](f: Function[R, R]): JavaRDD[R]

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

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

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

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

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

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

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

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

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

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

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

Definition Classes
JavaRDDLike
def name(): String

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

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
def partitioner: Optional[Partitioner]

Definition Classes
JavaRDDLike
def partitions: List[Partition]

Definition Classes
JavaRDDLike
def perPartitionLimit(rowsNumber: Long): CassandraJavaRDD[R]
def persist(newLevel: StorageLevel): JavaRDD[R]

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

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

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

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

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

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

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

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

Definition Classes
JavaRDD
def rdd(): CassandraRDD[R]

Definition Classes
CassandraJavaRDD → JavaRDD → JavaRDDLike
def reduce(f: Function2[R, R, R]): R

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

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

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

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

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

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

Definition Classes
JavaRDDLike
def select(columns: <repeated...>[ColumnRef]): CassandraJavaRDD[R]
def select(columnNames: <repeated...>[String]): CassandraJavaRDD[R]
def selectedColumnNames(): Array[String]
def selectedColumnRefs(): Array[ColumnRef]
def setName(name: String): JavaRDD[R]

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

Definition Classes
JavaRDD
def spanBy[K](f: Function[R, K], keyClass: Class[K]): JavaPairRDD[K, Iterable[R]]
def spanBy[K](f: Function[R, K], keyClassTag: ClassTag[K]): JavaPairRDD[K, Iterable[R]]
def sparkContext: SparkContext

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

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

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

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

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

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

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

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

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

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

Definition Classes
JavaRDDLike
def toDebugString(): String

Definition Classes
JavaRDDLike
def toEmptyCassandraRDD(): CassandraJavaRDD[R]
def toJavaRDD(): JavaRDD[R]

Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
Definition Classes
RDD
def toLocalIterator(): Iterator[R]

Definition Classes
JavaRDDLike
def toString(): String

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

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

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

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

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

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

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

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

Definition Classes
JavaRDD
def unpersist(): JavaRDD[R]

Definition Classes
JavaRDD
final def wait(): Unit

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

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

Definition Classes
AnyRef
Annotations
@throws( ... )
def where(cqlWhereClause: String, args: <repeated...>[AnyRef]): CassandraJavaRDD[R]
def withAscOrder(): CassandraJavaRDD[R]
def withConnector(connector: CassandraConnector): CassandraJavaRDD[R]
def withDescOrder(): CassandraJavaRDD[R]
def withReadConf(config: ReadConf): CassandraJavaRDD[R]
def wrap(newRDD: CassandraRDD[R]): CassandraJavaRDD[R]

Attributes
protected[com.datastax.spark.connector.japi.rdd]
def wrapRDD(rdd: RDD[R]): JavaRDD[R]

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

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

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

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

Definition Classes
JavaRDDLike
def →[B](y: B): (CassandraJavaRDD[R], B)

Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to ArrowAssoc[CassandraJavaRDD[R]] performed by method ArrowAssoc in scala.Predef.
Definition Classes
ArrowAssoc

Shadowed Implicit Value Members

def aggregate[U](zeroValue: U)(seqOp: (U, R) ⇒ U, combOp: (U, U) ⇒ U)(implicit arg0: ClassTag[U]): U
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).aggregate(zeroValue)(seqOp, combOp)(arg0)
Definition Classes
RDD
def cache(): RDD[R]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).cache()
Definition Classes
RDD
def cartesian[U](other: RDD[U])(implicit arg0: ClassTag[U]): RDD[(R, U)]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).cartesian(other)(arg0)
Definition Classes
RDD
def checkpoint(): Unit
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).checkpoint()
Definition Classes
RDD
def coalesce(numPartitions: Int, shuffle: Boolean, partitionCoalescer: Option[PartitionCoalescer])(implicit ord: Ordering[R]): RDD[R]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).coalesce(numPartitions, shuffle, partitionCoalescer)(ord)
Definition Classes
RDD
def collect[U](f: PartialFunction[R, U])(implicit arg0: ClassTag[U]): RDD[U]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).collect(f)(arg0)
Definition Classes
RDD
def collect(): Array[R]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).collect()
Definition Classes
RDD
def context: SparkContext
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).context
Definition Classes
RDD
def count(): Long
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).count()
Definition Classes
RDD
def countApprox(timeout: Long, confidence: Double): PartialResult[BoundedDouble]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).countApprox(timeout, confidence)
Definition Classes
RDD
def countApproxDistinct(relativeSD: Double): Long
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).countApproxDistinct(relativeSD)
Definition Classes
RDD
def countApproxDistinct(p: Int, sp: Int): Long
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).countApproxDistinct(p, sp)
Definition Classes
RDD
def countByValue()(implicit ord: Ordering[R]): Map[R, Long]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).countByValue()(ord)
Definition Classes
RDD
def countByValueApprox(timeout: Long, confidence: Double)(implicit ord: Ordering[R]): PartialResult[Map[R, BoundedDouble]]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).countByValueApprox(timeout, confidence)(ord)
Definition Classes
RDD
def distinct(): RDD[R]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).distinct()
Definition Classes
RDD
def distinct(numPartitions: Int)(implicit ord: Ordering[R]): RDD[R]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).distinct(numPartitions)(ord)
Definition Classes
RDD
def filter(f: (R) ⇒ Boolean): RDD[R]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).filter(f)
Definition Classes
RDD
def first(): R
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).first()
Definition Classes
RDD
def flatMap[U](f: (R) ⇒ TraversableOnce[U])(implicit arg0: ClassTag[U]): RDD[U]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).flatMap(f)(arg0)
Definition Classes
RDD
def fold(zeroValue: R)(op: (R, R) ⇒ R): R
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).fold(zeroValue)(op)
Definition Classes
RDD
def foreach(f: (R) ⇒ Unit): Unit
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).foreach(f)
Definition Classes
RDD
def foreachPartition(f: (Iterator[R]) ⇒ Unit): Unit
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).foreachPartition(f)
Definition Classes
RDD
def getCheckpointFile: Option[String]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).getCheckpointFile
Definition Classes
RDD
final def getNumPartitions: Int
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).getNumPartitions
Definition Classes
RDD
Annotations
@Since( "1.6.0" )
def getStorageLevel: StorageLevel
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).getStorageLevel
Definition Classes
RDD
def glom(): RDD[Array[R]]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).glom()
Definition Classes
RDD
def groupBy[K](f: (R) ⇒ K, p: Partitioner)(implicit kt: ClassTag[K], ord: Ordering[K]): RDD[(K, Iterable[R])]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).groupBy(f, p)(kt, ord)
Definition Classes
RDD
def groupBy[K](f: (R) ⇒ K, numPartitions: Int)(implicit kt: ClassTag[K]): RDD[(K, Iterable[R])]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).groupBy(f, numPartitions)(kt)
Definition Classes
RDD
def groupBy[K](f: (R) ⇒ K)(implicit kt: ClassTag[K]): RDD[(K, Iterable[R])]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).groupBy(f)(kt)
Definition Classes
RDD
val id: Int
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).id
Definition Classes
RDD
def intersection(other: RDD[R], numPartitions: Int): RDD[R]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).intersection(other, numPartitions)
Definition Classes
RDD
def intersection(other: RDD[R], partitioner: Partitioner)(implicit ord: Ordering[R]): RDD[R]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).intersection(other, partitioner)(ord)
Definition Classes
RDD
def intersection(other: RDD[R]): RDD[R]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).intersection(other)
Definition Classes
RDD
def isCheckpointed: Boolean
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).isCheckpointed
Definition Classes
RDD
def isEmpty(): Boolean
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).isEmpty()
Definition Classes
RDD
final def iterator(split: Partition, context: TaskContext): Iterator[R]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).iterator(split, context)
Definition Classes
RDD
def keyBy[K](f: (R) ⇒ K): RDD[(K, R)]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).keyBy(f)
Definition Classes
RDD
def map[U](f: (R) ⇒ U)(implicit arg0: ClassTag[U]): RDD[U]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).map(f)(arg0)
Definition Classes
RDD
def mapPartitions[U](f: (Iterator[R]) ⇒ Iterator[U], preservesPartitioning: Boolean)(implicit arg0: ClassTag[U]): RDD[U]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).mapPartitions(f, preservesPartitioning)(arg0)
Definition Classes
RDD
def mapPartitionsWithIndex[U](f: (Int, Iterator[R]) ⇒ Iterator[U], preservesPartitioning: Boolean)(implicit arg0: ClassTag[U]): RDD[U]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).mapPartitionsWithIndex(f, preservesPartitioning)(arg0)
Definition Classes
RDD
def max()(implicit ord: Ordering[R]): R
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).max()(ord)
Definition Classes
RDD
def min()(implicit ord: Ordering[R]): R
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).min()(ord)
Definition Classes
RDD
var name: String
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).name
Definition Classes
RDD
val partitioner: Option[Partitioner]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).partitioner
Definition Classes
RDD
final def partitions: Array[Partition]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).partitions
Definition Classes
RDD
def persist(): RDD[R]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).persist()
Definition Classes
RDD
def persist(newLevel: StorageLevel): RDD[R]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).persist(newLevel)
Definition Classes
RDD
def pipe(command: Seq[String], env: Map[String, String], printPipeContext: ((String) ⇒ Unit) ⇒ Unit, printRDDElement: (R, (String) ⇒ Unit) ⇒ Unit, separateWorkingDir: Boolean, bufferSize: Int, encoding: String): RDD[String]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).pipe(command, env, printPipeContext, printRDDElement, separateWorkingDir, bufferSize, encoding)
Definition Classes
RDD
def pipe(command: String, env: Map[String, String]): RDD[String]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).pipe(command, env)
Definition Classes
RDD
def pipe(command: String): RDD[String]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).pipe(command)
Definition Classes
RDD
def randomSplit(weights: Array[Double], seed: Long): Array[RDD[R]]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).randomSplit(weights, seed)
Definition Classes
RDD
def reduce(f: (R, R) ⇒ R): R
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).reduce(f)
Definition Classes
RDD
def repartition(numPartitions: Int)(implicit ord: Ordering[R]): RDD[R]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).repartition(numPartitions)(ord)
Definition Classes
RDD
def sample(withReplacement: Boolean, fraction: Double, seed: Long): RDD[R]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).sample(withReplacement, fraction, seed)
Definition Classes
RDD
def saveAsObjectFile(path: String): Unit
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).saveAsObjectFile(path)
Definition Classes
RDD
def saveAsTextFile(path: String, codec: Class[_ <: CompressionCodec]): Unit
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).saveAsTextFile(path, codec)
Definition Classes
RDD
def saveAsTextFile(path: String): Unit
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).saveAsTextFile(path)
Definition Classes
RDD
def setName(_name: String): RDD[R]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).setName(_name)
Definition Classes
RDD
def sortBy[K](f: (R) ⇒ K, ascending: Boolean, numPartitions: Int)(implicit ord: Ordering[K], ctag: ClassTag[K]): RDD[R]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).sortBy(f, ascending, numPartitions)(ord, ctag)
Definition Classes
RDD
def subtract(other: RDD[R], p: Partitioner)(implicit ord: Ordering[R]): RDD[R]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).subtract(other, p)(ord)
Definition Classes
RDD
def subtract(other: RDD[R], numPartitions: Int): RDD[R]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).subtract(other, numPartitions)
Definition Classes
RDD
def subtract(other: RDD[R]): RDD[R]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).subtract(other)
Definition Classes
RDD
def take(num: Int): Array[R]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).take(num)
Definition Classes
RDD
def takeOrdered(num: Int)(implicit ord: Ordering[R]): Array[R]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).takeOrdered(num)(ord)
Definition Classes
RDD
def takeSample(withReplacement: Boolean, num: Int, seed: Long): Array[R]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).takeSample(withReplacement, num, seed)
Definition Classes
RDD
def toDebugString: String
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).toDebugString
Definition Classes
RDD
def toLocalIterator: Iterator[R]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).toLocalIterator
Definition Classes
RDD
def toString(): String
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).toString()
Definition Classes
RDD → AnyRef → Any
def top(num: Int)(implicit ord: Ordering[R]): Array[R]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).top(num)(ord)
Definition Classes
RDD
def treeAggregate[U](zeroValue: U)(seqOp: (U, R) ⇒ U, combOp: (U, U) ⇒ U, depth: Int)(implicit arg0: ClassTag[U]): U
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).treeAggregate(zeroValue)(seqOp, combOp, depth)(arg0)
Definition Classes
RDD
def treeReduce(f: (R, R) ⇒ R, depth: Int): R
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).treeReduce(f, depth)
Definition Classes
RDD
def union(other: RDD[R]): RDD[R]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).union(other)
Definition Classes
RDD
def unpersist(blocking: Boolean): RDD[R]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).unpersist(blocking)
Definition Classes
RDD
def zip[U](other: RDD[U])(implicit arg0: ClassTag[U]): RDD[(R, U)]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).zip(other)(arg0)
Definition Classes
RDD
def zipPartitions[B, C, D, V](rdd2: RDD[B], rdd3: RDD[C], rdd4: RDD[D])(f: (Iterator[R], Iterator[B], Iterator[C], Iterator[D]) ⇒ Iterator[V])(implicit arg0: ClassTag[B], arg1: ClassTag[C], arg2: ClassTag[D], arg3: ClassTag[V]): RDD[V]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).zipPartitions(rdd2, rdd3, rdd4)(f)(arg0, arg1, arg2, arg3)
Definition Classes
RDD
def zipPartitions[B, C, D, V](rdd2: RDD[B], rdd3: RDD[C], rdd4: RDD[D], preservesPartitioning: Boolean)(f: (Iterator[R], Iterator[B], Iterator[C], Iterator[D]) ⇒ Iterator[V])(implicit arg0: ClassTag[B], arg1: ClassTag[C], arg2: ClassTag[D], arg3: ClassTag[V]): RDD[V]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).zipPartitions(rdd2, rdd3, rdd4, preservesPartitioning)(f)(arg0, arg1, arg2, arg3)
Definition Classes
RDD
def zipPartitions[B, C, V](rdd2: RDD[B], rdd3: RDD[C])(f: (Iterator[R], Iterator[B], Iterator[C]) ⇒ Iterator[V])(implicit arg0: ClassTag[B], arg1: ClassTag[C], arg2: ClassTag[V]): RDD[V]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).zipPartitions(rdd2, rdd3)(f)(arg0, arg1, arg2)
Definition Classes
RDD
def zipPartitions[B, C, V](rdd2: RDD[B], rdd3: RDD[C], preservesPartitioning: Boolean)(f: (Iterator[R], Iterator[B], Iterator[C]) ⇒ Iterator[V])(implicit arg0: ClassTag[B], arg1: ClassTag[C], arg2: ClassTag[V]): RDD[V]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).zipPartitions(rdd2, rdd3, preservesPartitioning)(f)(arg0, arg1, arg2)
Definition Classes
RDD
def zipPartitions[B, V](rdd2: RDD[B])(f: (Iterator[R], Iterator[B]) ⇒ Iterator[V])(implicit arg0: ClassTag[B], arg1: ClassTag[V]): RDD[V]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).zipPartitions(rdd2)(f)(arg0, arg1)
Definition Classes
RDD
def zipPartitions[B, V](rdd2: RDD[B], preservesPartitioning: Boolean)(f: (Iterator[R], Iterator[B]) ⇒ Iterator[V])(implicit arg0: ClassTag[B], arg1: ClassTag[V]): RDD[V]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).zipPartitions(rdd2, preservesPartitioning)(f)(arg0, arg1)
Definition Classes
RDD
def zipWithIndex(): RDD[(R, Long)]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).zipWithIndex()
Definition Classes
RDD
def zipWithUniqueId(): RDD[(R, Long)]
Implicit information
This member is added by an implicit conversion from CassandraJavaRDD[R] to RDD[R] performed by method toRDD in org.apache.spark.api.java.JavaRDD.
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:
(cassandraJavaRDD: RDD[R]).zipWithUniqueId()
Definition Classes
RDD

Inherited from JavaRDD[R]

Inherited from AbstractJavaRDDLike[R, JavaRDD[R]]

Inherited from JavaRDDLike[R, JavaRDD[R]]

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Inherited by implicit conversion toRDD from CassandraJavaRDD[R] to RDD[R]

Inherited by implicit conversion any2stringadd from CassandraJavaRDD[R] to any2stringadd[CassandraJavaRDD[R]]

Inherited by implicit conversion StringFormat from CassandraJavaRDD[R] to StringFormat[CassandraJavaRDD[R]]

Inherited by implicit conversion Ensuring from CassandraJavaRDD[R] to Ensuring[CassandraJavaRDD[R]]

Inherited by implicit conversion ArrowAssoc from CassandraJavaRDD[R] to ArrowAssoc[CassandraJavaRDD[R]]

Ungrouped

Related Doc: package rdd

class CassandraJavaRDD[R] extends JavaRDD[R]

Instance Constructors

new CassandraJavaRDD(rdd: CassandraRDD[R], classTag: ClassTag[R])

new CassandraJavaRDD(rdd: CassandraRDD[R], clazz: Class[R])

Value Members

final def !=(arg0: Any): Boolean

final def ##(): Int

def +(other: String): String

def ++(other: RDD[R]): RDD[R]

def ->[B](y: B): (CassandraJavaRDD[R], B)

final def ==(arg0: Any): Boolean

def aggregate[U](zeroValue: U)(seqOp: Function2[U, R, U], combOp: Function2[U, U, U]): U

final def asInstanceOf[T0]: T0

def barrier(): RDDBarrier[R]

def cache(): JavaRDD[R]

def cartesian[U](other: JavaRDDLike[U, _]): JavaPairRDD[R, U]

def cassandraCount(): Long

def checkpoint(): Unit

implicit val classTag: ClassTag[R]

def clone(): AnyRef

def coalesce(numPartitions: Int, shuffle: Boolean): JavaRDD[R]

def coalesce(numPartitions: Int): JavaRDD[R]

def collect(): List[R]

def collectAsync(): JavaFutureAction[List[R]]

def collectPartitions(partitionIds: Array[Int]): Array[List[R]]

def compute(split: Partition, context: TaskContext): Iterator[R]

def context: SparkContext

def count(): Long

def countApprox(timeout: Long): PartialResult[BoundedDouble]

def countApprox(timeout: Long, confidence: Double): PartialResult[BoundedDouble]

def countApproxDistinct(relativeSD: Double): Long

def countAsync(): JavaFutureAction[Long]

def countByValue(): Map[R, Long]

def countByValueApprox(timeout: Long): PartialResult[Map[R, BoundedDouble]]

def countByValueApprox(timeout: Long, confidence: Double): PartialResult[Map[R, BoundedDouble]]

final def dependencies: Seq[Dependency[_]]

def distinct(numPartitions: Int): JavaRDD[R]

def distinct(): JavaRDD[R]

def ensuring(cond: (CassandraJavaRDD[R]) ⇒ Boolean, msg: ⇒ Any): CassandraJavaRDD[R]

def ensuring(cond: (CassandraJavaRDD[R]) ⇒ Boolean): CassandraJavaRDD[R]

def ensuring(cond: Boolean, msg: ⇒ Any): CassandraJavaRDD[R]

def ensuring(cond: Boolean): CassandraJavaRDD[R]

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

def filter(f: Function[R, Boolean]): JavaRDD[R]

def finalize(): Unit

def first(): R

def flatMap[U](f: FlatMapFunction[R, U]): JavaRDD[U]

def flatMapToDouble(f: DoubleFlatMapFunction[R]): JavaDoubleRDD

def flatMapToPair[K2, V2](f: PairFlatMapFunction[R, K2, V2]): JavaPairRDD[K2, V2]

def fold(zeroValue: R)(f: Function2[R, R, R]): R

def foreach(f: VoidFunction[R]): Unit

def foreachAsync(f: VoidFunction[R]): JavaFutureAction[Void]

def foreachPartition(f: VoidFunction[Iterator[R]]): Unit

def foreachPartitionAsync(f: VoidFunction[Iterator[R]]): JavaFutureAction[Void]

def formatted(fmtstr: String): String

def getCheckpointFile(): Optional[String]

final def getClass(): Class[_]

def getNumPartitions: Int

def getStorageLevel: StorageLevel

def glom(): JavaRDD[List[R]]

def groupBy[U](f: Function[R, U], numPartitions: Int): JavaPairRDD[U, Iterable[R]]

def groupBy[U](f: Function[R, U]): JavaPairRDD[U, Iterable[R]]

def hashCode(): Int

def id: Int

def intersection(other: JavaRDD[R]): JavaRDD[R]

def isCheckpointed: Boolean

def isEmpty(): Boolean

final def isInstanceOf[T0]: Boolean

def iterator(split: Partition, taskContext: TaskContext): Iterator[R]

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

def limit(rowsNumber: Long): CassandraJavaRDD[R]

def localCheckpoint(): RDD[R]

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

def mapPartitions[U](f: FlatMapFunction[Iterator[R], U], preservesPartitioning: Boolean): JavaRDD[U]

def mapPartitions[U](f: FlatMapFunction[Iterator[R], U]): JavaRDD[U]

def mapPartitionsToDouble(f: DoubleFlatMapFunction[Iterator[R]], preservesPartitioning: Boolean): JavaDoubleRDD

def mapPartitionsToDouble(f: DoubleFlatMapFunction[Iterator[R]]): JavaDoubleRDD