Author: jbellis
Date: Tue May 10 16:53:55 2011
New Revision: 1101542
URL: http://svn.apache.org/viewvc?rev=1101542&view=rev
Log:
improve KsDef backwards-compatibility
Modified:
cassandra/branches/cassandra-0.8/drivers/java/src/org/apache/cassandra/cql/jdbc/ColumnDecoder.java
Modified:
cassandra/branches/cassandra-0.8/drivers/java/src/org/apache/cassandra/cql/jdbc/ColumnDecoder.java
URL:
http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.8/drivers/java/src/org/apache/cassandra/cql/jdbc/ColumnDecoder.java?rev=1101542&r1=1101541&r2=1101542&view=diff
==============================================================================
---
cassandra/branches/cassandra-0.8/drivers/java/src/org/apache/cassandra/cql/jdbc/ColumnDecoder.java
(original)
+++
cassandra/branches/cassandra-0.8/drivers/java/src/org/apache/cassandra/cql/jdbc/ColumnDecoder.java
Tue May 10 16:53:55 2011
@@ -28,7 +28,6 @@ import org.apache.cassandra.db.marshal.A
import org.apache.cassandra.db.marshal.AsciiType;
import org.apache.cassandra.thrift.*;
import org.apache.cassandra.utils.ByteBufferUtil;
-import org.apache.cassandra.utils.FBUtilities;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -59,7 +58,7 @@ class ColumnDecoder
{
try
{
- metadata.put(String.format("%s.%s", ks.getName(),
cf.getName()), CFMetaData.convertToCFMetaData(cf));
+ metadata.put(String.format("%s.%s", ks.getName(),
cf.getName()), CFMetaData.fromThrift(cf));
}
catch (InvalidRequestException e)
{
