Может кто-нибудь помочь мне в приведенном ниже сценарии в Talend

Question

Может кто-нибудь помочь мне в приведенном ниже сценарии в Talend: -

Создать отображение на основе следующего сценария,

Источник Структура и свои данные,

STORE_NAME Varchar2 (20) 
Q1_SALES number (10, 4) 
Q2_SALES number (10, 4) 
Q3_SALES number (10, 4) 
Q4_SALES number (10, 4) 

DB_Store_Source: (плоский файл)

STORE_NAME Q1_SALES Q2_SALES Q3_SALES Q4_SALES 

XYZ 100 200 150 900 
ABC 111 222 789 763 
DEF 333 444 555 2000 

FF_Store_Source: (Flat File)

STORE_NAME Q1_SALES Q2_SALES Q3_SALES Q4_SALES 

XYZ 100 200 150 900 
ABC 111 222 789 763 
ZZZ 200 200 200 300 

Целевая структура,

Store_Target: 

SNo integer, 
STORE_NAME varchar2 (20), 
QUARTER_NAME varchar2 (20), 
SALES_PER_QUARTER number (10, 4) 

Из приведенного выше сценария, создать отображение для объединения данных из DB_Store_Source и FF_Store_Source и передать уникальную запись в Store_Target. SNo должно быть заполнено сгенерированным по порядку значением (первая запись Начиная с 1000), а остальная часть столбцов заполняется из источника на основе нормализации

Я могу получить с помощью уникальных строк. Даже я в состоянии нормализовать, но не смогли достичь последней части, т.е. как хранить quarter_name.using функцию taggregaterow сумму я могу получить функцию суммы

Answer 1

Если вы ищете результат ниже, а затем использовать tsplitrow компонент

tsplitrow свойств компонента в изображении ниже

Примечание: используйте компонент tsplitrow после того, как вы взяли уникальные записи.

Answer 2

Вы можете использовать нижеследующее решение, как показано на скриншоте в нижней части вопроса, чтобы достичь результата.

Я следовал ниже шагов в последовательности: -

1. Считывание данных из обоих FF_STORE и DB_STORE и распространяются все записи обоих входов к tHashOutput.

2. На следующем шаге я взял данные из tHashOutput в компонент tUnite, чтобы объединить обе записи источника данных.

3. На следующем шаге используется tSplitRow для разделения столбца Quarter для заполнения в столбце Quarter_Name.

4. Затем с помощью tUniqRow удаляются дубликаты на основе столбца ключа.

Пожалуйста, обратитесь к ниже изображения

solution image