DEFINE JOB PRODUCT_SOURCE_LOAD DESCRIPTION 'LOAD PRODUCT DEFINITION TABLE' ( DEFINE OPERATOR STREAM_OPERATOR() DESCRIPTION 'CONTINUOUS OPERATOR FOR TERADATA WAREHOUSE BUILDER' TYPE STREAM SCHEMA * ATTRIBUTES ( VARCHAR AtomicUpsert, INTEGER ErrorLimit, INTEGER Buffers, INTEGER TenacityHours, INTEGER TenacitySleep, INTEGER MaxSessions, INTEGER MinSessions, INTEGER Pack, INTEGER PackMaximum, VARCHAR Robust, VARCHAR TdpId = 'yourtdpid', VARCHAR UserName = 'yourpassword', VARCHAR UserPassword = 'yourpassword', VARCHAR AccountID, VARCHAR ErrorTable = 'abhi_e1', VARCHAR LogTable = 'abhi_log', VARCHAR PrivateLogName = 'abhiC1', VARCHAR MacroDatabase, VARCHAR WorkingDatabase ); DEFINE SCHEMA PRODUCT_SOURCE_SCHEMA DESCRIPTION 'PRODUCT INFORMATION SCHEMA' ( Associate_Id INTEGER, Associate_Name CHAR(25), Salary FLOAT, DOJ INTDATE, Designation VARCHAR(25), Loan_Amount DECIMAL(5,2), Martial_Status CHAR(1), No_Of_Dependents BYTEINT ); DEFINE OPERATOR EXPORT_OPERATOR () DESCRIPTION 'Export Operator for Terabuilder' TYPE EXPORT SCHEMA PRODUCT_SOURCE_SCHEMA ATTRIBUTES ( VARCHAR PrivateLogName = 'abhiP1', INTEGER Blocksize = 64260, INTEGER TenacityHours = 1, INTEGER TenacitySleep = 1, INTEGER MaxSessions = 4, INTEGER MinSessions = 1, VARCHAR TdpId = 'yourtdpid', VARCHAR UserName = 'yourpassword', VARCHAR UserPassword = 'yourpassword', VARCHAR DateForm, VARCHAR AccountID, INTEGER Outlimit, VARCHAR WorkingDatabase, VARCHAR SelectStmt = 'select * from abhi_src; ' ); DEFINE OPERATOR DDL_OPERATOR() DESCRIPTION 'TERADATA DDL OPERATOR' TYPE DDL ATTRIBUTES ( VARCHAR TdpId = 'yourtdpid', VARCHAR UserName = 'yourpassword', VARCHAR UserPassword = 'yourpassword', VARCHAR PrivateLogName = 'abhiS1', VARCHAR ARRAY ErrorList = ['3706','3803','3807'] ); STEP STEP_01 ( APPLY (' DROP TABLE abhi_e1; '), (' DROP TABLE abhi_e2; '), (' DROP TABLE abhi_wt; '), (' DROP TABLE abhi_log; '), (' DROP TABLE abhi; '), (' DROP TABLE abhi_src; '), (' CT abhi ( Associate_Id INTEGER, Associate_Name CHAR(25), Salary FLOAT, DOJ DATE, Designation VARCHAR(25), Loan_Amount DECIMAL(5,2), Martial_Status CHAR(1), No_Of_Dependents BYTEINT ); '), (' CT abhi_src ( Associate_Id INTEGER, Associate_Name CHAR(25), Salary FLOAT, DOJ DATE, Designation VARCHAR(25), Loan_Amount DECIMAL(5,2), Martial_Status CHAR(1), No_Of_Dependents BYTEINT ); '), (' Ins abhi_src( 1,''Hard_Work_always_Pays_001'',10.12,''99-03-20'', ''Dedication_Plus_Sincer001'',110.12,''a'',1); Ins abhi_src( 2,''Hard_Work_always_Pays_002'',11.12,''99-03-21'', ''Dedication_Plus_Sincer002'',111.12,''b'',2); Ins abhi_src( 3,''Hard_Work_always_Pays_003'',12.12,''99-03-22'', ''Dedication_Plus_Sincer003'',112.12,''c'',3); Ins abhi_src( 4,''Hard_Work_always_Pays_004'',13.12,''99-03-23'', ''Dedication_Plus_Sincer004'',113.12,''d'',4); Ins abhi_src( 5,''Hard_Work_always_Pays_005'',14.12,''99-03-24'', ''Dedication_Plus_Sincer005'',114.12,''e'',5); Ins abhi_src( 6,''Hard_Work_always_Pays_006'',15.12,''99-03-25'', ''Dedication_Plus_Sincer006'',115.12,''f'',6); Ins abhi_src( 7,''Hard_Work_always_Pays_007'',16.12,''99-03-26'', ''Dedication_Plus_Sincer007'',116.12,''g'',7); Ins abhi_src( 8,''Hard_Work_always_Pays_008'',17.12,''99-03-27'', ''Dedication_Plus_Sincer008'',117.12,''h'',8); Ins abhi_src( 9,''Hard_Work_always_Pays_009'',18.12,''99-03-28'', ''Dedication_Plus_Sincer009'',118.12,''i'',9); Ins abhi_src(10,''Hard_Work_always_Pays_010'',19.12,''99-03-29'', ''Dedication_Plus_Sincer010'',119.12,''j'',10); Ins abhi_src(11,''Hard_Work_always_Pays_011'',20.12,''99-03-30'', ''Dedication_Plus_Sincer011'',120.12,''k'',11); Ins abhi_src(12,''Hard_Work_always_Pays_012'',21.12,''99-03-19'', ''Dedication_Plus_Sincer012'',121.12,''l'',12); Ins abhi_src(13,''Hard_Work_always_Pays_013'',22.12,''99-03-18'', ''Dedication_Plus_Sincer013'',122.12,''m'',13); Ins abhi_src(14,''Hard_Work_always_Pays_014'',23.12,''99-03-17'', ''Dedication_Plus_Sincer014'',123.12,''n'',14); Ins abhi_src(15,''Hard_Work_always_Pays_015'',24.12,''99-03-16'', ''Dedication_Plus_Sincer015'',124.12,''o'',15); Ins abhi_src(16,''Hard_Work_always_Pays_016'',25.12,''99-03-15'', ''Dedication_Plus_Sincer016'',125.12,''p'',16); Ins abhi_src(17,''Hard_Work_always_Pays_017'',26.12,''99-03-14'', ''Dedication_Plus_Sincer017'',126.12,''q'',17); Ins abhi_src(18,''Hard_Work_always_Pays_018'',27.12,''99-03-13'', ''Dedication_Plus_Sincer018'',127.12,''r'',18); Ins abhi_src(19,''Hard_Work_always_Pays_019'',28.12,''99-03-12'', ''Dedication_Plus_Sincer019'',128.12,''s'',19); Ins abhi_src(20,''Hard_Work_always_Pays_020'',29.12,''99-03-11'', ''Dedication_Plus_Sincer020'',129.12,''t'',20); ') TO OPERATOR (DDL_OPERATOR () ); ); STEP STEP_02 ( APPLY ( 'INSERT INTO abhi ( :Associate_Id, :Associate_Name, :Salary, :DOJ, :Designation, :Loan_Amount, :Martial_Status, :No_Of_Dependents );' ) SERIALIZE ON (Loan_Amount) TO OPERATOR (STREAM_OPERATOR() ) SELECT * FROM OPERATOR ( EXPORT_OPERATOR()); ); STEP STEP_03 ( APPLY (' DROP TABLE abhi_e1; '), (' DROP TABLE abhi_e2; '), (' DROP TABLE abhi_wt; '), (' DROP TABLE abhi_log; '), (' DROP TABLE abhi; '), (' DROP TABLE abhi_src; ') TO OPERATOR (DDL_OPERATOR () ATTR ( PrivateLogName = 'abhiS2' ) ); ); );