A Catalog Lookup Service implementation that provides ids for products.
Lookup Handler to serve requests.
This class represents a purchase made by a customer.
This implements a simple purchase history application via a scheduled MapReduce Workflow -- see package-info for more details.
This is a simple Flow that consumes purchase events from a Stream and stores Purchase objects in datastore.
This class represents the purchase history for one customer.
MapReduce that reads purchases from the purchases DataSet and creates a purchase history for every user
Reducer class to aggregate all purchases per user
Mapper class to emit user and corresponding purchase information
Service for retrieving a customer’s purchase history.
This stores purchase histories in an embedded object store.
Implements a simple Workflow with one Workflow action to run the PurchaseHistoryBuilder MapReduce.
Store the incoming Purchase objects in the purchases dataset.
This Flowlet reads events from a Stream and parses them as sentences of the form
This class represents the profile information for the user
Handler for user profile requests
Note: Because by default the PurchaseHistoryWorkflow process doesn't run until 4:00 A.M., you'll have to wait until the next day (or manually or programmatically execute the PurchaseHistoryBuilder.) after entering the first customers' purchases or the PurchaseQuery will return a "not found" error.
Copyright © 2018 Cask Data, Inc.. All rights reserved.