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
- Serializable
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
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( ... ) @native() @IntrinsicCandidate()
-
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: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
-
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
- @native() @IntrinsicCandidate()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
-
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( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
Deprecated Value Members
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] ) @Deprecated
- Deprecated