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