...
Purchase events are injected into the purchases
Stream. The sink
Flowlet reads events from the Stream and writes them into the PurchasesDataset
. The PurchasesDataset
has Hive integration enabled and can be queried, like any regular Database table, from a BI tool by using the CDAP JDBC Driver.
Implementation
The first step is to get our application structure set up. We will use a standard Maven project structure for all of the source code files:
...