You can find the actual code for the previous example here (under Example
2):
-
https://github.com/ging/fiware-cosmos-orion-flink-connector-examples#example-2-complete-orion-scenario-with-docker-compose
Salva
On 2023/06/09 07:28:17 Salva Alcántara wrote:
> I want to implement a job which feeds s
A related example I've found:
https://ngsi-ld-tutorials.readthedocs.io/en/latest/big-data-flink.html#feedback-loop-persisting-context-data
Salva
On 2023/06/09 07:28:17 Salva Alcántara wrote:
> I want to implement a job which feeds sink messages back into a source,
> effectively introducing a cyc
Just in case it helps...
Attached please find the overall scheme depicted.
Salva
On 2023/06/09 07:28:17 Salva Alcántara wrote:
> I want to implement a job which feeds sink messages back into a source,
> effectively introducing a cycle. For simplicity, consider the following
> kafka-based enrichm
I want to implement a job which feeds sink messages back into a source,
effectively introducing a cycle. For simplicity, consider the following
kafka-based enrichment scenario:
- A source for the "facts"
- A source for the "dimensions"
- A sink for the "dimensions" (this creates a loop)
- A co-pro
