Ingestion
Connect a source and stream data into the lakehouse. States reflect this deployment.
Object storage CHECKING
MinIO / S3 bucket notifications — objects dropped in intake process automatically.
Checking…
Document upload READY
Images, PDFs, archives → OCR pipeline (single or batch).
Upload on Documents → Ingest; batches poll to done.
Flow ingress CHECKING
Upload + run a Flow (PINGMapper, payments).
Checking…
Database CDC CHECKING
Change-data-capture from Postgres/MySQL.
Checking…
Kafka / events READY
Stream CloudEvents 1.0 into governed tables.
POST /api/v1/events/ingest routes events to tables by type — see Developers.