04.2_​ELT_​Usage

0 ×

- Various data are collected, e.g., session start, duration, # clicks, etc., as well as the session satisfaction score (optional)
- The company calculates averaged statistics for each customer, e.g., total # visits, average satisfaction, etc., and updates the "statistics" table in different locations
- Session satisfaction score column has missing values which need to be imputed, e.g., with machine learning predictions.

We access the usage data from Hive and personal data (anonymized & updated in sessions 1 & 2) and contracts data from a database. We perform in-database processing, read the data into Spark, enrich the usage data with the personal and contract data to predict missing values better, aggregate usage data on Spark, and save the aggregated data.

Here, we additionally export the final status of the workflow. In the case some processes fail, we notify responsible people via an automated email.

Nodes

• Component Input3 ×
• Component Output3 ×
• DB Table Selector (Labs)3 ×
• Spark SQL Query3 ×
• Variable Creator3 ×
• Show all 33 nodes

Extensions

• FeatureKNIME Base nodes
• FeatureKNIME Database
• FeatureKNIME Extension for Apache Spark
• FeatureKNIME Extension for Apache Spark (legacy)
• FeatureKNIME Personal Productivity Tools

Links

• No links available