Updated Branches: refs/heads/cassandra-1.0 651ca528d -> 4bd3f8d86
Integer corresponds to Int32Type Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/4bd3f8d8 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/4bd3f8d8 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/4bd3f8d8 Branch: refs/heads/cassandra-1.0 Commit: 4bd3f8d86fcc29259dd0d508873125f88ce588e4 Parents: 651ca52 Author: Brandon Williams <brandonwilli...@apache.org> Authored: Mon Feb 13 13:48:20 2012 -0600 Committer: Brandon Williams <brandonwilli...@apache.org> Committed: Mon Feb 13 13:48:20 2012 -0600 ---------------------------------------------------------------------- .../cassandra/hadoop/pig/CassandraStorage.java | 2 +- 1 files changed, 1 insertions(+), 1 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/4bd3f8d8/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 b9977a5..76a291a 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 @@ -493,7 +493,7 @@ public class CassandraStorage extends LoadFunc implements StoreFuncInterface, Lo if (o instanceof java.lang.String) return ByteBuffer.wrap(new DataByteArray((String)o).get()); if (o instanceof Integer) - return IntegerType.instance.decompose((BigInteger)o); + return Int32Type.instance.decompose((Integer)o); if (o instanceof Long) return LongType.instance.decompose((Long)o); if (o instanceof Float)