Skip to main content

End-to-End Journeys

Journey 1: CRM Data Onboarding​

Actor: Data Engineer

  1. Open Visual Canvas → Create "CRM Master Data" pipeline
  2. Add Source (Kafka) → DQ Block → Identity Block → SID Mapper → Profile Writer
  3. Validate → Test with 100 records → Submit for approval
  4. Deployed → 5M records backfilled

Outcome: 5M profiles with SID-compliant structure.

Journey 2: Segment Creation​

Actors: Data Engineer + Business Analyst

WHERE account.value_tier IN ('PLATINUM', 'GOLD')
  AND scores.churn_probability_30d > 50
  AND account.status = 'ACTIVE'
  AND consent.marketing = 'GRANTED'

Preview: 12,453 members → STREAMING refresh → Approved → Available in AI CEP.

Journey 3: DSAR Processing​

Actor: Privacy Officer

Request (ahmed@email.com) → Identity resolution → DTX_ID D001 → Compile all data → Officer reviews → JSON export → Delivered within 72 hours, fully audited.

Journey 4: CDR Processing (Automated)​

CDR on Kafka → Schema Validator → Format Normalizer → DTX_ID Resolver → Consent Checker → Event Writer → Trait Calculator (voice_minutes: 178→183) → Profile Writer → Segment Evaluator → Hot cache updated.

End-to-end in <500ms.