...
Let’s Build It!
...
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:
...