首頁(yè) 猿問 Astyanax 無(wú)法讀取某些列族

Astyanax 無(wú)法讀取某些列族

Java

一只萌萌小番薯 2021-10-27 13:46:48

我正在嘗試使用 Astyanax 驅(qū)動(dòng)程序在 Cassandra 中列出列族。它列出了鍵空間，但輸出中缺少許多列族。我有一個(gè)簡(jiǎn)單的程序：import com.netflix.astyanax.AstyanaxContext;import com.netflix.astyanax.Cluster;import com.netflix.astyanax.connectionpool.impl.ConnectionPoolConfigurationImpl;import com.netflix.astyanax.connectionpool.impl.CountingConnectionPoolMonitor;import com.netflix.astyanax.ddl.ColumnFamilyDefinition;import com.netflix.astyanax.ddl.KeyspaceDefinition;import com.netflix.astyanax.impl.AstyanaxConfigurationImpl;import com.netflix.astyanax.thrift.ThriftFamilyFactory;public class App { public static void main(String[] args) throws Exception { ConnectionPoolConfigurationImpl cpool = new ConnectionPoolConfigurationImpl("ConnectionPool") .setPort(9160) .setSeeds("localhost"); AstyanaxConfigurationImpl astyanaxConfiguration = new AstyanaxConfigurationImpl(); AstyanaxContext.Builder ctxBuilder = new AstyanaxContext.Builder(); ctxBuilder.forCluster("Cluster") .withAstyanaxConfiguration(astyanaxConfiguration) .withConnectionPoolConfiguration(cpool) .withConnectionPoolMonitor(new CountingConnectionPoolMonitor()); AstyanaxContext<Cluster> clusterContext = ctxBuilder.buildCluster(ThriftFamilyFactory.getInstance()); clusterContext.start(); Cluster cluster = clusterContext.getClient(); for (KeyspaceDefinition ksDef : cluster.describeKeyspaces()) { List<ColumnFamilyDefinition> cfDefList = ksDef.getColumnFamilyList(); System.out.println("there are " + cfDefList.size() + " column families in keyspace " + ksDef.getName()); for (ColumnFamilyDefinition cfDef : cfDefList) System.out.println(" - " + cfDef.getName()); }上面的輸出使用的是 cassandra 2.2，但我已經(jīng)確認(rèn)了其他版本的 cassandra 和 scylla 中的行為。

查看完整描述

3 回答

繁花不似錦

TA貢獻(xiàn)1851條經(jīng)驗(yàn) 獲得超4個(gè)贊

Thrift 已棄用，默認(rèn)情況下不再由 Cassandra 啟用。您需要啟用它才能使用它。請(qǐng)記住，在 Cassandra 的下一個(gè)版本中，它甚至不存在。很可能即使啟用它并使用它，事情也可能無(wú)法正常工作。沒有什么真正使用它了，也沒有那么多測(cè)試使用它。表的存儲(chǔ)和檢索方式在版本之間發(fā)生了變化，因此驅(qū)動(dòng)程序必須意識(shí)到這一點(diǎn)。由于 Astyanax 沒有得到維護(hù)，它可能不會(huì)正確。

Astyanax 已退役，僅適用于較舊的應(yīng)用程序。您應(yīng)該真正使用java 驅(qū)動(dòng)程序（與 Astyanax 頁(yè)面上的建議相同）。

反對(duì) 回復(fù) 2021-10-27

炎炎設(shè)計(jì)

TA貢獻(xiàn)1808條經(jīng)驗(yàn) 獲得超4個(gè)贊

我記得在 Cassandra 0.8.8 - 1.1 和 1.2 中使用 Astyanax。曾經(jīng)有一段時(shí)間，我們會(huì)將所有數(shù)據(jù)（列）作為 blob 推送到一個(gè)分區(qū)中（啟用更快的寫入），然后我們會(huì)從 thrift 胖客戶端解析數(shù)據(jù)（據(jù)稱 Cassandra 此時(shí)讀取速度很慢）。我們必須跟蹤模式，然后在反序列化來(lái)自 thrift 客戶端的輸出時(shí)，我們將根據(jù)所有單個(gè)列的數(shù)據(jù)類型進(jìn)行解析。在引入 CQL 之后，所有這些都發(fā)生了變化，正如 Chris 指出的那樣，這是使用 c* 的推薦方式。

反對(duì) 回復(fù) 2021-10-27