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