natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix pig build after FBU->Hex move. 

Patch by Brian Oneill reviewed by brandonwilliams for CASSANDRA-3341

git-svn-id: https://svn.apache.org/repos/asf/cassandra/branches/cassandra-1.0@1182458 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Brandon Williams 2011-10-12 16:21:19 +00:00
parent ab95f980f4
commit e860d2fdf5
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
contrib/pig/src/java/org/apache/cassandra/hadoop/pig/CassandraStorage.java
View File

@ -26,7 +26,7 @@ import org.apache.cassandra.db.marshal.BytesType;
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 @@ public class CassandraStorage extends LoadFunc implements StoreFuncInterface, Lo
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 @@ public class CassandraStorage extends LoadFunc implements StoreFuncInterface, Lo
CfDef cfDef = new CfDef();
try
{
deserializer.deserialize(cfDef, FBUtilities.hexToBytes(st));
deserializer.deserialize(cfDef, Hex.hexToBytes(st));
}
catch (TException e)
{