diff --git a/mappings/info_recruits/citizen_tables/border_crossing/parallel/border_crossing_flow.hpl b/mappings/info_recruits/citizen_tables/border_crossing/parallel/border_crossing_flow.hpl index 1b5c9d0..9dc7965 100644 --- a/mappings/info_recruits/citizen_tables/border_crossing/parallel/border_crossing_flow.hpl +++ b/mappings/info_recruits/citizen_tables/border_crossing/parallel/border_crossing_flow.hpl @@ -114,11 +114,6 @@ Table output - Block until transforms finish - Y - - - Block until transforms finish Filter rows Y @@ -143,29 +138,6 @@ 480 - - Block until transforms finish - BlockUntilTransformsFinish - - Y - - 1 - - none - - - - - - Update - - - - - 1264 - 320 - - Change job status on error ExecSql @@ -474,21 +446,23 @@ JOIN LATERAL ( none - N ${java.io.tmpdir} + + 1000000 + + N + + Y + recruit_id Y N N 0 - recruit_id N - srt - 1000000 - Y 688 diff --git a/mappings/info_recruits/citizen_tables/border_crossing/parallel/border_crossing_flow_delta.hpl b/mappings/info_recruits/citizen_tables/border_crossing/parallel/border_crossing_flow_delta.hpl index d7cc283..583e6aa 100644 --- a/mappings/info_recruits/citizen_tables/border_crossing/parallel/border_crossing_flow_delta.hpl +++ b/mappings/info_recruits/citizen_tables/border_crossing/parallel/border_crossing_flow_delta.hpl @@ -103,11 +103,6 @@ Insert / update - Block until transforms finish - Y - - - Block until transforms finish Filter rows Y @@ -132,29 +127,6 @@ 544 - - Block until transforms finish - BlockUntilTransformsFinish - - Y - - 1 - - none - - - - - - Update - - - - - 1200 - 352 - - Change job status on error ExecSql @@ -480,21 +452,23 @@ JOIN LATERAL ( none - N ${java.io.tmpdir} + + 1000000 + + N + + Y + recruit_id Y N N 0 - recruit_id N - srt - 1000000 - Y 752 diff --git a/mappings/info_recruits/citizen_tables/border_crossing/parallel/border_crossing_flow_repeat.hpl b/mappings/info_recruits/citizen_tables/border_crossing/parallel/border_crossing_flow_repeat.hpl index 85cd7c9..25dc20b 100644 --- a/mappings/info_recruits/citizen_tables/border_crossing/parallel/border_crossing_flow_repeat.hpl +++ b/mappings/info_recruits/citizen_tables/border_crossing/parallel/border_crossing_flow_repeat.hpl @@ -100,11 +100,6 @@ Insert / update - Block until transforms finish - Y - - - Block until transforms finish Filter rows Y @@ -129,29 +124,6 @@ 416 - - Block until transforms finish - BlockUntilTransformsFinish - - Y - - 1 - - none - - - - - - Update - - - - - 1296 - 208 - - Change job status on error ExecSql @@ -491,21 +463,23 @@ JOIN LATERAL ( none - N ${java.io.tmpdir} + + 1000000 + + N + + Y + recruit_id Y N N 0 - recruit_id N - srt - 1000000 - Y 672 diff --git a/mappings/info_recruits/citizen_tables/citizen_appealing_violations_fz53/parallel/citizen_appealing_violations_fz53_flow.hpl b/mappings/info_recruits/citizen_tables/citizen_appealing_violations_fz53/parallel/citizen_appealing_violations_fz53_flow.hpl index aa16067..4bdb654 100644 --- a/mappings/info_recruits/citizen_tables/citizen_appealing_violations_fz53/parallel/citizen_appealing_violations_fz53_flow.hpl +++ b/mappings/info_recruits/citizen_tables/citizen_appealing_violations_fz53/parallel/citizen_appealing_violations_fz53_flow.hpl @@ -125,11 +125,6 @@ Table output - Block until transforms finish - Y - - - Block until transforms finish Filter rows Y @@ -154,28 +149,6 @@ 832 - - Block until transforms finish - BlockUntilTransformsFinish - - Y - - 1 - - none - - - - - Update - - - - - 1296 - 656 - - Change job status on error ExecSql @@ -357,7 +330,6 @@ VALUES (DEFAULT, '${JOB_NAME}', 'PROCESSING', DEFAULT, null, '${IDM_ID}'); postgres.decision-document-service N - SELECT ad.recruit_id, ad.create_date, -- дата создания обжалования @@ -510,21 +482,23 @@ JOIN public.recruit r ON r.id = ad.recruit_id AND '${IDM_ID}' != '' -- Пров none - N ${java.io.tmpdir} + + 1000000 + + N + + Y + recruit_id Y N N 0 - recruit_id N - srt - 1000000 - Y 800 diff --git a/mappings/info_recruits/citizen_tables/citizen_appealing_violations_fz53/parallel/citizen_appealing_violations_fz53_flow_delta.hpl b/mappings/info_recruits/citizen_tables/citizen_appealing_violations_fz53/parallel/citizen_appealing_violations_fz53_flow_delta.hpl index b4fad23..a9049b3 100644 --- a/mappings/info_recruits/citizen_tables/citizen_appealing_violations_fz53/parallel/citizen_appealing_violations_fz53_flow_delta.hpl +++ b/mappings/info_recruits/citizen_tables/citizen_appealing_violations_fz53/parallel/citizen_appealing_violations_fz53_flow_delta.hpl @@ -70,18 +70,13 @@ sort_by_recruit_id Y - - Insert / update - Block until transforms finish - Y - Identify last row in a stream Detect empty stream Y - Block until transforms finish + Insert / update Filter rows Y @@ -106,28 +101,6 @@ 400 - - Block until transforms finish - BlockUntilTransformsFinish - - Y - - 1 - - none - - - - - Update - - - - - 1248 - 224 - - Change job status on error ExecSql @@ -396,7 +369,6 @@ and recruitment_id = '${IDM_ID}'; postgres.decision-document-service N - SELECT ad.recruit_id, ad.create_date, -- дата создания обжалования @@ -480,21 +452,23 @@ JOIN public.recruit r ON r.id = ad.recruit_id AND '${IDM_ID}' != '' -- Пров none - N ${java.io.tmpdir} + + 1000000 + + N + + Y + recruit_id Y N N 0 - recruit_id N - srt - 1000000 - Y 736 diff --git a/mappings/info_recruits/citizen_tables/citizen_appealing_violations_fz53/parallel/citizen_appealing_violations_fz53_flow_repeat.hpl b/mappings/info_recruits/citizen_tables/citizen_appealing_violations_fz53/parallel/citizen_appealing_violations_fz53_flow_repeat.hpl index 2f11a23..4114937 100644 --- a/mappings/info_recruits/citizen_tables/citizen_appealing_violations_fz53/parallel/citizen_appealing_violations_fz53_flow_repeat.hpl +++ b/mappings/info_recruits/citizen_tables/citizen_appealing_violations_fz53/parallel/citizen_appealing_violations_fz53_flow_repeat.hpl @@ -77,11 +77,6 @@ Insert / update - Block until transforms finish - Y - - - Block until transforms finish Filter rows Y @@ -106,28 +101,6 @@ 368 - - Block until transforms finish - BlockUntilTransformsFinish - - Y - - 1 - - none - - - - - Update - - - - - 1232 - 208 - - Change job status on error ExecSql @@ -411,7 +384,6 @@ DO UPDATE SET postgres.decision-document-service N - SELECT ad.recruit_id, ad.create_date, -- дата создания обжалования @@ -494,21 +466,23 @@ JOIN public.recruit r ON r.id = ad.recruit_id AND '${IDM_ID}' != '' -- Пров none - N ${java.io.tmpdir} + + 1000000 + + N + + Y + recruit_id Y N N 0 - recruit_id N - srt - 1000000 - Y 656 diff --git a/mappings/info_recruits/citizen_tables/citizen_criminal_liability_fz53/parallel/citizen_criminal_liability_fz53_flow.hpl b/mappings/info_recruits/citizen_tables/citizen_criminal_liability_fz53/parallel/citizen_criminal_liability_fz53_flow.hpl index cfe7cc4..b9e1fa4 100644 --- a/mappings/info_recruits/citizen_tables/citizen_criminal_liability_fz53/parallel/citizen_criminal_liability_fz53_flow.hpl +++ b/mappings/info_recruits/citizen_tables/citizen_criminal_liability_fz53/parallel/citizen_criminal_liability_fz53_flow.hpl @@ -65,11 +65,6 @@ Detect empty stream Y - - Table output - Block until transforms finish - Y - Identify last row in a stream sort_by_recruit_id @@ -81,7 +76,7 @@ Y - Block until transforms finish + Table output Filter rows Y @@ -106,28 +101,6 @@ 800 - - Block until transforms finish - BlockUntilTransformsFinish - - Y - - 1 - - none - - - - - Update - - - - - 1424 - 640 - - Change job status on error ExecSql @@ -309,7 +282,6 @@ VALUES (DEFAULT, '${JOB_NAME}', 'PROCESSING', DEFAULT, null, '${IDM_ID}'); postgres.decision-document-service N - SELECT i.recruit_id, i.created_at, @@ -495,21 +467,23 @@ WHERE i.type = 'CRIMINAL' none - N ${java.io.tmpdir} + + 1000000 + + N + + Y + recruit_id Y N N 0 - recruit_id N - srt - 1000000 - Y 912 diff --git a/mappings/info_recruits/citizen_tables/citizen_criminal_liability_fz53/parallel/citizen_criminal_liability_fz53_flow_delta.hpl b/mappings/info_recruits/citizen_tables/citizen_criminal_liability_fz53/parallel/citizen_criminal_liability_fz53_flow_delta.hpl index d7bb1bd..eb50978 100644 --- a/mappings/info_recruits/citizen_tables/citizen_criminal_liability_fz53/parallel/citizen_criminal_liability_fz53_flow_delta.hpl +++ b/mappings/info_recruits/citizen_tables/citizen_criminal_liability_fz53/parallel/citizen_criminal_liability_fz53_flow_delta.hpl @@ -77,11 +77,6 @@ Insert / update - Block until transforms finish - Y - - - Block until transforms finish Filter rows Y @@ -106,28 +101,6 @@ 720 - - Block until transforms finish - BlockUntilTransformsFinish - - Y - - 1 - - none - - - - - Update - - - - - 1264 - 528 - - Change job status on error ExecSql @@ -515,21 +488,23 @@ WHERE i.type = 'CRIMINAL' none - N ${java.io.tmpdir} + + 1000000 + + N + + Y + recruit_id Y N N 0 - recruit_id N - srt - 1000000 - Y 752 diff --git a/mappings/info_recruits/citizen_tables/citizen_criminal_liability_fz53/parallel/citizen_criminal_liability_fz53_flow_repeat.hpl b/mappings/info_recruits/citizen_tables/citizen_criminal_liability_fz53/parallel/citizen_criminal_liability_fz53_flow_repeat.hpl index b252737..1291de8 100644 --- a/mappings/info_recruits/citizen_tables/citizen_criminal_liability_fz53/parallel/citizen_criminal_liability_fz53_flow_repeat.hpl +++ b/mappings/info_recruits/citizen_tables/citizen_criminal_liability_fz53/parallel/citizen_criminal_liability_fz53_flow_repeat.hpl @@ -70,18 +70,13 @@ Update Y - - Insert / update - Block until transforms finish - Y - Identify last row in a stream Detect empty stream Y - Block until transforms finish + Insert / update Filter rows Y @@ -106,28 +101,6 @@ 384 - - Block until transforms finish - BlockUntilTransformsFinish - - Y - - 1 - - none - - - - - Update - - - - - 1184 - 208 - - Change job status on error ExecSql @@ -436,7 +409,6 @@ DO UPDATE SET postgres.decision-document-service N - SELECT i.recruit_id, i.created_at, @@ -533,21 +505,23 @@ WHERE i.type = 'CRIMINAL' none - N ${java.io.tmpdir} + + 1000000 + + N + + Y + recruit_id Y N N 0 - recruit_id N - srt - 1000000 - Y 688 diff --git a/mappings/info_recruits/citizen_tables/citizen_liability_fz53/parallel/citizen_liability_fz53_flow.hpl b/mappings/info_recruits/citizen_tables/citizen_liability_fz53/parallel/citizen_liability_fz53_flow.hpl index 3e00e56..4352b43 100644 --- a/mappings/info_recruits/citizen_tables/citizen_liability_fz53/parallel/citizen_liability_fz53_flow.hpl +++ b/mappings/info_recruits/citizen_tables/citizen_liability_fz53/parallel/citizen_liability_fz53_flow.hpl @@ -70,21 +70,16 @@ Detect empty stream Y - - Table output - Block until transforms finish - Y - - - Block until transforms finish - Filter rows - Y - sort_by_recruit_id Update Y + + Table output + Filter rows + Y + Abort @@ -106,28 +101,6 @@ 1056 - - Block until transforms finish - BlockUntilTransformsFinish - - Y - - 1 - - none - - - - - Update - - - - - 1152 - 832 - - Change job status on error ExecSql @@ -494,21 +467,23 @@ WHERE type = 'ADMINISTRATIVE' none - N ${java.io.tmpdir} + + 1000000 + + N + + Y + recruit_id Y N N 0 - recruit_id N - srt - 1000000 - Y 688 diff --git a/mappings/info_recruits/citizen_tables/citizen_liability_fz53/parallel/citizen_liability_fz53_flow_delta.hpl b/mappings/info_recruits/citizen_tables/citizen_liability_fz53/parallel/citizen_liability_fz53_flow_delta.hpl index 3f42baa..1db1bcd 100644 --- a/mappings/info_recruits/citizen_tables/citizen_liability_fz53/parallel/citizen_liability_fz53_flow_delta.hpl +++ b/mappings/info_recruits/citizen_tables/citizen_liability_fz53/parallel/citizen_liability_fz53_flow_delta.hpl @@ -65,16 +65,6 @@ Detect empty stream Y - - Insert / update - Block until transforms finish - Y - - - Block until transforms finish - Filter rows - Y - Identify last row in a stream sort_by_recruit_id @@ -85,6 +75,11 @@ Update Y + + Insert / update + Filter rows + Y + Abort @@ -106,28 +101,6 @@ 576 - - Block until transforms finish - BlockUntilTransformsFinish - - Y - - 1 - - none - - - - - Update - - - - - 1296 - 400 - - Change job status on error ExecSql @@ -520,21 +493,23 @@ WHERE type = 'ADMINISTRATIVE' none - N ${java.io.tmpdir} + + 1000000 + + N + + Y + recruit_id Y N N 0 - recruit_id N - srt - 1000000 - Y 832 diff --git a/mappings/info_recruits/citizen_tables/citizen_liability_fz53/parallel/citizen_liability_fz53_flow_repeat.hpl b/mappings/info_recruits/citizen_tables/citizen_liability_fz53/parallel/citizen_liability_fz53_flow_repeat.hpl index 2848fe6..d4f0855 100644 --- a/mappings/info_recruits/citizen_tables/citizen_liability_fz53/parallel/citizen_liability_fz53_flow_repeat.hpl +++ b/mappings/info_recruits/citizen_tables/citizen_liability_fz53/parallel/citizen_liability_fz53_flow_repeat.hpl @@ -55,11 +55,6 @@ Insert / update Y - - Insert / update - Block until transforms finish - Y - Identify last row in a stream Detect empty stream @@ -81,7 +76,7 @@ Y - Block until transforms finish + Insert / update Filter rows Y @@ -106,28 +101,6 @@ 400 - - Block until transforms finish - BlockUntilTransformsFinish - - Y - - 1 - - none - - - - - Update - - - - - 1088 - 208 - - Change job status on error ExecSql @@ -441,7 +414,6 @@ DO UPDATE SET postgres.decision-document-service N - SELECT i.recruit_id, i.created_at, @@ -534,21 +506,23 @@ WHERE type = 'ADMINISTRATIVE' none - N ${java.io.tmpdir} + + 1000000 + + N + + Y + recruit_id Y N N 0 - recruit_id N - srt - 1000000 - Y 656 diff --git a/mappings/info_recruits/citizen_tables/citizenship/parallel/citizenship_flow.hpl b/mappings/info_recruits/citizen_tables/citizenship/parallel/citizenship_flow.hpl index dbebd8b..65f42cb 100644 --- a/mappings/info_recruits/citizen_tables/citizenship/parallel/citizenship_flow.hpl +++ b/mappings/info_recruits/citizen_tables/citizenship/parallel/citizenship_flow.hpl @@ -65,16 +65,6 @@ Detect empty stream Y - - Table output - Block until transforms finish - Y - - - Block until transforms finish - Filter rows - Y - Identify last row in a stream sort_by_recruit_id @@ -85,6 +75,11 @@ Update Y + + Table output + Filter rows + Y + Abort @@ -106,28 +101,6 @@ 496 - - Block until transforms finish - BlockUntilTransformsFinish - - Y - - 1 - - none - - - - - Update - - - - - 1312 - 320 - - Change job status on error ExecSql @@ -456,21 +429,23 @@ where --ri.info->'svedGrazhdanRF'->>'prOtsGrazhdanRF' is null and none - N ${java.io.tmpdir} + + 1000000 + + N + + Y + recruit_id Y N N 0 - recruit_id N - srt - 1000000 - Y 688 diff --git a/mappings/info_recruits/citizen_tables/citizenship/parallel/citizenship_flow_delta.hpl b/mappings/info_recruits/citizen_tables/citizenship/parallel/citizenship_flow_delta.hpl index b5efb3d..bddc0b2 100644 --- a/mappings/info_recruits/citizen_tables/citizenship/parallel/citizenship_flow_delta.hpl +++ b/mappings/info_recruits/citizen_tables/citizenship/parallel/citizenship_flow_delta.hpl @@ -65,16 +65,6 @@ Detect empty stream Y - - Insert / update - Block until transforms finish - Y - - - Block until transforms finish - Filter rows - Y - Identify last row in a stream sort_by_recruit_id @@ -85,6 +75,11 @@ Update Y + + Insert / update + Filter rows + Y + Abort @@ -106,28 +101,6 @@ 528 - - Block until transforms finish - BlockUntilTransformsFinish - - Y - - 1 - - none - - - - - Update - - - - - 1200 - 352 - - Change job status on error ExecSql @@ -401,7 +374,6 @@ and recruitment_id = '${IDM_ID}'; ervu-dashboard N - select ri.recruit_id, to_date(ri.info->'svedFL'->'svedGrazhdanRF'->'grazhdanRF'->>'dataSved', 'YYYY-MM-DD') AS source_update_date, -- дата обновления сведений @@ -482,21 +454,23 @@ where --ri.info->'svedGrazhdanRF'->>'prOtsGrazhdanRF' is null and none - N ${java.io.tmpdir} + + 1000000 + + N + + Y + recruit_id Y N N 0 - recruit_id N - srt - 1000000 - Y 768 diff --git a/mappings/info_recruits/citizen_tables/citizenship/parallel/citizenship_flow_repeat.hpl b/mappings/info_recruits/citizen_tables/citizenship/parallel/citizenship_flow_repeat.hpl index 7099292..28d1d9e 100644 --- a/mappings/info_recruits/citizen_tables/citizenship/parallel/citizenship_flow_repeat.hpl +++ b/mappings/info_recruits/citizen_tables/citizenship/parallel/citizenship_flow_repeat.hpl @@ -60,16 +60,6 @@ Insert / update Y - - Insert / update - Block until transforms finish - Y - - - Block until transforms finish - Filter rows - Y - Identify last row in a stream Detect empty stream @@ -85,6 +75,11 @@ Update Y + + Insert / update + Filter rows + Y + Abort @@ -106,28 +101,6 @@ 400 - - Block until transforms finish - BlockUntilTransformsFinish - - Y - - 1 - - none - - - - - Update - - - - - 1168 - 208 - - Change job status on error ExecSql @@ -416,7 +389,6 @@ DO UPDATE SET ervu-dashboard N - select ri.recruit_id, to_date(ri.info->'svedFL'->'svedGrazhdanRF'->'grazhdanRF'->>'dataSved', 'YYYY-MM-DD') AS source_update_date, -- дата обновления сведений @@ -495,21 +467,23 @@ where --ri.info->'svedGrazhdanRF'->>'prOtsGrazhdanRF' is null and none - N ${java.io.tmpdir} + + 1000000 + + N + + Y + recruit_id Y N N 0 - recruit_id N - srt - 1000000 - Y 672 diff --git a/mappings/info_recruits/citizen_tables/citizenship_foreign/parallel/citizenship_foreign_flow.hpl b/mappings/info_recruits/citizen_tables/citizenship_foreign/parallel/citizenship_foreign_flow.hpl index 14164c6..e5095ea 100644 --- a/mappings/info_recruits/citizen_tables/citizenship_foreign/parallel/citizenship_foreign_flow.hpl +++ b/mappings/info_recruits/citizen_tables/citizenship_foreign/parallel/citizenship_foreign_flow.hpl @@ -65,16 +65,6 @@ Detect empty stream Y - - Table output - Block until transforms finish - Y - - - Block until transforms finish - Filter rows - Y - Identify last row in a stream sort_by_recruit_id @@ -85,6 +75,11 @@ Update Y + + Table output + Filter rows + Y + Abort @@ -106,28 +101,6 @@ 480 - - Block until transforms finish - BlockUntilTransformsFinish - - Y - - 1 - - none - - - - - Update - - - - - 1120 - 320 - - Change job status on error ExecSql @@ -309,7 +282,6 @@ VALUES (DEFAULT, '${JOB_NAME}', 'PROCESSING', DEFAULT, null, '${IDM_ID}'); ervu-dashboard N - WITH base AS ( SELECT ri.recruit_id, @@ -485,21 +457,23 @@ FROM citizen none - N ${java.io.tmpdir} + + 1000000 + + N + + Y + recruit_id Y N N 0 - recruit_id N - srt - 1000000 - Y 688 diff --git a/mappings/info_recruits/citizen_tables/citizenship_foreign/parallel/citizenship_foreign_flow_delta.hpl b/mappings/info_recruits/citizen_tables/citizenship_foreign/parallel/citizenship_foreign_flow_delta.hpl index cd6b03c..2f4cb91 100644 --- a/mappings/info_recruits/citizen_tables/citizenship_foreign/parallel/citizenship_foreign_flow_delta.hpl +++ b/mappings/info_recruits/citizen_tables/citizenship_foreign/parallel/citizenship_foreign_flow_delta.hpl @@ -70,21 +70,16 @@ Detect empty stream Y - - Insert / update - Block until transforms finish - Y - - - Block until transforms finish - Filter rows - Y - sort_by_recruit_id Update Y + + Insert / update + Filter rows + Y + Abort @@ -106,28 +101,6 @@ 528 - - Block until transforms finish - BlockUntilTransformsFinish - - Y - - 1 - - none - - - - - Update - - - - - 1232 - 352 - - Change job status on error ExecSql @@ -503,21 +476,23 @@ FROM citizen none - N ${java.io.tmpdir} + + 1000000 + + N + + Y + recruit_id Y N N 0 - recruit_id N - srt - 1000000 - Y 784 diff --git a/mappings/info_recruits/citizen_tables/citizenship_foreign/parallel/citizenship_foreign_flow_repeat.hpl b/mappings/info_recruits/citizen_tables/citizenship_foreign/parallel/citizenship_foreign_flow_repeat.hpl index 0d00ff5..d9a2408 100644 --- a/mappings/info_recruits/citizen_tables/citizenship_foreign/parallel/citizenship_foreign_flow_repeat.hpl +++ b/mappings/info_recruits/citizen_tables/citizenship_foreign/parallel/citizenship_foreign_flow_repeat.hpl @@ -77,11 +77,6 @@ Insert / update - Block until transforms finish - Y - - - Block until transforms finish Filter rows Y @@ -106,28 +101,6 @@ 400 - - Block until transforms finish - BlockUntilTransformsFinish - - Y - - 1 - - none - - - - - Update - - - - - 1168 - 208 - - Change job status on error ExecSql @@ -510,21 +483,23 @@ FROM citizen none - N ${java.io.tmpdir} + + 1000000 + + N + + Y + recruit_id Y N N 0 - recruit_id N - srt - 1000000 - Y 704 diff --git a/mappings/info_recruits/citizen_tables/deferment_liberation/parallel/deferment_liberation_flow.hpl b/mappings/info_recruits/citizen_tables/deferment_liberation/parallel/deferment_liberation_flow.hpl index 9ce8ff0..adaddee 100644 --- a/mappings/info_recruits/citizen_tables/deferment_liberation/parallel/deferment_liberation_flow.hpl +++ b/mappings/info_recruits/citizen_tables/deferment_liberation/parallel/deferment_liberation_flow.hpl @@ -70,21 +70,16 @@ Detect empty stream Y - - Table output - Block until transforms finish - Y - - - Block until transforms finish - Filter rows - Y - sort_by_recruit_id Update Y + + Table output + Filter rows + Y + Abort @@ -106,28 +101,6 @@ 464 - - Block until transforms finish - BlockUntilTransformsFinish - - Y - - 1 - - none - - - - - Update - - - - - 1184 - 320 - - Change job status on error ExecSql @@ -309,7 +282,6 @@ VALUES (DEFAULT, '${JOB_NAME}', 'PROCESSING', DEFAULT, null, '${IDM_ID}'); postgres.decision-document-service N - WITH part_recruits AS ( SELECT @@ -498,21 +470,23 @@ WHERE d.type_code = '2' -- освобождение none - N ${java.io.tmpdir} + + 1000000 + + N + + Y + recruit_id Y N N 0 - recruit_id N - srt - 1000000 - Y 688 diff --git a/mappings/info_recruits/citizen_tables/deferment_liberation/parallel/deferment_liberation_flow_delta.hpl b/mappings/info_recruits/citizen_tables/deferment_liberation/parallel/deferment_liberation_flow_delta.hpl index 0af2223..3a20ee2 100644 --- a/mappings/info_recruits/citizen_tables/deferment_liberation/parallel/deferment_liberation_flow_delta.hpl +++ b/mappings/info_recruits/citizen_tables/deferment_liberation/parallel/deferment_liberation_flow_delta.hpl @@ -77,11 +77,6 @@ Insert / update - Block until transforms finish - Y - - - Block until transforms finish Filter rows Y @@ -106,28 +101,6 @@ 512 - - Block until transforms finish - BlockUntilTransformsFinish - - Y - - 1 - - none - - - - - Update - - - - - 1200 - 352 - - Change job status on error ExecSql @@ -381,7 +354,6 @@ and recruitment_id = '${IDM_ID}'; postgres.decision-document-service N - WITH part_recruits AS ( SELECT @@ -501,21 +473,23 @@ WHERE d.type_code = '2' -- освобождение none - N ${java.io.tmpdir} + + 1000000 + + N + + Y + recruit_id Y N N 0 - recruit_id N - srt - 1000000 - Y 752 diff --git a/mappings/info_recruits/citizen_tables/deferment_liberation/parallel/deferment_liberation_flow_repeat.hpl b/mappings/info_recruits/citizen_tables/deferment_liberation/parallel/deferment_liberation_flow_repeat.hpl index 4a5ccf0..aa73ae3 100644 --- a/mappings/info_recruits/citizen_tables/deferment_liberation/parallel/deferment_liberation_flow_repeat.hpl +++ b/mappings/info_recruits/citizen_tables/deferment_liberation/parallel/deferment_liberation_flow_repeat.hpl @@ -65,16 +65,6 @@ Detect empty stream Y - - Insert / update - Block until transforms finish - Y - - - Block until transforms finish - Filter rows - Y - Identify last row in a stream sort_by_recruit_id @@ -85,6 +75,11 @@ Update Y + + Insert / update + Filter rows + Y + Abort @@ -106,28 +101,6 @@ 400 - - Block until transforms finish - BlockUntilTransformsFinish - - Y - - 1 - - none - - - - - Update - - - - - 1088 - 208 - - Change job status on error ExecSql @@ -396,7 +369,6 @@ DO UPDATE SET postgres.decision-document-service N - WITH part_recruits AS ( SELECT @@ -515,21 +487,23 @@ WHERE d.type_code = '2' -- освобождение none - N ${java.io.tmpdir} + + 1000000 + + N + + Y + recruit_id Y N N 0 - recruit_id N - srt - 1000000 - Y 656 diff --git a/mappings/info_recruits/citizen_tables/deferment_liberation_permission/parallel/deferment_liberation_permission_flow.hpl b/mappings/info_recruits/citizen_tables/deferment_liberation_permission/parallel/deferment_liberation_permission_flow.hpl index b03215a..f5c83d4 100644 --- a/mappings/info_recruits/citizen_tables/deferment_liberation_permission/parallel/deferment_liberation_permission_flow.hpl +++ b/mappings/info_recruits/citizen_tables/deferment_liberation_permission/parallel/deferment_liberation_permission_flow.hpl @@ -77,11 +77,6 @@ Table output - Block until transforms finish - Y - - - Block until transforms finish Filter rows Y @@ -106,28 +101,6 @@ 496 - - Block until transforms finish - BlockUntilTransformsFinish - - Y - - 1 - - none - - - - - Update - - - - - 1152 - 320 - - Change job status on error ExecSql @@ -309,7 +282,6 @@ VALUES (DEFAULT, '${JOB_NAME}', 'PROCESSING', DEFAULT, null, '${IDM_ID}'); ervu_person_registry N - WITH part_recruits AS ( SELECT @@ -470,21 +442,23 @@ JOIN p_recruits_deferment d ON r.id = d.recruit_id none - N ${java.io.tmpdir} + + 1000000 + + N + + Y + recruit_id Y N N 0 - recruit_id N - srt - 1000000 - Y 688 diff --git a/mappings/info_recruits/citizen_tables/deferment_liberation_permission/parallel/deferment_liberation_permission_flow_delta.hpl b/mappings/info_recruits/citizen_tables/deferment_liberation_permission/parallel/deferment_liberation_permission_flow_delta.hpl index 3fc9c45..e5e3f10 100644 --- a/mappings/info_recruits/citizen_tables/deferment_liberation_permission/parallel/deferment_liberation_permission_flow_delta.hpl +++ b/mappings/info_recruits/citizen_tables/deferment_liberation_permission/parallel/deferment_liberation_permission_flow_delta.hpl @@ -77,11 +77,6 @@ Insert / update - Block until transforms finish - Y - - - Block until transforms finish Filter rows Y @@ -106,28 +101,6 @@ 528 - - Block until transforms finish - BlockUntilTransformsFinish - - Y - - 1 - - none - - - - - Update - - - - - 1248 - 352 - - Change job status on error ExecSql @@ -386,7 +359,6 @@ and recruitment_id = '${IDM_ID}'; ervu_person_registry N - WITH part_recruits AS ( SELECT @@ -483,21 +455,23 @@ JOIN p_recruits_deferment d ON r.id = d.recruit_id none - N ${java.io.tmpdir} + + 1000000 + + N + + Y + recruit_id Y N N 0 - recruit_id N - srt - 1000000 - Y 752 diff --git a/mappings/info_recruits/citizen_tables/deferment_liberation_permission/parallel/deferment_liberation_permission_flow_repeat.hpl b/mappings/info_recruits/citizen_tables/deferment_liberation_permission/parallel/deferment_liberation_permission_flow_repeat.hpl index 3a6c89f..4e2120e 100644 --- a/mappings/info_recruits/citizen_tables/deferment_liberation_permission/parallel/deferment_liberation_permission_flow_repeat.hpl +++ b/mappings/info_recruits/citizen_tables/deferment_liberation_permission/parallel/deferment_liberation_permission_flow_repeat.hpl @@ -77,11 +77,6 @@ Insert / update - Block until transforms finish - Y - - - Block until transforms finish Filter rows Y @@ -106,28 +101,6 @@ 400 - - Block until transforms finish - BlockUntilTransformsFinish - - Y - - 1 - - none - - - - - Update - - - - - 1248 - 208 - - Change job status on error ExecSql @@ -496,21 +469,23 @@ JOIN p_recruits_deferment d ON r.id = d.recruit_id none - N ${java.io.tmpdir} + + 1000000 + + N + + Y + recruit_id Y N N 0 - recruit_id N - srt - 1000000 - Y 704 diff --git a/mappings/info_recruits/citizen_tables/property/parallel/property_flow.hpl b/mappings/info_recruits/citizen_tables/property/parallel/property_flow.hpl index 3023a31..b427e70 100644 --- a/mappings/info_recruits/citizen_tables/property/parallel/property_flow.hpl +++ b/mappings/info_recruits/citizen_tables/property/parallel/property_flow.hpl @@ -70,18 +70,13 @@ Update Y - - Table output - Block until transforms finish - Y - Identify last row in a stream Detect empty stream Y - Block until transforms finish + Table output Filter rows Y @@ -106,28 +101,6 @@ 528 - - Block until transforms finish - BlockUntilTransformsFinish - - Y - - 1 - - none - - - - - Update - - - - - 1200 - 320 - - Change job status on error ExecSql @@ -655,21 +628,23 @@ from all_data none - N ${java.io.tmpdir} + + 1000000 + + N + + Y + recruit_id Y N N 0 - recruit_id N - srt - 1000000 - Y 688 diff --git a/mappings/info_recruits/citizen_tables/property/parallel/property_flow_delta.hpl b/mappings/info_recruits/citizen_tables/property/parallel/property_flow_delta.hpl index 6242a83..a2cbb74 100644 --- a/mappings/info_recruits/citizen_tables/property/parallel/property_flow_delta.hpl +++ b/mappings/info_recruits/citizen_tables/property/parallel/property_flow_delta.hpl @@ -65,16 +65,6 @@ Change job status on error Y - - Insert / update - Block until transforms finish - Y - - - Block until transforms finish - Filter rows - Y - sort_by_recruit_id Update @@ -85,6 +75,11 @@ Change job status on error Y + + Insert / update + Filter rows + Y + Abort @@ -106,28 +101,6 @@ 512 - - Block until transforms finish - BlockUntilTransformsFinish - - Y - - 1 - - none - - - - - Update - - - - - 1312 - 352 - - Change job status on error ExecSql @@ -416,7 +389,6 @@ and recruitment_id = '${IDM_ID}'; ervu-dashboard N - WITH base as( SELECT @@ -677,21 +649,23 @@ FROM all_data none - N ${java.io.tmpdir} + + 1000000 + + N + + Y + recruit_id Y N N 0 - recruit_id N - srt - 1000000 - Y 768 diff --git a/mappings/info_recruits/citizen_tables/property/parallel/property_flow_repeat.hpl b/mappings/info_recruits/citizen_tables/property/parallel/property_flow_repeat.hpl index b6e6a19..e51cc67 100644 --- a/mappings/info_recruits/citizen_tables/property/parallel/property_flow_repeat.hpl +++ b/mappings/info_recruits/citizen_tables/property/parallel/property_flow_repeat.hpl @@ -77,11 +77,6 @@ Insert / update - Block until transforms finish - Y - - - Block until transforms finish Filter rows Y @@ -106,28 +101,6 @@ 688 - - Block until transforms finish - BlockUntilTransformsFinish - - Y - - 1 - - none - - - - - Update - - - - - 1472 - 496 - - Change job status on error ExecSql @@ -431,7 +404,6 @@ DO UPDATE SET ervu-dashboard N - WITH base as( SELECT @@ -692,21 +664,23 @@ from all_data none - N ${java.io.tmpdir} + + 1000000 + + N + + Y + recruit_id Y N N 0 - recruit_id N - srt - 1000000 - Y 768 diff --git a/mappings/info_recruits/citizen_tables/recruit_archive/parallel/recruit_archive_flow.hpl b/mappings/info_recruits/citizen_tables/recruit_archive/parallel/recruit_archive_flow.hpl index f37e40e..cf911d8 100644 --- a/mappings/info_recruits/citizen_tables/recruit_archive/parallel/recruit_archive_flow.hpl +++ b/mappings/info_recruits/citizen_tables/recruit_archive/parallel/recruit_archive_flow.hpl @@ -65,16 +65,6 @@ Detect empty stream Y - - Table output - Block until transforms finish - Y - - - Block until transforms finish - Filter rows - Y - Identify last row in a stream sort_by_recruit_id @@ -85,6 +75,11 @@ Update Y + + Table output + Filter rows + Y + Abort @@ -106,28 +101,6 @@ 480 - - Block until transforms finish - BlockUntilTransformsFinish - - Y - - 1 - - none - - - - - Update - - - - - 1168 - 320 - - Change job status on error ExecSql @@ -309,7 +282,6 @@ VALUES (DEFAULT, '${JOB_NAME}', 'PROCESSING', DEFAULT, null, '${IDM_ID}'); ervu_person_archive N - SELECT id, recruit_id, @@ -441,21 +413,23 @@ WHERE '${IDM_ID}' != '' -- Проверка на пустую строку none - N ${java.io.tmpdir} + + 1000000 + + N + + Y + recruit_id Y N N 0 - recruit_id N - srt - 1000000 - Y 720 diff --git a/mappings/info_recruits/citizen_tables/recruit_archive/parallel/recruit_archive_flow_delta.hpl b/mappings/info_recruits/citizen_tables/recruit_archive/parallel/recruit_archive_flow_delta.hpl index af151f0..dd449de 100644 --- a/mappings/info_recruits/citizen_tables/recruit_archive/parallel/recruit_archive_flow_delta.hpl +++ b/mappings/info_recruits/citizen_tables/recruit_archive/parallel/recruit_archive_flow_delta.hpl @@ -60,16 +60,6 @@ Detect empty stream Y - - Insert / update - Block until transforms finish - Y - - - Block until transforms finish - Filter rows - Y - Identify last row in a stream sort_by_recruit_id @@ -85,6 +75,11 @@ Change job status on error Y + + Insert / update + Filter rows + Y + Abort @@ -106,28 +101,6 @@ 496 - - Block until transforms finish - BlockUntilTransformsFinish - - Y - - 1 - - none - - - - - Update - - - - - 1200 - 352 - - Change job status on error ExecSql @@ -376,7 +349,6 @@ and recruitment_id = '${IDM_ID}'; ervu_person_archive N - SELECT id, recruit_id, @@ -451,21 +423,23 @@ WHERE '${IDM_ID}' != '' -- Проверка на пустую строку none - N ${java.io.tmpdir} + + 1000000 + + N + + Y + recruit_id Y N N 0 - recruit_id N - srt - 1000000 - Y 704 diff --git a/mappings/info_recruits/citizen_tables/recruit_archive/parallel/recruit_archive_flow_repeat.hpl b/mappings/info_recruits/citizen_tables/recruit_archive/parallel/recruit_archive_flow_repeat.hpl index fb38c85..c0e19db 100644 --- a/mappings/info_recruits/citizen_tables/recruit_archive/parallel/recruit_archive_flow_repeat.hpl +++ b/mappings/info_recruits/citizen_tables/recruit_archive/parallel/recruit_archive_flow_repeat.hpl @@ -65,16 +65,6 @@ Detect empty stream Y - - Insert / update - Block until transforms finish - Y - - - Block until transforms finish - Filter rows - Y - Identify last row in a stream sort_by_recruit_id @@ -85,6 +75,11 @@ Update Y + + Insert / update + Filter rows + Y + Abort @@ -106,28 +101,6 @@ 352 - - Block until transforms finish - BlockUntilTransformsFinish - - Y - - 1 - - none - - - - - Update - - - - - 976 - 208 - - Change job status on error ExecSql @@ -391,7 +364,6 @@ DO UPDATE SET ervu_person_archive N - SELECT id, recruit_id, @@ -466,21 +438,23 @@ WHERE '${IDM_ID}' != '' -- Проверка на пустую строку none - N ${java.io.tmpdir} + + 1000000 + + N + + Y + recruit_id Y N N 0 - recruit_id N - srt - 1000000 - Y 528 diff --git a/mappings/info_recruits/citizen_tables/subpoena/parallel/subpoena_flow.hpl b/mappings/info_recruits/citizen_tables/subpoena/parallel/subpoena_flow.hpl index 09438c0..3f9959c 100644 --- a/mappings/info_recruits/citizen_tables/subpoena/parallel/subpoena_flow.hpl +++ b/mappings/info_recruits/citizen_tables/subpoena/parallel/subpoena_flow.hpl @@ -77,11 +77,6 @@ Table output - Block until transforms finish - Y - - - Block until transforms finish Filter rows Y @@ -106,28 +101,6 @@ 512 - - Block until transforms finish - BlockUntilTransformsFinish - - Y - - 1 - - none - - - - - Update - - - - - 1184 - 320 - - Change job status on error ExecSql @@ -309,7 +282,6 @@ VALUES (DEFAULT, '${JOB_NAME}', 'PROCESSING', DEFAULT, null, '${IDM_ID}'); postgres.subpoena N - SELECT s.id, --id повестки CASE @@ -514,21 +486,23 @@ WHERE none - N ${java.io.tmpdir} + + 1000000 + + N + + Y + recruit_id Y N N 0 - recruit_id N - srt - 1000000 - Y 704 diff --git a/mappings/info_recruits/citizen_tables/subpoena/parallel/subpoena_flow_delta.hpl b/mappings/info_recruits/citizen_tables/subpoena/parallel/subpoena_flow_delta.hpl index 81b0267..63584ae 100644 --- a/mappings/info_recruits/citizen_tables/subpoena/parallel/subpoena_flow_delta.hpl +++ b/mappings/info_recruits/citizen_tables/subpoena/parallel/subpoena_flow_delta.hpl @@ -77,11 +77,6 @@ Insert / update - Block until transforms finish - Y - - - Block until transforms finish Filter rows Y @@ -106,28 +101,6 @@ 880 - - Block until transforms finish - BlockUntilTransformsFinish - - Y - - 1 - - none - - - - - Update - - - - - 1312 - 704 - - Change job status on error ExecSql @@ -416,7 +389,6 @@ and recruitment_id = '${IDM_ID}'; postgres.subpoena N - SELECT s.id, --id повестки CASE @@ -525,21 +497,23 @@ WHERE none - N ${java.io.tmpdir} + + 1000000 + + N + + Y + recruit_id Y N N 0 - recruit_id N - srt - 1000000 - Y 848 diff --git a/mappings/info_recruits/citizen_tables/subpoena/parallel/subpoena_flow_repeat.hpl b/mappings/info_recruits/citizen_tables/subpoena/parallel/subpoena_flow_repeat.hpl index 9692d38..fd39d53 100644 --- a/mappings/info_recruits/citizen_tables/subpoena/parallel/subpoena_flow_repeat.hpl +++ b/mappings/info_recruits/citizen_tables/subpoena/parallel/subpoena_flow_repeat.hpl @@ -77,11 +77,6 @@ Insert / update - Block until transforms finish - Y - - - Block until transforms finish Filter rows Y @@ -106,28 +101,6 @@ 752 - - Block until transforms finish - BlockUntilTransformsFinish - - Y - - 1 - - none - - - - - Update - - - - - 1296 - 560 - - Change job status on error ExecSql @@ -431,7 +404,6 @@ DO UPDATE SET postgres.subpoena N - SELECT s.id, --id повестки CASE @@ -540,21 +512,23 @@ WHERE none - N ${java.io.tmpdir} + + 1000000 + + N + + Y + recruit_id Y N N 0 - recruit_id N - srt - 1000000 - Y 848