phoenix

0热度

1回答

我试图在时间戳列上使用Apache Phoenix的过滤器。我的表格和列存在。该列是类型TIMESTAMP。 https://phoenix.apache.org/language/datatypes.html#timestamp_type 0: jdbc:phoenix:localhost:2181:/hbase> SELECT * FROM METRIC where METRIC_ID =

1热度

1回答

在客户端实现ThreadPoolSize的更改 - JDBC驱动程序Apache Phoenix

我最近设置了一个JDBC驱动程序来使用Apache Phoenix连接到Hadoop db。松鼠的基本查询运行良好（例如，“从数据文件中选择*”），但只要我问一个稍微复杂的查询（即“从列data1 where column2 ='filter1'”选择column1，我遇到此错误： org.apache.phoenix.exception.PhoenixIOException: Task org

0热度

1回答

无法使用JDBC连接到Phoenix

我有一个使用HBase和Phoenix设置的Hadoop集群，我尝试使用JDBC连接到Phoenix，但我无法获得成功的连接。我想使用JDBC来使用Python 3.x进行连接，但为了简单的测试目的，我在Eclipse中使用Java建立了一个连接。我最初使用Python的第三方库（phoenixdb），但我开始使用这个库超时（随着我的数据库的增长）。在此之后，我更改了我的hbase-site.

1热度

1回答

apache phoenix 4.10从hbase列映射

我有一个现有的hbase表，已经把所有数据以phoenix格式。然后尝试在它上面创建一个凤凰表。在凤凰4.9一切都很好。但phoenix 4.10有一个列映射https://blogs.apache.org/phoenix/entry/column-mapping-and-immutable-data，所以我的列限定符不能是地址，名称等原始字符串。但必须映射到某个整数，我该怎么做？有没有办法来禁用

-1热度

1回答

当将spark数据帧保存到phoenix时，DateUtil.java中的IllegalDataException

我正在使用kafka + spark流来传输消息并执行分析，然后保存到phoenix。一些火花作业是否失败，每天数次，出现以下错误信息： org.apache.phoenix.schema.IllegalDataException: java.lang.IllegalArgumentException: Invalid format: "" at org.apache.phoenix.

1热度

2回答

在PySpark中运行自定义的Apache Phoenix SQL查询

有人可以提供一个使用pyspark的例子来说明如何运行自定义的Apache Phoenix SQL查询并将查询的结果存储在RDD或DF中。注意：我正在查找自定义查询，而不是要将整个表读入RDD。从凤凰文件，加载整个表我可以用这个： table = sqlContext.read \ .format("org.apache.phoenix.spark") \ .option

0热度

1回答

使用Apache Phoenix Spark连接到Spark并运行自定义SQL查询

有人可以告诉如何使用Phoenix Spark连接器而不是使用Phoenix作为JDBC数据源来连接到Spark（如果作为JDBC源使用，但性能是问题https://phoenix.apache.org/phoenix_spark.html）。这是我试图用Phoenix驱动程序来做的，但它会抛出“Table Not Found”异常。 sql = '(select COL1, COL2 from

0热度

1回答

使用Phoenix CsvBulkLoadTool（）从jboss5.1加载hbase表

我想从jboss使用phoenix CsvBulkLoadTool（）加载hbase表。它正在运行，但它没有从保存在WEB-INF/classes文件夹中的hbase-site.xml中进行配置。当我通过命令行运行时，它从指定的类路径中取出hbase-site.xml属性。 INFO QueryUtil：335使用jdbc url创建连接：jdbc：phoenix：localhost：2181

0热度

1回答

无法通过hbase启动apache phoenix

我无法启动通过hbase安装的apache phoenix。当我尝试执行py文件时，出现以下错误。请告知

1热度

1回答

Apache Phoenix for Spark不起作用

根据Phoenix网站上的“使用数据源API载入数据框”示例，我无法通过Spark（2.1.0）连接到Phoenix（4.10）。我使用lastet（Phoenix 4.10）和Hbase 1.2.5。我可以通过Phoenix（sqlline客户端）在Hbase中创建一个表格。星火内返回的错误如下： scala> val df = sqlContext.load("org.apache.phoen