From 6658d2f4bc6d7c9326fcc7b49e03f91ffbc64350 Mon Sep 17 00:00:00 2001 From: Russell Spitzer Date: Fri, 12 Aug 2016 09:56:16 -0700 Subject: [PATCH] CleanupMerge --- .../connector/rdd/partitioner/CassandraPartitionGenerator.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/spark-cassandra-connector/src/main/scala/com/datastax/spark/connector/rdd/partitioner/CassandraPartitionGenerator.scala b/spark-cassandra-connector/src/main/scala/com/datastax/spark/connector/rdd/partitioner/CassandraPartitionGenerator.scala index e1c129909..eed4cc146 100644 --- a/spark-cassandra-connector/src/main/scala/com/datastax/spark/connector/rdd/partitioner/CassandraPartitionGenerator.scala +++ b/spark-cassandra-connector/src/main/scala/com/datastax/spark/connector/rdd/partitioner/CassandraPartitionGenerator.scala @@ -159,7 +159,7 @@ object CassandraPartitionGenerator { conn: CassandraConnector, tableDef: TableDef, splitCount: Option[Int], - splitSize: Long): CassandraRDDPartitioner[V, T] = { + splitSize: Long): CassandraPartitionGenerator[V, T] = { val tokenFactory = getTokenFactory(conn) new CassandraPartitionGenerator(conn, tableDef, splitCount, splitSize)(tokenFactory)