phoenix

    1熱度

    1回答

    我在hbase上的phoenix中有獨特和聚合函數的問題。 我在我的表中有一些ip。其中一些是重複性的。當我使用 select *, 查詢返回的所有IPS但是當我使用 distinct or count(1) and group by 要刪除重複的IP地址,但結果有些IP地址完全刪除,有沒有結果。我將我的ips保存在hbase的varchar列中,並用phoenix在hbase上查詢。 我

    0熱度

    1回答

    我想使用phonix上傳批量csv文件,但我無法理解下面的命令。你能詳細解釋我嗎? HADOOP_CLASSPATH=$(hbase mapredcp):/path/to/hbase/conf hadoop jar phoenix-<version>-client.jar org.apache.phoenix.mapreduce.CsvBulkLoadTool --table EXAMPLE --

    1熱度

    1回答

    我試圖使用PhoenixStorageHandler作爲記錄here,並與直線殼下面的查詢來填充它: insert into table pheonix_table select * from hive_table; 我得到的TEZ會話映射器的以下故障: ... INFO : Map 1: 0(+50)/50 INFO : Map 1: 0(+50)/50 INFO : Map 1: 0

    0熱度

    1回答

    oracl sql開發人員可能會這樣做。我想,在鳳凰相同的功能就是可以 DDL與DCL語句

    0熱度

    1回答

    Team.When我在火花集羣上運行一個程序來保存RDD到phoenix,我總是報告這個錯誤。如下: 17/06/12 09:35:46 ERROR kerberos.SaveAsPhoenixApp$: save to phoenix error :java.lang.RuntimeException: java.lang.ClassNotFoundException: Class org.ap

    0熱度

    1回答

    我在Phoenix中的類型爲Date的列中包含activation_date列,其中包含類似「2016-06-18 07:00:00.000」, 的條目如何選擇相同的日期大於x日期: select activation_date from xyz where activation_date > '2017-03-17 07:00:00.000' limit 10; 上面的查詢提供了錯誤,如:

    0熱度

    1回答

    我已經創建了一個phbase表與鳳凰SQL創建表查詢,還指定salt_buckets。如預期的那樣,Salting爲rowkey添加前綴。 我已經創建了一個外部蜂巢表映射到這個HBase的表HBase的SERDE問題是,當我通過rowkey過濾查詢該表: 其中key =「值」 它不」因爲我認爲salt pre-fix也會被拿到鑰匙上。這限制了對密鑰上的數據進行過濾的能力。選項: 「,其中rowke

    1熱度

    2回答

    我正在使用phoenix(4.10.0-Hbase-1.2)在hbase(1.2.6)上工作。 我收到此錯誤: org.apache.hadoop.hbase.client.RetriesExhaustedException:無法獲取位置錯誤 下面是我的代碼,通過它我試圖連接到HBase的使用鳳: Connection connection = DriverManager.getConnectio

    0熱度

    1回答

    I am using Phoenix verion :4.10.0-HBase-1.2 I am getting below error while creating new schema: 不一致的命名空間映射性質在..確保配置 phoenix.schema.isNamespaceMappingEnabled是在客戶端和服務器 到consitent創建HBase的架構。 What doe

    0熱度

    1回答

    如何使用Phoenix刪除包含HBase表中的表的模式? HBase的版本:1.2.6 鳳凰版本:4.10.0-HBase的-1.2.0 我試圖刪除模式,但我無法做到這一點。我的模式由一些表組成。 我得到一個錯誤,該架構不是空的。在這種情況下,我該如何放棄架構?我還需要額外做些什麼? 這是使用鳳凰從HBase的下降架構的Java代碼: Connection conn = setupDbConnec