Streamsets階段的記錄數

Question

我使用Streamsets從Oracle向ElasticSearch提取記錄。我想在maprDB目標中註冊我在oracle查詢中處理每個步驟的記錄數。我怎樣才能在特定的流式設置階段獲得記錄的數量？

Answer 1

您可以插入一個腳本處理器（JavaScript Evaluator）來觸發事件記錄。並將MaprDB目標連接到腳本處理器事件通道。

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

Sample Pipeline