diff --git a/pom.xml b/pom.xml
index a6aa0447c..f56135df7 100644
--- 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
index 75e15f687..bd39634e8 100644
--- 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
index dba7d4cd3..6c8f27348 100644
--- 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/src/main/scala/scray/cassandra/sync/CassandraImpl.scala b/scray-cassandra/src/main/scala/scray/cassandra/sync/cassandraImpl.scala
similarity index 99%
rename from scray-cassandra/src/main/scala/scray/cassandra/sync/CassandraImpl.scala
rename to scray-cassandra/src/main/scala/scray/cassandra/sync/cassandraImpl.scala
index 1633ffd62..d4bf711a2 100644
--- a/scray-cassandra/src/main/scala/scray/cassandra/sync/CassandraImpl.scala
+++ b/scray-cassandra/src/main/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()))
   }