ストリームセットステージのレコード数

Question

OracleからElasticSearchへレコードを取り込むためにStreamsetsを使用します。私は、oracleクエリの各ステップを処理するレコードの数をmaprDB宛先に登録したいと考えています。特定のストリームセットステージでレコードの数を取得するにはどうすればよいですか？

Answer 1

スクリプトプロセッサ（JavaScriptエバリュエータ）を挿入して、イベントレコードをトリガすることができます。また、MaprDBのデスティネーションをスクリプトプロセッサのイベントレーンに接続します。

var eventRecord = sdcFunctions.createEvent("count", 1); 
eventRecord.value = { recordCount : records.length}; 
sdcFunctions.toEvent(eventRecord); 

Sample Pipeline