phoenix

0热度

1回答

对不起这个问题，因为这已经提出了很多的时间，但我仍然无法找到解决我的问题后，通过每个相关的职位。我在HDP 2.4.2上的Kerberos env上使用Spark Streaming（1.6.1）和Phoenix（4.4），当尝试从HBase读取或写入时获取下面的异常。即使跳过spark-submit中的key-ph.conf文件，我也会遇到同样的问题。我对后下看它有相同的问题，因为我的，但我

0热度

1回答

SparkSQL：我正在做对吗？

以下是我正在使用的一个小应用程序中如何使用Spark-SQL。我有两个Hbase表t1，t2。我的输入是一个csv文件，我解析每一行和查询（SparkSQL）表t1。我将输出写入另一个文件。现在我解析第二个文件并查询第二个表，并将某些函数应用于结果并输出数据。表t1具有购买细节，t2具有每个用户随时间框架添加到购物车的项目列表。输入 - >客户ID（在csv文件的它列表）输出 - >甲

1热度

1回答

如何使用WildFly连接到Kerberos保护的Apache Phoenix数据源？

我最近花了好几个星期试图让WildFly成功连接到Kerberized Apache Phoenix数据源。有关如何做到这一点的文档数量惊人的有限，但现在我已经破解它，我分享。环境： WildFly 9+。一个等效的JBoss版本也应该工作（但未经测试）。 WildFly 8不包含所需的org.jboss.security.negotiation.KerberosLoginModule类（但您可

0热度

1回答

Apache Phoenix创建视图抛出TableAlreadyExistException

我已经使用包含2列族的shell在Hbase中创建了一个表。我可以使用Hbase客户端API写入它。我正在使用phoenix JDBC驱动程序从中查询数据。我了解到HBase和Phoenix表之间没有一对一的映射关系。所以，我创建一个视图我现有的表，但每当我跑我的代码，我得到 org.apache.phoenix.schema.TableAlreadyExistsException: ERROR

0热度

1回答

凤凰不HBASE视图

返回任何行我有一个表中的HBase是绝对包含数据： scan "my_table", {LIMIT=>1} 000008d624784f434ea441eb930eb84e201511162015111624000024498 column=g:orig_ccy, timestamp=3688201677984955, value=XXX 但是，创建了这个表在凤凰城的顶视图后，不返回任何行：

3热度

1回答

加载表

我想知道这究竟工程时，从凤凰过滤， df = sqlContext.read \ .format("org.apache.phoenix.spark") \ .option("table", "TABLE") \ .option("zkUrl", "10.0.0.11:2181:/hbase-unsecure") \ .load() 如果

0热度

2回答

在Apache的凤凰创建视图：错误505

我不能后，在凤凰运行该命令 CREATE VIEW "t1" (pk VARCHAR PRIMARY KEY, "f1".val VARCHAR) 我已经在HBase的命令执行的 create 't1', {NAME => 'f1', VERSIONS => 5} 我得到以下错误 org.apache.phoenix.schema.ReadOnlyTableException: ERROR

0热度

2回答

续签到Apache凤凰（使用Kerberos）连接失败正是10小时

后，我有可能一个Java应用程序，使Apache的凤凰某些SQL SELECT语句。对于此我使用一个原理用密钥表创建连接。这是支持的连接类： public class PhoenixDriverConnect { private static Connection conn; private static final Logger logger = LoggerFactory.getLogge

1热度

1回答

什么是从HBase提取数据的最快方法

我有大约5TB的数据分布在HBase的30个不同表中。我的用例是基于每个表中的YEAR和Country两个特定列，我必须创建5K个不同的文本文件。为了这个目的，我整合了HIVE和HBase，但从HIVE中提取需要很长时间。我必须在10个小时内完成。寻求你的想法如何实现这一点。我对此有一些疑问。 HIVE HBase整合是好方法吗？使用mapreduce从HBase提取数据将是个好主意吗

1热度

2回答

用于HBASE的JDBC Phoenix驱动程序，重试36并抛出异常

我在服务器（远程）中安装了独立的HBase。我编写了一个Java客户端，它使用Phoenix进行通信，并看到它尝试了36次尝试并因此抛出异常。 HBase-Version : 1.1.5 Phoenix-core: 4.8.0-HBase-1.1 的ConnectionString： Class.forName("org.apache.phoenix.jdbc.PhoenixDriver"