我正在尝试在我的项目中从使用pycassa转向使用本机协议(这将让我们升级cassandra的版本)。我的模式是使用pycassa定义的,所以它使用紧凑的存储创建了一个列族,它有3列,这些列不是复合主键的一部分(我知道CQL协议不允许这一点)。
我当前的Cassandra集群的版本是2.0.17。当我使用thrift协议"显示模式"时,模式是:
create column family store
with column_type = 'Standard'
and comparator = 'CompositeType(org.apache.cassandra.db.marshal.ReversedType(org.apache.cassandra.db.marshal.LongType),org.apache.cassandra.db.marshal.AsciiType,org.apache.cassandra.db.marshal.AsciiType)'
and default_validation_class = 'DoubleType'
and key_validation_class = 'AsciiType'
and column_metadata = [
{column_name : 'something1',
validation_class : AsciiType},
{column_name : 'something2',
validation_class : AsciiType}]
但是当我检查本机协议上的模式时,它缺少"column3"one_answers"value"列。结果如下:
CREATE TABLE store (
key ascii,
column1 bigint,
column2 ascii,
something1 ascii,
something2 ascii,
PRIMARY KEY ((key), column1, column2)
) WITH COMPACT STORAGE AND
CLUSTERING ORDER BY (column1 DESC, column2 ASC)
现在,由于这个差异,我无法在客户端从pycassa转换到本机协议。我还没有找到任何方法来克服这个问题,并确保本机协议看到正确的模式。你能给我什么建议来解决这个问题吗?
总之,修改表,添加缺失的列。
看起来你没有任何列元数据值或column3我不确定他们是什么类型,如果他们只是ascii以及你应该能够做以下操作:
ALTER TABLE store ADD column3 ascii;
ALTER TABLE store ADD value ascii;