cassandra-2.0

    1熱度

    1回答

    我試圖獲取從com.datastax.driver.core.ResultSet結果,並打印出來的: ResultSet results = getSession().execute("Select * from test.table"); //getsession returns a session int numcols = results.getColumnDefinitions().si

    0熱度

    3回答

    DSE版本4.8.2 我向數據集羣添加了6個新節點並將bootstrap:false。他們加入後,我正在進行重建。我相信1 NODE已完成,但控制檯上的命令仍在「運行」(例如,我現在還不能運行其他命令)。我想確保它完全完成。沒有壓縮,並且沒有流對該單元有效。更新:現在已經過了4天,仍然在命令提示符下。 除了compationstats和netstats之外,還有什麼可能是我錯過了嗎?我看到它流數據

    1熱度

    1回答

    使用Cassandra作爲隊列: 真的那麼糟嗎? 設置:5節點的集羣,所有的操作在仲裁 執行使用DateTieredCompaction應顯著減少墓碑的費用,並讓整個SSTables在一次被丟棄。 我們添加的所有消息隊列使用相同的TTL 我們基於時間(例如1分鐘間隔)分區信息,並跟蹤讀地位。 消耗的消息將被明確刪除。 (只有1個線程提取消息) 某些消息可能在被讀取之前被明確刪除(即我們可能在讀取位

    0熱度

    1回答

    我是cassandra的新手。我正在嘗試設置cassandra2.0.0羣集(4個節點)並使用wso2 DAS 3.0.1進行配置。我已經安裝了集羣成功後,將其配置爲DAS,在啓動時DAS服務器提供了以下錯誤, [2016-02-29 16:52:38,515] INFO {com.datastax.driver.core.Cluster} - New Cassandra host /127.0.

    1熱度

    2回答

    許多分佈式系統使用的閒話協議,例如卡桑德拉與環中的其他節點進行通信。那麼,它使用HTTP還是TCP協議? 此外,在分佈式系統中選擇一個在另一個之上的優點是什麼?因爲他們在網絡堆棧的不同層工作

    5熱度

    3回答

    我正在使用cassandra 2.1.10。 所以,首先,我會清楚,我知道二級指標是反模式在cassandra.But用於測試目的,我嘗試以下操作: CREATE TABLE test_topology1.tt ( a text PRIMARY KEY, b timestamp ) WITH bloom_filter_fp_chance = 0.01 AND cach

    0熱度

    1回答

    我希望爲Cassandra集羣收集不同的指標(如讀/寫延遲,內存使用率,堆大小,cpu使用率,壓縮計數等),該信息將被其他第三方監控工具。 所以,我才知道像 nodetool(其內部使用JMX API)的 JMX API(的MBean) JConsole的(單卡珊德拉過程可以追蹤,並在內部將使用JMX數據讀取選項該機器) 但是這裏的幾個疑問: 這是正確的,nodetoo l沒有提供直接由jmx提供

    1熱度

    1回答

    由於從Cassandra中查詢數據是有限制的,我試圖用Spark批量讀取數據並將其存儲在RDD中。 然後我添加所有的RDD,使用聯合函數。 這是我的代碼。 private void getDataFromCassandra(JavaSparkContext sc) { CassandraJavaRDD<CassandraRow> cassandraRDD = null ;

    0熱度

    2回答

    我有x GB(x從25-40 GB變化)的日常數據駐留在cassandra中,我想將它導出到一個文件中。所以,我穿過了這個SO link。使用它你可以導出具有格式的查詢數據,如下所示: select column1, column2 from table where condition = xy 因此,我在cron作業中安排了相同的方法。但由於大量的數據處理在寫入文本文件時被殺死。那麼,給定查

    0熱度

    1回答

    我使用卡桑德拉2.0.9,其中我得到了一些意外關機說OutOfMemoryError,雖然輕微壓實運行背景我得到這個錯誤。在此之前,我對墓碑有一些警告。但我已經將gc_grace設置爲只有一天。 WARN [ReadStage:95] 2016-03-09 06:10:31,548 SliceQueryFilter.java (line 225) Read 1 live and 21072 tom