cassandra-sink_2.2.1

License	Apache License, Version 2.0
Categories	Cassandra Data Databases
GroupId	com.fhuertas
ArtifactId	cassandra-sink_2-2-1_2.11
Last Version	1.0.0
Release Date	Mar 30, 2018
Type	jar
Description	cassandra-sink_2.2.1 cassandra-sink_2.2.1
Project URL	https://github.com/fhuertas/cassandra-sink-spark-structured-streaming
Project Organization	com.fhuertas
Source Code Management	https://github.com/fhuertas/cassandra-sink-spark-structured-streaming.git

Download cassandra-sink_2-2-1_2.11

Filename	Size
cassandra-sink_2-2-1_2.11-1.0.0.pom
cassandra-sink_2-2-1_2.11-1.0.0.jar	4 KB
cassandra-sink_2-2-1_2.11-1.0.0-sources.jar	2 KB
cassandra-sink_2-2-1_2.11-1.0.0-javadoc.jar	354 KB

How to add to project

Apache Maven

<!-- https://jarcasting.com/artifacts/com.fhuertas/cassandra-sink_2-2-1_2.11/ -->
<dependency>
    <groupId>com.fhuertas</groupId>
    <artifactId>cassandra-sink_2-2-1_2.11</artifactId>
    <version>1.0.0</version>
</dependency>

Gradle Groovy

// https://jarcasting.com/artifacts/com.fhuertas/cassandra-sink_2-2-1_2.11/
implementation 'com.fhuertas:cassandra-sink_2-2-1_2.11:1.0.0'

Gradle Kotlin

// https://jarcasting.com/artifacts/com.fhuertas/cassandra-sink_2-2-1_2.11/
implementation ("com.fhuertas:cassandra-sink_2-2-1_2.11:1.0.0")

Apache Buildr

'com.fhuertas:cassandra-sink_2-2-1_2.11:jar:1.0.0'

Apache Ivy

<dependency org="com.fhuertas" name="cassandra-sink_2-2-1_2.11" rev="1.0.0">
  <artifact name="cassandra-sink_2-2-1_2.11" type="jar" />
</dependency>

Groovy Grape

@Grapes(
@Grab(group='com.fhuertas', module='cassandra-sink_2-2-1_2.11', version='1.0.0')
)

Scala SBT

libraryDependencies += "com.fhuertas" % "cassandra-sink_2-2-1_2.11" % "1.0.0"

Leiningen

[com.fhuertas/cassandra-sink_2-2-1_2.11 "1.0.0"]

Dependencies

compile (2)

Group / Artifact	Type	Version
org.scala-lang : scala-library	jar	2.11.12
com.datastax.spark : spark-cassandra-connector_2.11	jar	2.0.7

provided (3)

Group / Artifact	Type	Version
org.apache.spark : spark-core_2.11	jar	2.2.1
org.apache.spark : spark-sql_2.11	jar	2.2.1
org.apache.spark : spark-streaming_2.11	jar	2.2.1

test (3)

Group / Artifact	Type	Version
org.scalatest : scalatest_2.11	jar	3.0.4
com.typesafe : config	jar	1.3.2
org.scalacheck : scalacheck_2.11	jar	1.13.5

Project Modules

There are no modules declared in this project.

sink-cassandra-structured-streaming

Unoffical sink for cassandra for spark structured streaming. This connector only support append mode

Usage

First, you should include the dependency in your code.

libraryDependencies += "com.fhuertas" %% "cassandra_sink_2.2.0" % "1.0.0"
// Or 
libraryDependencies += "com.fhuertas" %% "cassandra_sink_2.2.1" % "1.0.0"

This connector is used like others structured streaming connectors. This is a code example that how to use the connectors

dataframe.writeStream.options(...).start()

You can see an example in the test: CassandraSinkTest

Versions

Version
1.0.0 Mar 30, 2018