See: Description
Interface | Description |
---|---|
NoSQLSubscriber |
The subscriber interface is to be implemented by the application.
|
NoSQLSubscription |
A NoSQL subscription to the source kvstore.
|
StreamOperation |
The operation (Put, Delete) that was delivered over the NoSQL stream.
|
StreamOperation.DeleteEvent |
Used to signal a Delete operation
|
StreamOperation.PutEvent |
Used to signal a Put operation
|
StreamOperation.SequenceId |
A SequenceId uniquely identifies a stream operation associated with a
Publisher.
|
Class | Description |
---|---|
NoSQLPublisher |
Object represents a NoSQLPublisher which publishes changes to the NoSQL
store on order, an implementation of Reactive Streams Publisher interface.
|
NoSQLPublisherConfig |
Configuration used to create an instance of NoSQLPublisher.
|
NoSQLPublisherConfig.Builder |
Builder to help construct a NoSQLPublisherConfig instance
|
NoSQLSubscriberId |
Object to represent a subscriber id in a subscription group.
|
NoSQLSubscriptionConfig |
Configuration used by the NoSQL Publisher to create a subscription.
|
NoSQLSubscriptionConfig.Builder |
Builder to construct a NoSQLSubscriptionConfig instance
|
StreamPosition |
A StreamPosition represents a position in a subscription stream.
|
Enum | Description |
---|---|
NoSQLStreamMode |
Subscription stream mode used to configure the starting point for a NoSQL
subscription.
|
StreamOperation.Type |
The type of the operation.
|
Exception | Description |
---|---|
CheckpointFailureException |
Exception that is raised when a subscriber fails to make a checkpoint.
|
PublisherFailureException |
Exception that will be raised when NoSQL Publisher cannot be created due
to errors, or experiences irrecoverable errors and must be closed.
|
ShardTimeoutException |
Exception raised when publisher does not hear from source shard for a
given period of time.
|
SubscriptionFailureException |
Exception raised when a subscription fails.
|
SubscriptionInsufficientLogException |
Exception used to indicate that the logs on at least one shard were
insufficient for the purposes of the stream.
|
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.
Copyright (c) 2011, 2017 Oracle and/or its affiliates. All rights reserved.