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
-
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.