Package oracle.kv.pubsub
The classes defined here extend or implement the interfaces defined by the reactive stream APIs. Generally, the Oracle NoSQL Subscription API allows users to create subscription streams from each replication group in the Oracle NoSQL Database on a given tables. The subscription stream, as a sequence of onNext calls defined in reactive stream API, represents a partial order which guarantees that for any single key, the order of operations performed on that key on the Oracle NoSQL Database is strictly preserved. The interfaces and classes defined in this package includes NoSQLPublisher, NoSQLSubscriber, NoSQLSubscription and other auxiliary configuration classes required to use the Oracle NoSQL Subscription API.
-
ClassDescriptionException that is raised when a subscriber fails to make a checkpoint.Object represents a NoSQLPublisher which publishes changes to the NoSQL store on order, an implementation of Reactive Streams Publisher interface.Configuration used to create an instance of NoSQLPublisher.Builder to help construct a NoSQLPublisherConfig instanceSubscription stream mode used to configure the starting point for a NoSQL subscription.The subscriber interface is to be implemented by the application.Object to represent a subscriber id in a subscription group.A NoSQL subscription to the source kvstore.Configuration used by the NoSQL Publisher to create a subscription.Builder to construct a NoSQLSubscriptionConfig instanceException that will be raised when NoSQL Publisher cannot be created due to errors, or experiences irrecoverable errors and must be closed.Exception raised when publisher does not hear from source shard for a given period of time.The operation (Put, Delete) that was delivered over the NoSQL stream.Used to signal a Delete operationUsed to signal a Put operationA SequenceId uniquely identifies a stream operation associated with a Publisher.The type of the operation.A StreamPosition represents a position in a subscription stream.Exception raised when change cannot be applied to the running subscription, and the subscription is unchanged.Describes the reason that a change was not applied.Exception raised when a subscription fails.Exception used to indicate that the logs on at least one shard were insufficient for the purposes of the stream.Exception raised when one or more tables are not found in kvstore when performing an operation on a subscription.