Исполнитель преобразования интеграции данных Pentaho
Не вдаваясь в подробности о нашем конечном продукте, у меня есть несколько преобразований, которые связаны вместе с помощью шагов Transformation Executor в конце. Преобразование 1 имеет в конце шаг «Исполнитель преобразования», который выполняет преобразование 2.
Теперь мне нужно создать преобразования, которые обрабатывают более одного входного потока (например, использовать шаг добавления потоков под обложками). Хотя достаточно легко заставить каждое входное преобразование выполнять одно и то же преобразование во время своего шага Transformation Executor, я боюсь, что оно не будет работать правильно, если я не укажу, на какой входной поток на шаге Transformation Executor текущий поток должен быть сопоставлен. . К сожалению, документация Pentaho по этой теме очень слабая (то есть ее не существует).
Есть ли способ указать это?
Если я далеко и это действительно не беспокоит, пожалуйста, поясните это.
Как всегда, заранее спасибо за любую помощь, которую вы можете мне оказать !!
Я могу рассказать о случае, который вы описываете. На самом деле у меня есть KTR 1 и KTR 2, генерирующие данные, и мне нужно, чтобы они оба были входами в KTR 3, который преобразует оба потока. Есть ли способ сопоставить KTR 1 с одним входом в KTR 3 и сопоставить KTR 2 с другим?
Если KTR 1 и 2 только генерируют данные или имеют очень мало шагов, зачем разделять их на 2 KTR? Если это всего 2 входа, поместите их все на один KTR и соедините их там. Если бы вы могли поделиться изображением или образцом KJB / KTR, это очень помогло бы.
Я не уверен, что смогу показать вам образец кода, не нарушая какое-то соглашение о конфиденциальности с моей компанией. По сути, KTR1 и KTR2 являются строительными блоками. Иногда нам нужно только подключить выход KTR1 ко входу какого-то другого шага. Иногда это будет только KTR2. Иногда нам нужно объединить входные источники и соединить объединенный выход в другой шаг. Иногда мы хотим соединить два выхода в два отдельных входа на третьем шаге (например, что-то, выполняющее сортировку слиянием под крышками). Это последнее, что может лучше всего раскрыть проблему.
Позвольте мне попытаться лучше понять, что вам нужно, так это чтобы входной поток на KTR 1 выполнялся более одного раза, так сказать, для разных баз, это так? Как SQL-запрос, который можно запустить в нескольких БД, а KTR 2 просто преобразует эти данные, независимо от того, откуда они? Это верно ?