Skip to content

Commit e2ae99e

Browse files
authored
Add 'ifNotExists' option to Cassandra output settings
ifNotExists allows user to conditionally write to Keyspaces.
1 parent 6f13741 commit e2ae99e

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

scala/datastax-v4/aws-glue/import-from-s3/import-sample.scala

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,9 @@ object GlueApp {
4949
("spark.cassandra.output.concurrent.writes", "1"),
5050
("spark.cassandra.output.batch.grouping.key", "none"),
5151
("spark.cassandra.output.batch.size.rows", "1"),
52-
("spark.cassandra.output.ignoreNulls", "true")
52+
("spark.cassandra.output.ignoreNulls", "true"),
53+
("spark.cassandra.output.ifNotExists", "false")
54+
5355
))
5456

5557
val spark: SparkContext = new SparkContext(conf)

0 commit comments

Comments
 (0)