fix move of cassandra sync api and dependencies

obermeier · Jul 28, 2016 · 4ff0cf6 · 4ff0cf6
1 parent 82e4457
commit 4ff0cf6
Show file tree

Hide file tree

Showing 4 changed files with 26 additions and 0 deletions.
diff --git a/pom.xml b/pom.xml
@@ -105,6 +105,11 @@
 				<artifactId>kryo</artifactId>
 				<version>3.0.3</version>
 			</dependency>
+			<dependency>
+				<groupId>com.google.guava</groupId>
+				<artifactId>guava</artifactId>
+				<version>16.0.1</version>
+			</dependency>
 
 			<dependency>
 				<groupId>com.datastax.cassandra</groupId>

diff --git a/scray-cassandra/pom.xml b/scray-cassandra/pom.xml
@@ -39,6 +39,23 @@
 			<artifactId>snakeyaml</artifactId>
 			<version>1.11</version>
 		</dependency>
+		<dependency>
+			<groupId>com.websudos</groupId>
+			<artifactId>phantom-dsl_2.10</artifactId>
+			<version>1.4.0</version>
+			<exclusions>
+				<exclusion>
+					<groupId>com.datastax.cassandra</groupId>
+					<artifactId>cassandra-driver-core</artifactId>
+				</exclusion>
+			</exclusions>
+		</dependency>
+		<dependency>
+			<groupId>org.cassandraunit</groupId>
+			<artifactId>cassandra-unit</artifactId>
+			<version>2.2.2.1</version>
+			<scope>test</scope>
+		</dependency>
 	</dependencies>
 
 	<licenses>

diff --git a/scray-cassandra/src/main/scala/scray/cassandra/sync/CassandraJobInfo.scala b/scray-cassandra/src/main/scala/scray/cassandra/sync/CassandraJobInfo.scala
@@ -19,6 +19,8 @@ class CassandraJobInfo(
     numberOfOnlineSlots: Int = 2,
     lockTimeOut: Int = 500) extends JobInfo[Statement, Insert, ResultSet](name, numberOfBatchSlots, numberOfOnlineSlots) with LazyLogging {
 
+  import CassandraImplementation.genericCassandraColumnImplicit
+
   val statementGenerator = CassandraStatementGenerator
 
   def getLock(dbSession: DbSession[Statement, Insert, ResultSet]): LockApi[Statement, Insert, ResultSet] = {

diff --git a/.../scray/cassandra/sync/CassandraImpl.scala → .../scray/cassandra/sync/cassandraImpl.scala b/.../scray/cassandra/sync/CassandraImpl.scala → .../scray/cassandra/sync/cassandraImpl.scala
@@ -116,6 +116,8 @@ class OnlineBatchSyncCassandra(dbSession: DbSession[Statement, Insert, ResultSet
     OnlineBatchSyncWithTableIdentifier[Statement, Insert, ResultSet] with 
     StateMonitoringApi[Statement, Insert, ResultSet] {
 
+  import CassandraImplementation.genericCassandraColumnImplicit
+
   def this(dbHostname: String) = {
     this(new CassandraDbSession(Cluster.builder().addContactPoint(dbHostname).build().connect()))
   }