(data, scope)
| 148735 | }, userEncode); |
| 148736 | } |
| 148737 | function parseData(data, scope) { |
| 148738 | const transforms = []; |
| 148739 | if (data.transform) data.transform.forEach((tx)=>{ |
| 148740 | transforms.push(parseTransform(tx, scope)); |
| 148741 | }); |
| 148742 | if (data.on) data.on.forEach((on)=>{ |
| 148743 | parseTrigger(on, scope, data.name); |
| 148744 | }); |
| 148745 | scope.addDataPipeline(data.name, analyze(data, scope, transforms)); |
| 148746 | } |
| 148747 | /** |
| 148748 | * Analyze a data pipeline, add needed operators. |
| 148749 | */ function analyze(data, scope, ops) { |
no test coverage detected