Name	Name	Last commit message	Last commit date
parent directory ..
src	src
.gitignore	.gitignore
Dockerfile	Dockerfile
README.md	README.md
docker-compose.yml	docker-compose.yml
pom.xml	pom.xml
run.sh	run.sh

Name

Last commit message

Last commit date

Analytics Reporting

Orchestrates analytics reporting through a multi-stage Conductor workflow.

Input: reportId, dateRange, dataSources | Timeout: 60s

Pipeline

anr_collect_events
    │
anr_aggregate_data
    │
anr_compute_metrics
    │
anr_generate_report

AggregateDataWorker (anr_aggregate_data)

Reads aggregatedData. Outputs aggregatedData, totalSessions, uniqueUsers, pageViews, avgSessionDuration.

CollectEventsWorker (anr_collect_events)

Reads eventCount. Outputs eventCount, rawDataPath, sourcesProcessed, collectionTimeMs.

ComputeMetricsWorker (anr_compute_metrics)

Reads metrics. Outputs metrics, dau, wau, mau, bounceRate.

GenerateReportWorker (anr_generate_report)

Reads reportUrl. Outputs reportUrl, format, generatedAt, scheduledDelivery.

4 tests cover valid inputs, boundary values, null handling, and error paths.

mvn test

Run this example: see RUNNING.md for setup, build, and CLI instructions.