주전자 단계에 대한 다중 입력 처리

Question

두 개의 입력이있는 단계를 만들려고합니다. 둘 다 같은 형식이어야합니다. 이 두 입력 스트림을 사용하여 처리하고 하나의 스트림을 출력해야합니다. 다음은

내가 processRow() 지금까지 가지고있는 코드 :

List<StreamInterface> infoStreams = meta.getStepIOMeta().getInfoStreams(); 

data.oneRowSet = findInputRowSet(infoStreams.get(0).getStepname()); 
data.twoRowSet = findInputRowSet(infoStreams.get(1).getStepname()); 

경우 자사의 첫 번째 행과 모든 행에 대해 다음 라인 data.oneRowSet = findInputRowSet(infoStreams.get(0).getStepname());에 그러나

data.one = getRowFrom(data.oneRowSet); 
data.two = getRowFrom(data.twoRowSet); 

if (data.one == null && data.two == null) { 
     setOutputDone(); 
     return false; 
} 

, I 다음 오류가 발생합니다 : The source step to read from [null] couldn't be found.

당신의 의견은 정말 도움이 될 것입니다. 감사.

편집 : https://github.com/adeydas/KettleMultipleStreams/tree/develop

Answer 1

내가 해결책을 찾은 것 같다 : 나는 예를 들어 변환 및 여기 내 단계의 소스 코드를 추가했습니다. 여기에 작은 "사용법"을 작성했습니다 : http://abhis.ws/display/KKB/Kettle+transformation+step+with+multiple+input+streams이고 코드는 GitHub : https://github.com/adeydas/KettleMultipleStreams에 있습니다.