cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From brandonwilli...@apache.org
Subject [6/6] git commit: Return DateType as long in pig.
Date Tue, 01 May 2012 19:57:56 GMT
Return DateType as long in pig.


Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/2b7672fa
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/2b7672fa
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/2b7672fa

Branch: refs/heads/cassandra-1.0
Commit: 2b7672fa11efa6e8c3c5cbc6fa857b3bc8947092
Parents: f4430ff
Author: Brandon Williams <brandonwilliams@apache.org>
Authored: Tue May 1 14:57:05 2012 -0500
Committer: Brandon Williams <brandonwilliams@apache.org>
Committed: Tue May 1 14:57:05 2012 -0500

----------------------------------------------------------------------
 .../cassandra/hadoop/pig/CassandraStorage.java     |    2 +-
 1 files changed, 1 insertions(+), 1 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cassandra/blob/2b7672fa/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 329155c..a5d9143 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
@@ -218,7 +218,7 @@ public class CassandraStorage extends LoadFunc implements StoreFuncInterface,
Lo
        else if (value instanceof UUID)
            pair.set(position, new DataByteArray(UUIDGen.decompose((java.util.UUID) value)));
        else if (value instanceof Date)
-           pair.set(position, new DataByteArray(ByteBufferUtil.getArray(DateType.instance.decompose((Date)
value))));
+           pair.set(position, DateType.instance.decompose((Date) value).getLong());
        else
            pair.set(position, value);
     }


Mime
View raw message