| ID | product.processing.stream_pipeline |
|---|---|
| Description | Stateful Flink / Spark Streaming jobs. |
| Key | stream_pipeline |
| Type | microservice:service |
| Team | Data Engineering |
| Owner | eng@dataplatform.example |
| Status | active |
| Technologies | Spark, dbt, Airflow |
| Attributes | engine: Flink, mode: streaming, state: keyed |
| Tags |
Stateful Flink / Spark Streaming jobs.
Container
Part of the Processing system. Components inside this container link only to siblings — cross-container integration happens at the service boundary.
Could not build diagram for model "example-data-processing".
1 incoming link · 1 workflow
| Source object | Label | Link type | Relation | Raw id | Required | Description | |
|---|---|---|---|---|---|---|---|
| feeds | — | links | product.processing.stream_pipeline | — | — |
| Workflow | Model | Participant id | Participant label |
|---|---|---|---|
| Real-time event ingestion streaming.realtime-event | example-data-processing | product.processing.stream_pipeline | Stream pipeline |