使用 Cassandra 集成点燃

Question

我正在尝试将 Ignite 与 Cassandra 集成。我正在使用持久性策略作为 BLOB。当我运行程序时，它显示一个错误，如“com.datastax.driver.core.exceptions.CodecNotFoundException：未找到请求操作的编解码器：com.datastax.driver.core 的 [varchar java.nio.HeapByteBuffer]。 CodecRegistry.notFound(CodecRegistry.java:679) "

这是我的持久化 xml 文件

<persistence keyspace="sam" table="key">
<keyPersistence class="java.lang.String" strategy="BLOB" column="key"/>
<valuePersistence class="java.lang.String" strategy="BLOB" column="value"/>
</persistence>

main.cpp

int main()
{
IgniteConfiguration cfg;
cfg.springCfgPath = "apache-ignite-fabric-2.0.0-bin/cassandra-config.xml";
Ignite grid = Ignition::Start(cfg);
Cache<Test, Test> cache = grid.GetCache<Test, Test>("cache1");
Test obj;
cache.LoadCache ();
Test key;
key.key = "123dfsdfs";
obj.value = "sdfsf";
cache.Put (key,obj);
return 0;
}

Answer 1

该错误表示 Cassandra 中的列类型为 varchar，但您正尝试将 BLOB 写入其中。因此失败。

但是为什么你对字符串使用BLOB 策略呢？您可以改用PRIMITIVE 策略将字符串按原样写入varchar 列。