From 161d8811c9f1d6dd846dc15430c80e86f5c1a794 Mon Sep 17 00:00:00 2001 From: Grigory Pomadchin Date: Thu, 23 Mar 2017 12:45:12 +0300 Subject: [PATCH] ensureKeyspaceExists in CassandraRDDWriter Signed-off-by: Grigory Pomadchin --- .../geotrellis/spark/io/cassandra/CassandraRDDWriter.scala | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/cassandra/src/main/scala/geotrellis/spark/io/cassandra/CassandraRDDWriter.scala b/cassandra/src/main/scala/geotrellis/spark/io/cassandra/CassandraRDDWriter.scala index 4d2d7a2404..b0b42f3ffa 100644 --- a/cassandra/src/main/scala/geotrellis/spark/io/cassandra/CassandraRDDWriter.scala +++ b/cassandra/src/main/scala/geotrellis/spark/io/cassandra/CassandraRDDWriter.scala @@ -49,10 +49,10 @@ object CassandraRDDWriter { implicit val sc = raster.sparkContext val codec = KeyValueRecordCodec[K, V] - val schema = codec.schema - instance.withSessionDo { - _.execute( + instance.withSessionDo { session => + instance.ensureKeyspaceExists(keyspace, session) + session.execute( SchemaBuilder.createTable(keyspace, table).ifNotExists() .addPartitionKey("key", bigint) .addClusteringColumn("name", text)