class RDDFunctions[T] extends Serializable
Functions which can be performed on an RDD if the evidence matches.
- T
the generic RDD type to operate on.
- Alphabetic
- By Inheritance
- RDDFunctions
- Serializable
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new RDDFunctions(rdd: RDD[T])
- rdd
the rdd on which the operations are performed on.
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- def couchbaseInsert[V](keyspace: Keyspace = Keyspace(), insertOptions: InsertOptions = null, ignoreIfExists: Boolean = false, connectionIdentifier: String = null)(implicit evidence: <:<[RDD[T], RDD[Insert[V]]], serializer: JsonSerializer[V]): RDD[MutationResult]
Inserts documents into couchbase.
Inserts documents into couchbase.
- V
the generic type to use.
- keyspace
the optional keyspace to override the implicit configuration.
- insertOptions
optional parameters to customize the behavior.
- ignoreIfExists
set to true if individual DocumentExistsException should be ignored.
- evidence
the generic type for which this method is made available on the RDD.
- serializer
the JSON serializer to use when encoding the documents.
- returns
the RDD result.
- def couchbaseMutateIn(keyspace: Keyspace = Keyspace(), mutateInOptions: MutateInOptions = null, connectionIdentifier: String = null)(implicit evidence: <:<[RDD[T], RDD[MutateIn]]): RDD[MutateInResult]
Mutates sub-documents in couchbase.
Mutates sub-documents in couchbase.
- keyspace
the optional keyspace to override the implicit configuration.
- mutateInOptions
optional parameters to customize the behavior.
- evidence
the generic type for which this method is made available on the RDD.
- returns
the RDD result.
- def couchbaseRemove(keyspace: Keyspace = Keyspace(), removeOptions: RemoveOptions = null, ignoreIfNotFound: Boolean = false, connectionIdentifier: String = null)(implicit evidence: <:<[RDD[T], RDD[Remove]]): RDD[MutationResult]
Removes documents from couchbase.
Removes documents from couchbase.
- keyspace
the optional keyspace to override the implicit configuration.
- removeOptions
optional parameters to customize the behavior.
- ignoreIfNotFound
set to true if individual DocumentNotFoundException should be ignored.
- evidence
the generic type for which this method is made available on the RDD.
- returns
the RDD result.
- def couchbaseReplace[V](keyspace: Keyspace = Keyspace(), replaceOptions: ReplaceOptions = null, ignoreIfNotFound: Boolean = false, connectionIdentifier: String = null)(implicit evidence: <:<[RDD[T], RDD[Replace[V]]], serializer: JsonSerializer[V]): RDD[MutationResult]
Replaces documents in couchbase.
Replaces documents in couchbase.
- V
the generic type to use.
- keyspace
the optional keyspace to override the implicit configuration.
- replaceOptions
optional parameters to customize the behavior.
- ignoreIfNotFound
set to true if individual DocumentNotFoundException should be ignored.
- evidence
the generic type for which this method is made available on the RDD.
- serializer
the JSON serializer to use when encoding the documents.
- returns
the RDD result.
- def couchbaseUpsert[V](keyspace: Keyspace = Keyspace(), upsertOptions: UpsertOptions = null, connectionIdentifier: String = null)(implicit evidence: <:<[RDD[T], RDD[Upsert[V]]], serializer: JsonSerializer[V]): RDD[MutationResult]
Upserts documents into couchbase.
Upserts documents into couchbase.
- V
the generic type to use.
- keyspace
the optional keyspace to override the implicit configuration.
- upsertOptions
optional parameters to customize the behavior.
- evidence
the generic type for which this method is made available on the RDD.
- serializer
the JSON serializer to use when encoding the documents.
- returns
the RDD result.
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)