Jonathan,
We need a small update to contrib/pig to accommodate pulling hexToBytes out
of FBUtilities into Hex.
I raised an issue, and attached is the patch for trunk.
https://issues.apache.org/jira/browse/CASSANDRA-3341
-brian
--
Brian ONeill
Lead Architect, Health Market Science (http://healthmarketscience.com)
mobile:215.588.6024
blog: http://weblogs.java.net/blog/boneill42/
blog: http://brianoneill.blogspot.com/
Index: src/java/org/apache/cassandra/hadoop/pig/CassandraStorage.java
===================================================================
--- src/java/org/apache/cassandra/hadoop/pig/CassandraStorage.java
(revision 1181048)
+++ src/java/org/apache/cassandra/hadoop/pig/CassandraStorage.java
(working copy)
@@ -26,7 +26,7 @@
import org.apache.cassandra.db.marshal.IntegerType;
import org.apache.cassandra.db.marshal.TypeParser;
import org.apache.cassandra.thrift.*;
-import org.apache.cassandra.utils.FBUtilities;
+import org.apache.cassandra.utils.Hex;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
@@ -601,7 +601,7 @@
TSerializer serializer = new TSerializer(new
TBinaryProtocol.Factory());
try
{
- return FBUtilities.bytesToHex(serializer.serialize(cfDef));
+ return Hex.bytesToHex(serializer.serialize(cfDef));
}
catch (TException e)
{
@@ -616,7 +616,7 @@
CfDef cfDef = new CfDef();
try
{
- deserializer.deserialize(cfDef, FBUtilities.hexToBytes(st));
+ deserializer.deserialize(cfDef, Hex.hexToBytes(st));
}
catch (TException e)
{
