The Oracle NoSQL Database streams API builds upon the existing JE facilities (that streams updates to replicas) to offer a store-wide stream of all write operations performed against tables to which the application is subscribed.
The following illustration depicts the overall architecture of the Oracle NoSQL Database streaming service:
Each shard in Oracle NoSQL Database supplies a stream of updates from the shard. The
NoSQLPublisher aggregates all the shard streams to implement a unified publisher interface for the entire Oracle NoSQL Database store that it presents to users.
NoSQLPublisher is responsible for creating, managing, and canceling all subscriptions created by the user.