hector

    12熱度

    2回答

    我的應用程序的運行監控,我正在尋找類似常用的「SQL連接驗證」的東西查詢 SELECT 1; 在卡桑德拉,使用赫克託司機。我嘗試過諸如查看Cluster.getKnownPoolHosts()和.getConnectionManager()。getActivePools()。但是,似乎他們的狀態並沒有不斷更新,只有當我真的試圖通過查詢訪問Cassandra時。 我希望我的健康檢查獨立於任何需要存在

    2熱度

    3回答

    我要尋找一個列族中,我可以在下面 keyspace1{ :rowid1 AND its associated column field :rowid2 with a Super Column } 在本例中同時添加超列和正常列像這可能嗎?如果是PLZ建議 在此先感謝

    1熱度

    1回答

    我的數據模型看起來像這樣 #keyspace_name{ #columnfamily1 {startDate_mobileNo: // row key { Call_TYpe: // super column { xyz: value endDate : value; }

    4熱度

    2回答

    我在Cassandra的某個地方收到了一個OOM異常。 Mine是一個運行在適度供電的服務器上的單個實例,我正在做一些負載測試,所以在那裏並不奇怪。 但是,我後來無法使用該實例。當我列出密鑰空間時,只顯示「系統」。但是當我嘗試重新創建我正在測試的密鑰空間時,Hector響應了令人恐懼的「所有主機池標記爲down,重試負載推送給客戶端」。消息,卡桑德拉日誌有以下堆棧跟蹤: ERROR [Migrat

    2熱度

    1回答

    我想流中的部分文件和出卡珊德拉的,因爲我們已經在使用它,而不是建立一個完整的Hadoop分佈式文件系統。是否有任何異步放入atyanax或hector,我提供一個回調,當它完成,所以我可以避免1000個調用的1毫秒網絡延遲,因爲我寫1000個條目(在幾行和列之間分割,所以它流式傳輸到幾臺並行的服務器,然後所有的響應/回調在完成流式傳輸時返回)。 Hector或astyanax是否支持這一點? 它看

    3熱度

    1回答

    我有以下代碼: StringSerializer ss = StringSerializer.get(); String cf = "TEST"; CassandraHostConfigurator conf = new CassandraHostConfigurator("localhost:9160"); conf.setCassandraThriftSocketTimeout(4000

    4熱度

    1回答

    Cassandra經常使用的情況是將數據存儲在動態創建的列族的列名中。在這種情況下,行值本身是不需要的,通常的做法是在那裏存儲空值。 然而,赫克託打交道時,似乎沒有辦法插入空值,因爲赫克託HColumnImpl不明確的空檢查列的構造函數: public HColumnImpl(N name, V value, long clock, Serializer<N> nameSerializer,

    2熱度

    1回答

    我想使用列族和行密鑰從Cassandra中檢索一行。 但是,當我使用SliceQuery時,會出現一個異常:引起:me.prettyprint.hector.api.exceptions.HectorException:列名稱和範圍均未設置,這是一個無效的片斷謂詞。 有誰知道我是否使用了錯誤的查詢實現?

    1熱度

    1回答

    是否存在cassandra-cli中的API(Thrift或Hector)或某些命令的示例,說明如何在Cassandra中存儲小文件(幾百KB)。 我試過Google搜索,但找不到任何東西。

    1熱度

    1回答

    我有一個超級列家族,在這段時間裏需要刪除一系列超級列。我四處搜索,似乎沒有找到使用hector的解決方案。任何人都可以幫忙嗎?