This is a Spark connector for the FIWARE Orion Context Broker. It has two parts:
-
OrionReceiver
: Source for receiving NGSIv2 events in the shape of HTTP messages from subscriptions. -
NGSILDReceiver
: Source for receiving NGSI-LD events from subscriptions via HTTP. -
OrionSink
: Sink for writing back to the Context Broker.
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.spark.connector-1.2.2.jar -DgroupId=org.fiware.cosmos -DartifactId=orion.spark.connector -Dversion=1.2.2 -Dpackaging=jar
Add it to your pom.xml
file inside the dependencies section.
<dependency>
<groupId>org.fiware.cosmos</groupId>
<artifactId>orion.spark.connector</artifactId>
<version>1.2.2</version>
</dependency>