APIコンポーネント

Reactive Streams標準(http://www.reactive-streams.orgを参照)では、様々なAPIコンポーネントについて説明しています。Oracle NoSQL Database Streams APIについては、これらがすべて実装されています。主なAPIコンポーネントを次に簡単に示します。

API	説明	詳細情報
NoSQLPublisher	表操作を1つのストリームに集約し、サブスクライバから受け取った構成に従ってそれらをパブリッシュします。 どのJava JVMについても、1つのパブリッシャ構成に対してNoSQLPublisherクラス・インスタンスを1つのみ作成します。構成が異なっていれば、JVMごとに複数のパブリッシャを作成できます。たとえば、2つ以上のパブリッシャをサポートする1つのJVMを作成し、構成が異なる別々のストアにそれぞれを接続できます。 複数のサブスクライバを使用してOracle NoSQL Databaseストアからのイベントをストリームするように、ストリーミング・サービスをスケーリングできます。	NoSQLPublisherの概要は、Streamsパブリッシャの使用方法というタイトルの章を参照してください。 複数のサブスクライバを使用するようにストリーミング・サービスをスケーリングする方法の詳細は、Streamsアプリケーションのスケーリングを参照してください。 NoSQLPublisherの詳細は、「NoSQLPublisher」を参照してください。
NoSQLSubscriber	それぞれのストア操作、警告およびエラーの処理方法を定義するために実装する必要があるインタフェース。NoSQLPublisherは、提供されたそれぞれのNoSQLSubscriberインスタンスを管理します。NoSQLPublisherは、複数のNoSQLSubscriberインスタンスを使用できます。	サブスクライバ実装の概要は、サブスクライバの実装を参照してください。 複数のサブスクライバを使用してOracle NoSQL Databaseストアからのイベントをストリームする方法の詳細は、Streamsアプリケーションのスケーリングを参照してください。 NoSQLSubscriberの詳細は、「NoSQLSubscriber」を参照してください。
NoSQLSubscription	作成した1つのサブスクリプションを表します。このクラスは、操作ストリーム内に存在するwriteイベントとdeleteイベントをStreamOperationオブジェクトの形式で受け取り、処理のためにNoSQLSubscriber実装に提供します。	NoSQLSubscriptionの概要は、サブスクリプションの操作を参照してください。StreamOperationクラスについては、StreamOperationクラスの使用方法で概要を説明しています。 NoSQLSubscriptionの詳細は、「NoSQLSubscription」を参照してください。