You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by db...@apache.org on 2013/12/20 12:04:48 UTC
git commit: src/java/org/apache/cassandra/hadoop/pig/CqlStorage.java
patch by dbrosius reviewed by slebresne for cassandra-6515
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 <db...@mebigfatguy.com>
Authored: Fri Dec 20 06:03:50 2013 -0500
Committer: Dave Brosius <db...@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 */