我使用 Cassandra 和Phantom作为 Scala DSL 和驱动程序。
现在,我想使用Cassandra Lucene Index作为 Cassandra 插件。它们提供了一个基于 Lucene 的二级索引,可以通过这种方式创建:
CREATE CUSTOM INDEX tweets_index ON tweets ()
USING 'com.stratio.cassandra.lucene.Index'
WITH OPTIONS = {
'refresh_seconds': '1',
'schema': '{
fields: {
id: {type: "integer"},
user: {type: "string"},
body: {type: "text", analyzer: "english"}
}
}'
};
不幸的是,我还没有找到一种方法来使用 Phantom 作为 DSL 创建这样的索引。所以我想在这里问一下是否有可能使用 Phantom 或者我是否必须使用原始 CQL 语句或 Cassandra 的 Java API?
另外我猜不可能使用 Phantom 来查询 Lucene 索引?