Updated Branches: refs/heads/trunk fb6037744 -> 0d695d4d1
src/java/org/apache/cassandra/hadoop/pig/CqlStorage.java patch by dbrosius reviewed by slebresne for cassandra-6515 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/0d695d4d Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/0d695d4d Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/0d695d4d Branch: refs/heads/trunk Commit: 0d695d4d1eac1241fa251dc45103953aeb977ce2 Parents: fb60377 Author: Dave Brosius <dbros...@mebigfatguy.com> Authored: Fri Dec 20 06:03:50 2013 -0500 Committer: Dave Brosius <dbros...@mebigfatguy.com> Committed: Fri Dec 20 06:03:50 2013 -0500 ---------------------------------------------------------------------- src/java/org/apache/cassandra/hadoop/pig/CqlStorage.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/0d695d4d/src/java/org/apache/cassandra/hadoop/pig/CqlStorage.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/hadoop/pig/CqlStorage.java b/src/java/org/apache/cassandra/hadoop/pig/CqlStorage.java index 3dda264..76d8026 100644 --- a/src/java/org/apache/cassandra/hadoop/pig/CqlStorage.java +++ b/src/java/org/apache/cassandra/hadoop/pig/CqlStorage.java @@ -187,10 +187,11 @@ public class CqlStorage extends AbstractCassandraStorage { // standard Map<ByteBuffer,AbstractType> validators = getValidatorMap(cfDef); - if (validators.get(col.name()) == null) + ByteBuffer cellName = col.name().toByteBuffer(); + if (validators.get(cellName) == null) return cassandraToObj(getDefaultMarshallers(cfDef).get(MarshallerType.DEFAULT_VALIDATOR), col.value()); else - return cassandraToObj(validators.get(col.name()), col.value()); + return cassandraToObj(validators.get(cellName), col.value()); } /** set read configuration settings */
