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

Return DateType as long in pig.

This commit is contained in:
Brandon Williams 2012-05-01 14:57:05 -05:00
parent f4430ff4e7
commit 2b7672fa11
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -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);
}