Type Members

1.  case class Get(id: String) extends KeyValueOperation with Product with Serializable
2.  class GetRDD extends RDD[GetResult] with Logging
3.  case class Insert[T](id: String, content: T) extends KeyValueOperation with Product with Serializable
4.  class InsertRDD[T] extends RDD[MutationResult] with Logging
5.  class KeyValueContinuousStream extends KeyValueDataStream with ContinuousStream
6.  class KeyValueDataStream extends SparkDataStream with Logging
7.  case class KeyValueInputPartition(schema: StructType, partitionOffset: KeyValuePartitionOffset, conf: CouchbaseConfig, config: KeyValueStreamConfig) extends InputPartition with Product with Serializable
8.  class KeyValueMicroBatchStream extends KeyValueDataStream with MicroBatchStream
9.  case class KeyValueOffset(offsets: List[PartitionOffset]) extends Offset with Product with Serializable
10.  sealed abstract class KeyValueOperation extends AnyRef
11.  class KeyValuePartition extends Partition
12.  case class KeyValuePartitionOffset(streamStartOffsets: Map[Int, KeyValueStreamOffset], streamEndOffsets: Option[Map[Int, KeyValueStreamOffset]]) extends PartitionOffset with Product with Serializable

    Holds the offset information for an individual vbucket.

13.  class KeyValuePartitionReader extends ContinuousPartitionReader[InternalRow] with Logging

    The KeyValuePartitionReader is responsible for actually streaming the mutations from a number of vbuckets.

14.  class KeyValueScan extends Scan
15.  class KeyValueScanBuilder extends ScanBuilder
16.  class KeyValueSourceInitialOffsetWriter extends HDFSMetadataLog[Map[Int, KeyValueStreamOffset]]
17.  case class KeyValueStreamConfig(streamFrom: StreamFrom, numInputPartitions: Int, bucket: String, scope: Option[String], collections: Seq[String], streamContent: Boolean, streamXattrs: Boolean, flowControlBufferSize: Option[Int], persistencePollingInterval: Option[String], connectionIdentifier: Option[String]) extends Product with Serializable
18.  case class KeyValueStreamOffset(vbuuid: Long, seqno: Long, snapshotStartSeqno: Long, snapshotEndSeqno: Long, collectionsManifestUid: Long) extends Product with Serializable
19.  class KeyValueTable extends SupportsRead
20.  class KeyValueTableProvider extends Logging with TableProvider with DataSourceRegister with CreatableRelationProvider
21.  case class KeyValueWriteConfig(bucket: String, scope: Option[String], collection: Option[String], idFieldName: String, durability: Option[String], timeout: Option[String], connectionIdentifier: Option[String]) extends Product with Serializable
22.  case class LookupIn(id: String, specs: Seq[LookupInSpec]) extends KeyValueOperation with Product with Serializable
23.  class LookupInRDD extends RDD[LookupInResult] with Logging
24.  case class MutateIn(id: String, specs: Seq[MutateInSpec], cas: Long = 0) extends KeyValueOperation with Product with Serializable
25.  class MutateInRDD extends RDD[MutateInResult] with Logging
26.  class RelationPartitionWriter extends ForeachPartitionFunction[String] with Logging
27.  case class Remove(id: String, cas: Long = 0) extends KeyValueOperation with Product with Serializable
28.  class RemoveRDD extends RDD[MutationResult] with Logging
29.  case class Replace[T](id: String, content: T, cas: Long = 0) extends KeyValueOperation with Product with Serializable
30.  class ReplaceRDD[T] extends RDD[MutationResult] with Logging
31.  case class Upsert[T](id: String, content: T) extends KeyValueOperation with Product with Serializable
32.  class UpsertRDD[T] extends RDD[MutationResult] with Logging