hector

3熱度

2回答

我是scala的新手，我想將我的java代碼轉換爲scala。我的數據庫是卡桑德拉和列族定義這個樣子的 Family name :colFam Rowkey: rowKey1 =>(name=comkey1:comkey1,value='xyz',timestamp=1554515485) =>(name=comkey1:comkey2,value='xyz',timestamp=1554

0熱度

1回答

Cassandra在多節點集羣上編寫一致性級別

我使用Hector API連接到Cassandra並使用計數器列族來更新計數器。數據是從網頁展示中收集的，並且數據量大約爲每秒2000個事件。我正在使用運行Cassandra節點的五個AWS大型實例。我覺得一致性水平存在一些問題。我已經嘗試QUARM和ONE一致性級別，但兩個小時後它拋出timedout異常。而且我也試圖與任何一致性的水平，但我得到以下異常：代碼： Configurable

0熱度

1回答

實現數據的鎖定用C

我只是想知道是否有實現卡桑德拉數據的鎖定任何可能的方法是什麼？我想用多線程赫克託但這並沒有進行得很順利。任何人都可以提出一種方法

0熱度

1回答

如何使用Hector檢索Cassandra keyspace/columnfamily中的密鑰列的名稱？

我想將Cassandra keyspace/columnfamily行轉換爲JSON字符串。我當前的代碼（片段）： RangeSlicesQuery<K, N, V> rangeSlicesQuery = HFactory .createRangeSlicesQuery(this.keyspace, this.kSerializer, this.nSerializer, this.vSe

1熱度

1回答

cassandra如何在節點執行寫操作並且節點發生故障時作出反應

我們有2個節點的Cassandra集羣。複製因子爲1，一致性級別爲1.我們不使用複製，因爲我們插入的數據對於每條記錄都非常大。當在該節點中執行寫操作時，Cassandra如何在節點關閉時作出反應？我們使用Java客戶端的Hector API。我的理解是，Cassandra將執行寫入正在運行的其他節點。

1熱度

1回答

顯示卡桑德拉列族中的所有行和特定行

出於某種原因，我只能使用'cassandra-cli'來執行一些CQL操作。這是我使用的版本： Welcome to Cassandra CLI version 1.1.10 而且我用的是卡桑德拉的版本是： apache-cassandra-1.1.10 我創建了一個名爲「goldenbuck」密鑰空間和列族稱爲「holytest」那裏面鍵空間。然後我使用Hector API在其中插入一行

0熱度

1回答

如何設置/初始化Cassandra中新添加列的值

我們在Cassandra中有超過1000萬行，並且它們都在同一個表下。最近我們計劃在現有表格中添加一個新列，並且所有行的新列都需要設置爲true。有沒有辦法爲新添加的列初始化值？我現在的想法是迭代所有行並獲取輸出文件的所有密鑰，並基於檢索到的所有密鑰更新新添加的列值。請幫忙。我們可以通過哪種方式解決它，CQL，Java或Python並不重要。提前致謝。

1熱度

1回答

是否可以在日誌文件中禁用TimingLogger行？

我們使用Cassandra作爲我們的數據庫，並使用Hector與Cassandra對話。在我們的日誌文件中會出現以下噸行： 2015年10月15日08：53：50798信息mpcassandra.hector.TimingLogger - 啓動[1444910030795]時間[3]標籤[READ .success_] 2015年10月15日08：53：50798 INFO mpcassandr

1熱度

1回答

Cassandra-Hector單節點羣集HUnavailableException：：可能沒有足夠的副本來處理一致性級別

我正在嘗試使用單節點羣集（我認爲）創建cassandra數據庫，但不管設置複製的值是多少因素我不斷收到此錯誤： me.prettyprint.hector.api.exceptions.HUnavailableException：：可能沒有足夠的副本來處理一致性級別。這裏是我的代碼： public static String[]getSerializedClusterMap(){ Cl

1熱度

1回答

如何聲明覆合串行斯卡拉

import me.prettyprint.cassandra.serializers._ import me.prettyprint.hector.api._ import me.prettyprint.hector.api.factory.HFactory val se = StringSerializer.get() val le = LongSerializer.get.asIn