Обработка нескольких входов на шаг чайника

Question

Я пытаюсь создать шаг, на котором у меня есть два входа. Оба они должны быть в одном формате. Мне нужно обработать эти два входных потока и вывести один поток.

Ниже приведен код, у меня до сих пор в processRow():

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

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

, если его первая строка и следующий для всех строк:

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

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

Однако на линии data.oneRowSet = findInputRowSet(infoStreams.get(0).getStepname());, я получите следующую ошибку: The source step to read from [null] couldn't be found.

Ваши данные по этому вопросу были бы очень полезными. Благодарю.

EDIT: Я добавил пример трансформации и исходный код моего шага здесь: https://github.com/adeydas/KettleMultipleStreams/tree/develop

Answer 1

Я, кажется, нашел решение. Я написал небольшой «how-to» здесь: http://abhis.ws/display/KKB/Kettle+transformation+step+with+multiple+input+streams и код на GitHub: https://github.com/adeydas/KettleMultipleStreams.