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

Merge branch '3886' into cassandra-1.0

This commit is contained in:
Brandon Williams 2012-02-10 12:01:18 -06:00
parent c3dc789415 742648c821
commit cb0efd09cf
1 changed files with 12 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -491,8 +491,18 @@ public class CassandraStorage extends LoadFunc implements StoreFuncInterface, Lo
if (o == null) if (o == null)
return (ByteBuffer)o; return (ByteBuffer)o;
if (o instanceof java.lang.String) if (o instanceof java.lang.String)
o = new DataByteArray((String)o); return new ByteBuffer.wrap(DataByteArray((String)o).get());
return ByteBuffer.wrap(((DataByteArray) o).get()); if (o instanceof Integer)
return IntegerType.instance.decompose((BigInteger)o);
if (o instanceof Long)
return LongType.instance.decompose((Long)o);
if (o instanceof Float)
return FloatType.instance.decompose((Float)o);
if (o instanceof Double)
return DoubleType.instance.decompose((Double)o);
if (o instanceof UUID)
return ByteBuffer.wrap(UUIDGen.decompose((UUID) o));
return null;
} }
public void putNext(Tuple t) throws ExecException, IOException public void putNext(Tuple t) throws ExecException, IOException