November 2017
Beginner to intermediate
290 pages
7h 34m
English
The low-level DAG API is defined by the Apex engine. Any application that runs on Apex, irrespective of the original specification format, will be translated into this API. It is sometimes also referred to as compositional, as it represents the logical DAG, which will be translated into a physical plan and mapped to the execution layer by the Apex runtime.
The following is the Word Count example application, briefly introduced in the Stream Processing section earlier written with the DAG API:
LineReader lineReader = dag.addOperator("input", new LineReader()); Parser parser = dag.addOperator("parser", new Parser()); UniqueCounter counter = dag.addOperator("counter", new UniqueCounter()); ConsoleOutputOperator cons = dag.addOperator("console", ...Read now
Unlock full access