cassandra

3熱度

1回答

我有一個卡桑德拉表Department，列name_list extends ListColumn[String]和id extends StringColumn with PartitionKey。我想獲取ID所請求的名存在於NAME_LIST。我試過在運營商select(_.id).where(name in name_list)但它不工作。另一個查詢，我試過select(_.id).w

2熱度

2回答

如何從幻像中的SetColumn [String]中選擇字段

我有一個Cassandra表Department，列name_list extends SetColumn[String] with PartitionKey和id extends StringColumn with PartitionKey。我想獲取ID所請求的名存在於NAME_LIST。我試過下面使用此代碼，但沒有得到任何結果 abstract class Departments exte

1熱度

1回答

如何整合彈性搜索與cassandra？

我想在我的應用程序中使用cassandra作爲db來實現彈性搜索。這個應用程序是使用Jhipster技術的創。有人請提出一種使用cassandra實現彈性搜索的方法。 Jhipster官員稱當時卡桑德拉不支持彈性搜索。 elassandra是一種方法，但沒有適當的方式來與elassandra合作。

-1熱度

1回答

在cassandra中讀取一致性LOCAL_QUORUM暗示

感謝您的回答Nikita。另外，再澄清一點。假設我在具有三個DC的DC-DC羣集中使用LOCAL_QUORUM來讀取一致性 - DC1，DC2，DC3，每個DC中有三個節點，複製因子爲3.讀取期間，讓我們假設請求首先落在DC1中的節點上。該節點已經失敗，因此DC1中的第二個節點被聯繫等等，並假定DC1中的所有節點都失敗了。然後，羣集將連接到DC2或DC3以滿足LOCAL_QUORUM，即從兩個DC

1熱度

1回答

使用Spark + Cassandra處理一張桌子到另一張桌子的低性能

我試圖使用spark + spark-cassandra-connector將一張桌子複製到另一張桌子，花費很多時間（〜17小時）。即使對於所有行（~2億）的簡單計數，我也花費了大約1個小時。我如何加快這個過程？卡桑德拉版本：3.1 object Init { def main(args: Array[String]): Unit = { val sparkConf = n

3熱度

1回答

如何做日期時間算術在CQL

我的目標，是去除的固定時間內，從現在開始（）。所以，我總是最後五分鐘，或過去五小時。我怎樣才能實現呢？ The documentation上卡桑德拉說：的持續時間可以被添加（+）或中減去 - 從時間戳或日期創建一個新的時間戳或日期（）。因此，例如： SELECT * FROM myTable WHERE t = '2017-01-01' - 2d 將選擇所有與T的值，它是在2016年內cq

0熱度

1回答

Scala/Apache Spark轉換DataFrame列值和類型，否則爲多個

我有一個主要的SQL表，我正在讀入Spark並修改爲寫入CassandraDB。目前，我有一個將性別從0,1,2,3（整數）轉換爲「男性」，「女性」，「Trans」等（字符串）的工作實現。雖然下面的方法做工作，似乎非常低效，使那些映射到數據幀一個單獨的陣列，它加入到主表/數據幀，然後刪除，重命名等我看到： .withColumn("gender", when(col("gender) === 1

1熱度

3回答

使用CQLSH查看Cassandra分區使用Cassandra

使用Cassandra，我如何根據我創建的主鍵創建了多少個分區？我一直在遵循一個教程，它提到去bin/cassandra-cli並使用LIST命令。然而，最新的Cassandra安裝不會附帶這個，我已經閱讀了其他在線文章，指出cli現在已被棄用。反正有我看到使用cqlsh創建的分區嗎？在此先感謝！

0熱度

1回答

如何通過Docker Image將Elassandra集成到我的Jhipster應用程序中？

我想將elassandra整合到我的jijster應用程序中。我在其中使用cassandra作爲分貝。我正在使用docker映像正式執行elassandra安裝過程，但他們很難理解哪個container_name必須添加到哪個命令中。這裏是官方鏈接：http://doc.elassandra.io/en/latest/installation.html#docker-image 和我的端口92

0熱度

1回答

Scala Spark將多個列中的值聚合到新列中

我正在對Cassandra進行SQL遷移，並且在將多個列合併到單個列中時遇到問題。例如，假設我有一個人可以參加一場或多場比賽。我現在每個人都有0或1的比賽。我如何能夠將它作爲一個集合合併到一個列中？ SQL Schema +----------------------------------+ - R_White R_Af_American R_Asian - - 1 1 1