|
42 | 42 | "name": "CADSink" |
43 | 43 | } |
44 | 44 | ], |
45 | | - "script": "source(output(PreviousConversionRate as double,Country as string,DateTime1 as string,CurrentConversionRate as double),allowSchemaDrift: false,validateSchema: false) ~> USDCurrency\nsource(output(PreviousConversionRate as double,Country as string,DateTime1 as string,CurrentConversionRate as double),allowSchemaDrift: true,validateSchema: false) ~> CADSource\nUSDCurrency, CADSource union(byName: true)~> Union\nUnion derive(NewCurrencyRate = round(CurrentConversionRate*1.25)) ~> NewCurrencyColumn\nNewCurrencyColumn split(Country == 'USD',Country == 'CAD',disjoint: false) ~> ConditionalSplit1@(USD, CAD)\nConditionalSplit1@USD sink(saveMode:'overwrite' ) ~> USDSink\nConditionalSplit1@CAD sink(saveMode:'overwrite' ) ~> CADSink" |
| 45 | + "scriptLines": [ |
| 46 | + "source(output(", |
| 47 | + "PreviousConversionRate as double,", |
| 48 | + "Country as string,", |
| 49 | + "DateTime1 as string,", |
| 50 | + "CurrentConversionRate as double", |
| 51 | + "),", |
| 52 | + "allowSchemaDrift: false,", |
| 53 | + "validateSchema: false) ~> USDCurrency", |
| 54 | + "source(output(", |
| 55 | + "PreviousConversionRate as double,", |
| 56 | + "Country as string,", |
| 57 | + "DateTime1 as string,", |
| 58 | + "CurrentConversionRate as double", |
| 59 | + "),", |
| 60 | + "allowSchemaDrift: true,", |
| 61 | + "validateSchema: false) ~> CADSource", |
| 62 | + "USDCurrency, CADSource union(byName: true)~> Union", |
| 63 | + "Union derive(NewCurrencyRate = round(CurrentConversionRate*1.25)) ~> NewCurrencyColumn", |
| 64 | + "NewCurrencyColumn split(Country == 'USD',", |
| 65 | + "Country == 'CAD',disjoint: false) ~> ConditionalSplit1@(USD, CAD)", |
| 66 | + "ConditionalSplit1@USD sink(saveMode:'overwrite' ) ~> USDSink", |
| 67 | + "ConditionalSplit1@CAD sink(saveMode:'overwrite' ) ~> CADSink" |
| 68 | + ] |
46 | 69 | } |
47 | 70 | } |
48 | 71 | }, |
|
97 | 120 | "name": "CADSink" |
98 | 121 | } |
99 | 122 | ], |
100 | | - "script": "source(output(PreviousConversionRate as double,Country as string,DateTime1 as string,CurrentConversionRate as double),allowSchemaDrift: false,validateSchema: false) ~> USDCurrency\nsource(output(PreviousConversionRate as double,Country as string,DateTime1 as string,CurrentConversionRate as double),allowSchemaDrift: true,validateSchema: false) ~> CADSource\nUSDCurrency, CADSource union(byName: true)~> Union\nUnion derive(NewCurrencyRate = round(CurrentConversionRate*1.25)) ~> NewCurrencyColumn\nNewCurrencyColumn split(Country == 'USD',Country == 'CAD',disjoint: false) ~> ConditionalSplit1@(USD, CAD)\nConditionalSplit1@USD sink(saveMode:'overwrite' ) ~> USDSink\nConditionalSplit1@CAD sink(saveMode:'overwrite' ) ~> CADSink" |
| 123 | + "scriptLines": [ |
| 124 | + "source(output(", |
| 125 | + "PreviousConversionRate as double,", |
| 126 | + "Country as string,", |
| 127 | + "DateTime1 as string,", |
| 128 | + "CurrentConversionRate as double", |
| 129 | + "),", |
| 130 | + "allowSchemaDrift: false,", |
| 131 | + "validateSchema: false) ~> USDCurrency", |
| 132 | + "source(output(", |
| 133 | + "PreviousConversionRate as double,", |
| 134 | + "Country as string,", |
| 135 | + "DateTime1 as string,", |
| 136 | + "CurrentConversionRate as double", |
| 137 | + "),", |
| 138 | + "allowSchemaDrift: true,", |
| 139 | + "validateSchema: false) ~> CADSource", |
| 140 | + "USDCurrency, CADSource union(byName: true)~> Union", |
| 141 | + "Union derive(NewCurrencyRate = round(CurrentConversionRate*1.25)) ~> NewCurrencyColumn", |
| 142 | + "NewCurrencyColumn split(Country == 'USD',", |
| 143 | + "Country == 'CAD',disjoint: false) ~> ConditionalSplit1@(USD, CAD)", |
| 144 | + "ConditionalSplit1@USD sink(saveMode:'overwrite' ) ~> USDSink", |
| 145 | + "ConditionalSplit1@CAD sink(saveMode:'overwrite' ) ~> CADSink" |
| 146 | + ] |
101 | 147 | } |
102 | 148 | }, |
103 | 149 | "etag": "0a0066d4-0000-0000-0000-5b245bd20000" |
|
0 commit comments