nats-connector-spark-scala (homepage)

A Scala based Spark Publish/Subscribe NATS Connector

@Logimethods / (0)


That library provides a Scala-based Apache Spark (a fast and general engine for large-scale data processing) integration with the NATS messaging system (a highly performant cloud-native messaging system) as well as NATS Streaming (a data streaming system powered by NATS).

That library provided a wrapper over the (Java-based) NATS / Spark Connectors to facilitate its usage on Scala (which is the de facto language of Spark).

Tags

  • 1|streaming
  • 1|scala
  • 1|nats

How to

Include this package in your Spark Applications using:

spark-shell, pyspark, or spark-submit

> $SPARK_HOME/bin/spark-shell --packages com.logimethods:nats-connector-spark-scala_2.11:1.0.0

sbt

In your sbt build file, add:

libraryDependencies += "com.logimethods" % "nats-connector-spark-scala_2.11" % "1.0.0"

Maven

In your pom.xml, add: 
<dependencies>
  <!-- list of dependencies -->
  <dependency>
    <groupId>com.logimethods</groupId>
    <artifactId>nats-connector-spark-scala_2.11</artifactId>
    <version>1.0.0</version>
  </dependency>
</dependencies>

Releases

Version: 1.0.0 ( acbd47 | zip | jar ) / Date: 2019-06-10 / License: MIT / Scala version: 2.11