2

✓

✓

✓

✓

✓

✓

✓

Op1

Hadoop (YARN + HDFS)

Real-time Analytics &

Visualizations

Op3

Op2

Op4

44

Solutions for Business

Ingestion & Data Prep ETL Pipelines

Tools Real-Time Data VisualizationManagement & MonitoringGUI Application Assembly

Application Templates

Apex-Malhar Operator Library

Big Data Infrastructure Hadoop 2.x – YARN + HDFS – On Prem & Cloud

Core

High-level APITransformation ML & Score SQL Analytics

FileSync

Dev Framework Batch Support

Apache Apex Core

Kafka-to-HDFS JDBC-to-HDFS HDFS-to-HDFS S3-to-HDFS

6

…

7

8

public AdEvent(String publisherId,String campaignId

String location, double cost, double revenue, long impressions, long clicks, long time….) { this.publisherId = publisherId; this.campaignId = campaignId; this.location = location; this.cost = cost; this.revenue = revenue; this.impressions = impressions; this.clicks = clicks; this.time = time; …. } /* Getters and setters go here */

9

dimensions.setUnifier(new DimensionsComputationUnifierImpl<InputEvent, Aggregate>());

10

11

12

14