You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by br...@apache.org on 2012/02/13 23:39:08 UTC
[12/12] git commit: Pig's objToBB should handle all types. Patch by
brandonwilliams, reviewed by xedin for CASSANDRA-3886
Pig's objToBB should handle all types.
Patch by brandonwilliams, reviewed by xedin for CASSANDRA-3886
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/742648c8
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/742648c8
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/742648c8
Branch: refs/heads/trunk
Commit: 742648c821bb5922018423ff5f360233017a08ba
Parents: 22b8a97
Author: Brandon Williams <br...@apache.org>
Authored: Fri Feb 10 10:07:53 2012 -0600
Committer: Brandon Williams <br...@apache.org>
Committed: Fri Feb 10 12:00:07 2012 -0600
----------------------------------------------------------------------
.../cassandra/hadoop/pig/CassandraStorage.java | 14 ++++++++++++--
1 files changed, 12 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/742648c8/contrib/pig/src/java/org/apache/cassandra/hadoop/pig/CassandraStorage.java
----------------------------------------------------------------------
diff --git a/contrib/pig/src/java/org/apache/cassandra/hadoop/pig/CassandraStorage.java b/contrib/pig/src/java/org/apache/cassandra/hadoop/pig/CassandraStorage.java
index b1af1b5..63758ab 100644
--- a/contrib/pig/src/java/org/apache/cassandra/hadoop/pig/CassandraStorage.java
+++ b/contrib/pig/src/java/org/apache/cassandra/hadoop/pig/CassandraStorage.java
@@ -491,8 +491,18 @@ public class CassandraStorage extends LoadFunc implements StoreFuncInterface, Lo
if (o == null)
return (ByteBuffer)o;
if (o instanceof java.lang.String)
- o = new DataByteArray((String)o);
- return ByteBuffer.wrap(((DataByteArray) o).get());
+ return new ByteBuffer.wrap(DataByteArray((String)o).get());
+ if (o instanceof Integer)
+ return IntegerType.instance.decompose((BigInteger)o);
+ if (o instanceof Long)
+ return LongType.instance.decompose((Long)o);
+ if (o instanceof Float)
+ return FloatType.instance.decompose((Float)o);
+ if (o instanceof Double)
+ return DoubleType.instance.decompose((Double)o);
+ if (o instanceof UUID)
+ return ByteBuffer.wrap(UUIDGen.decompose((UUID) o));
+ return null;
}
public void putNext(Tuple t) throws ExecException, IOException