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:

Architectural Diagram

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.

A NoSQLPublisher is responsible for creating, managing, and canceling all subscriptions created by the user.