0
Oracle에서 ElasticSearch로 레코드를 수집하는 데 Streamsets를 사용합니다. maprDB destination에 oracle 쿼리의 각 단계를 처리하는 레코드 수를 등록하고 싶습니다. 특정 스트림 세트 단계에서 레코드 수를 얻으려면 어떻게해야합니까?스트림 세트 단계의 레코드 수
A
답변
1
스크립트 프로세서 (JavaScript Evaluator) 중 하나를 삽입하여 이벤트 레코드를 트리거 할 수 있습니다. 그리고 MaprDB 목적지를 스크립트 프로세서 이벤트 레인에 연결하십시오.
var eventRecord = sdcFunctions.createEvent("count", 1);
eventRecord.value = { recordCount : records.length};
sdcFunctions.toEvent(eventRecord);
