phoenix

0熱度

2回答

我想通過Spark/Scala連接到Phoenix來讀寫數據作爲DataFrame。我正在關注GitHub上的示例，但是當我嘗試使用數據源API的第一個示例加載爲DataFrame時，我得到以下例外。 Exception in thread "main" java.lang.NoSuchMethodError: org.apache.hadoop.hbase.client.Put.setWrite

1熱度

1回答

Phoenix Spark Plugin

是spark 2.0的插件更新嗎？我不能使用該插件 val df = spark.read .format("org.apache.phoenix.spark") .option("table", "web_stat") .option("zkUrl", "localhost:2181") .option("driver","org.apache.

1熱度

1回答

記錄來自Apache Phoenix的所有查詢

我們使用Apache Phoenix訪問HBase數據存儲。作爲一些要求的一部分，我們需要記錄每個更新操作，例如從任何Phoenix客戶端發佈的寫入和刪除表命令。 Phoenix的日誌記錄是否已經以可解析的格式捕獲這些命令？如果不是，我如何獲取這些信息？

0熱度

2回答

選擇警報類型和項目標識相同的行，並選擇多少行類似

我試圖在我的項目中儘可能簡化通知系統。「約翰·布朗和另外4人喜歡你的照片」我想： Select a.id, a.item_id, a.type u.f_name, u.l_name, count(a) From alerts Join users on a.user_id = u.u_id Where owner_id = {THE_USER_ID} 但它不「工作」用戶表 u_i

0熱度

2回答

Apache phoenix併發查詢失敗，出現異常

我們正在嘗試一些操作，如SELECT->將行鍵存儲到集合中 - >然後將集合拆分到每個工作線程中 - >每個線程再次使用phoenix jdbc創建連接 - >執行SELECT然後根據結果UPSERT到不同的鳳凰表。我正在使用ExecutorService的固定線程池爲4我看到如下例外。 org.apache.phoenix.exception.PhoenixIOException: org.a

4熱度

2回答

如何在phoenix/elixir中啓用Elm 0.18的調試標誌

我開始嘗試使用Phoenix框架和Elm的新項目。我有正確的項目設置，但我想在我的項目中啓用在Elm 0.18中發佈的調試器。有誰知道如何啓用與brunch或鳳凰的--debug標誌。謝謝。

1熱度

1回答

Pyspark和鳳凰表

我想用Pyspark的鳳凰表。我嘗試我在這裏找到的解決方案：https://phoenix.apache.org/phoenix_spark.html 但是我有一個錯誤。你能幫我解決這個錯誤嗎？ df_metadata = sqlCtx.read.format("org.apache.phoenix.spark").option("zkUrl", "xxx").load("lib.name_of_

0熱度

1回答

阿帕奇鳳凰大容量數據加載 - 不能用小寫字母使用表名

我有現成的鳳凰臺ABC 我通過MapReduce的想批量數據加載和再使用如下命令加載csv文件 Hadoop的罐子/root/Phoenix/apache-phoenix-4.8.0-HBase-0.98-bin/phoenix-4.8.0-HBase-0.98-client.jar org.apache.phoenix.mapreduce.CsvBulkLoadTool --t abc --i

0熱度

2回答

更新非關鍵列查詢Pheonix JDBC

我在更新aphph phoenix中的值時遇到問題。下面的查詢引發JDBC異常。我是Pheonix JDBC的新手，並且使用upsert查詢用法來更新非主鍵字段值。 String sql = UPSERT INTO mytable (serverName,SationName, product) SELECT serverName,stationName ‘sampleProduct’ FROM

0熱度

1回答

使用Phoenix驅動程序將數據保存到Hbase時區問題

我是HBase的新手，並使用Phoenix驅動程序使用Squirrel客戶端連接HBase。下面的查詢描述了我的表結構，它具有帶「Alert Id（varchar）」和「Alert StartTime（Row Timestamp）」的複合主鍵。 CREATE TABLE ALERT_DETAILS (ALERTID VARCHAR,MACHINENAME VARCHAR(100),PLACE VA