From 2b7672fa11efa6e8c3c5cbc6fa857b3bc8947092 Mon Sep 17 00:00:00 2001 From: Brandon Williams Date: Tue, 1 May 2012 14:57:05 -0500 Subject: [PATCH] Return DateType as long in pig. --- .../java/org/apache/cassandra/hadoop/pig/CassandraStorage.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 329155cc9e..a5d9143574 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); }