増分書込みの実行

writeRecords()メソッドを使用して、レコードの増分セットをレコード・ストアに書き込みます。

増分書込みを実行するには:

  1. create()メソッドをコールし、ServiceAddressオブジェクトおよびレコード・ストア・インスタンス名を渡して、レコード・ストア・サーバーへの接続を作成します。
    ServiceAddress address = new ServiceAddress(host, port, contextPath); 
    RecordStoreLocator locator = RecordStoreLocator.create(address, instanceName);
  2. getService()メソッドをコールして、レコード・ストア・インスタンスを作成します。
    RecordStore recordStore = locator.getService();
  3. startTransaction()メソッドをコールして、READ_WRITEトランザクションを開始します。
    TransactionId transactionId = recordStore.startTransaction(TransactionType.READ_WRITE);
  4. writeRecords()メソッドをコールして、レコードのバッチを書き込みます。
    recordStore.writeRecords(recordBatch1);
    この手順を繰り返して、レコードの他のバッチをレコード・ストアに書き込みます。
  5. commitTransaction()メソッドをコールして、トランザクションをコミットします。
    recordStore.commitTransaction(transactionId);

増分書込みの実行例

ServiceAddress address = new ServiceAddress(host, port, contextPath); 
RecordStoreLocator locator = RecordStoreLocator.create(address, instanceName);

RecordStore recordStore = locator.getService();

TransactionId transactionId = recordStore.startTransaction(TransactionType.READ_WRITE);

recordStore.writeRecords(recordBatch1);

recordStore.writeRecords(recordBatch2);

recordStore.commitTransaction(transactionId);