This is a Flink connector for the FIWARE Orion Context Broker. It has two parts:

  • OrionSource: Source for receiving NGSI v2 events from subscriptions via HTTP.

  • OrionSink: Sink for writing the processed data in Orion.

In order to install the connector, first you must download the JAR from the latest release.

In your project directory run:

mvn install:install-file -Dfile=$(PATH_DOWNLOAD)/orion.flink.connector-1.1.0.jar -DgroupId=org.fiware.cosmos -DartifactId=orion.flink.connector -Dversion=1.1.0 -Dpackaging=jar

Add it to your pom.xml file inside the dependencies section.

<dependency>
    <groupId>org.fiware.cosmos</groupId>
    <artifactId>orion.flink.connector</artifactId>
    <version>1.1.0</version>
</dependency>