object CouchbaseSource
- Source
- CouchbaseSource.scala
- Alphabetic
- By Inheritance
- CouchbaseSource
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
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
- def analyticsQuery(statement: String, options: AnalyticsOptions = AnalyticsOptions.analyticsOptions())(implicit scope: AsyncScope): Source[AnalyticsResult, NotUsed]
Performs an Analytics query , QueryResult contains List<Row>
Performs an Analytics query , QueryResult contains List<Row>
val rows: List[JsonObject] = QueryResult.rowsAsObject, every Row is a json with CollectionName key
{ "collectionName": Document }Warning: couchbase-community not support analyticsQuery, we not test this API https://www.couchbase.com/products/editions/server/
- statement
Analytics query sql
- def analyticsQueryJson(statement: String, options: AnalyticsOptions = AnalyticsOptions.analyticsOptions())(implicit scope: AsyncScope): Source[JsonObject, NotUsed]
Warning: couchbase-community not support analyticsQuery, we not test this API
Warning: couchbase-community not support analyticsQuery, we not test this API
Performs an Analytics query and convert document row to jsonObject
different with analyticsQuery, jsonObject not has the collection Key, but is Document directly- See also
- 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()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def get(id: String, options: GetOptions = GetOptions.getOptions)(implicit asyncCollection: AsyncCollection): Source[GetResult, NotUsed]
get a document by id from Couchbase collection
get a document by id from Couchbase collection
- id
document id
- options
reference to Couchbase options doc
- def getAllReplicas(id: String, options: GetAllReplicasOptions = GetAllReplicasOptions.getAllReplicasOptions)(implicit asyncCollection: AsyncCollection): Source[GetReplicaResult, NotUsed]
similar to CouchbaseSource.get .Reads from replicas or the active node based on the options and returns the results as a list
similar to CouchbaseSource.get .Reads from replicas or the active node based on the options and returns the results as a list
- options
reference to Couchbase options doc
- See also
- def getAllReplicasJson(id: String, options: GetAllReplicasOptions = GetAllReplicasOptions.getAllReplicasOptions)(implicit asyncCollection: AsyncCollection): Source[JsonObject, NotUsed]
reference to CouchbaseSource.getAllReplicas, deserialize to Couchbase JsonObject
- def getAllReplicasObject[T](id: String, target: Class[T], options: GetAllReplicasOptions = GetAllReplicasOptions.getAllReplicasOptions)(implicit asyncCollection: AsyncCollection): Source[T, NotUsed]
reference to CouchbaseSource.getAllReplicas, deserialize to class If you add DefaultScalaModule to jackson of couchbase, it could deserialize to scala class
- def getAllReplicasType[T](id: String, target: TypeRef[T], options: GetAllReplicasOptions = GetAllReplicasOptions.getAllReplicasOptions)(implicit asyncCollection: AsyncCollection): Source[T, NotUsed]
reference to CouchbaseSource.getAllReplicasObject, deserialize to class with Generics
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def getJson(id: String, options: GetOptions = GetOptions.getOptions)(implicit asyncCollection: AsyncCollection): Source[JsonObject, NotUsed]
reference to CouchbaseSource.get deserialize to Couchbase JsonObject
- def getObject[T](id: String, target: Class[T], options: GetOptions = GetOptions.getOptions)(implicit asyncCollection: AsyncCollection): Source[T, NotUsed]
reference to CouchbaseSource.get,deserialize to class
- def getType[T](id: String, target: TypeRef[T], options: GetOptions = GetOptions.getOptions)(implicit asyncCollection: AsyncCollection): Source[T, NotUsed]
reference to CouchbaseSource.getObject,deserialize to class with Generics
- 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()
- def query(statement: String, options: QueryOptions = QueryOptions.queryOptions())(implicit scope: AsyncScope): Source[QueryResult, NotUsed]
N1QL query in a Scope.
N1QL query in a Scope.
QueryResult contains List<Row>, every Row is a json like
{ "collectionName": Document } - def queryAllIndex(options: GetAllQueryIndexesOptions = GetAllQueryIndexesOptions.getAllQueryIndexesOptions)(implicit asyncCollection: AsyncCollection): Source[QueryIndex, NotUsed]
Fetches all indexes from this collection with custom options.
Fetches all indexes from this collection with custom options.
- def queryJson(statement: String, options: QueryOptions = QueryOptions.queryOptions())(implicit scope: AsyncScope): Source[JsonObject, NotUsed]
N1QL query in a Scope.
- def scan(scanType: ScanType, options: ScanOptions = ScanOptions.scanOptions())(implicit asyncCollection: AsyncCollection): Source[ScanResult, NotUsed]
similar to GetCouchbaseSource.get, batch get documents from collection by ScanTypeScanType
- def scanJson(scanType: ScanType, options: ScanOptions = ScanOptions.scanOptions())(implicit asyncCollection: AsyncCollection): Source[JsonObject, NotUsed]
reference to CouchbaseSource.scan, deserialize to Couchbase JsonObject
- def scanObject[T](scanType: ScanType, target: Class[T], options: ScanOptions = ScanOptions.scanOptions())(implicit asyncCollection: AsyncCollection): Source[T, NotUsed]
reference to CouchbaseSource.scan, deserialize to class If you add DefaultScalaModule to jackson of couchbase, it could deserialize to scala class
- def scanType[T](scanType: ScanType, target: TypeRef[T], options: ScanOptions = ScanOptions.scanOptions())(implicit asyncCollection: AsyncCollection): Source[T, NotUsed]
reference to CouchbaseSource.scan, CouchbaseSource.scanObject, deserialize to class with Generics
- 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])