phoenix相关内容

Apache phoenix:创建phoenix表映射到现有的hbase表

我确实有hbase表&对于SQL支持,我正在尝试探索是否可以创建apache phoenix表. 我想知道是否在现有的hbase表上创建phoenix表,它是否复制(或复制)hbase表中存在的数据,或者phoenix表只是链接到hbase中存在的现有数据? 我的凤凰版本是 ..
发布时间:2021-05-13 20:51:17 其他开发

如何在Phoenix框架中运行响应后的中间件功能?

我正在与Phoenix一起在Elixir中开发一个简单的网站.我想添加一些自定义中间件,该中间件在生成响应后 即可运行.例如,为了记录每个响应中的字节总数,我想要一个这样的插件 defmodule HelloWeb.Plugs.ByteLogger做导入Plug.Conn需要记录仪def init(默认),执行:默认def调用(conn,默认)log(“发送的字节数:#{String.leng ..
发布时间:2021-05-04 18:33:22 其他开发

火花连接到Phoenix NoSuchMethod异常

我正在尝试通过Spark/Scala连接到Phoenix以读取和写入数据作为DataFrame.我在 GitHub 上关注该示例,但是当我第一次尝试时示例使用数据源API加载为DataFrame 我遇到了以下异常. 线程"main"中的异常java.lang.NoSuchMethodError:org.apache.hadoop.hbase.client.Put.setWriteToWAL( ..
发布时间:2021-04-08 20:18:40 其他开发

加载表格时从凤凰过滤

我想知道它是如何工作的, df = sqlContext.read \.format("org.apache.phoenix.spark")\.option("table","TABLE")\.option("zkUrl","10.0.0.11:2181:/hbase-unsecure")\.加载() 如果这正在加载整个表,否则将延迟加载以了解是否将应用过滤. 在第一种情况下,如何告 ..
发布时间:2021-04-08 19:58:05 其他开发

如何使用JDBC驱动程序为Django编写自定义数据库适配器?

我在Django中有一个Web应用,在Hbase中有一个后端.要访问hbase,我正在使用Apache Phoenix查询hbase. Phoenix公开了jdbc驱动程序. 如何使用这些jdbc驱动程序将Phoenix与Django ORM集成在一起? 我可以编写客户数据库适配器还是其他方法? 谢谢. 解决方案 我也一直在尝试查看是否有可能将django的ORM扩展为使用ap ..
发布时间:2021-02-11 19:27:54 其他开发

Apache Phoenix非法数据异常

我在从HBase写入数据并用Phoenix读取数据时遇到问题. 这些是重现该问题的步骤: 使用Phoenix创建表. CREATE TABLE test ( id varchar not null, t1.a unsigned_int, t1.b varchar CONSTRAINT pk PRIMARY KEY (id)) COLUMN_ENCOD ..
发布时间:2020-11-22 19:01:48 其他开发

使用Spark和Phoenix将CSV文件保存到hbase表

有人可以指出一个使用Spark 2.2 将csv文件保存到Hbase表的工作示例吗? 我尝试和失败的选项(请注意:所有选项都对我来说适用于Spark 1.6) 凤凰火花 hbase-spark it.nerdammer.bigdata:spark-hbase-connector_2.10 在解决所有问题之后,所有这些最终都给此谢谢 解决方案 将以下参数添加到您的spark作 ..
发布时间:2020-11-22 19:01:42 其他开发

Apache Phoenix Create语句为select(从)

我正在尝试从Phoenix中的现有结构创建一个新表.在Phoenix中是否有一个CREATE as Select语句.我正在尝试,但失败了,但出现以下异常. 欢迎在这里提出任何建议.预先感谢. CREATE TABLE TEST AS (SELECT * FROM TEST_2 WHERE 1 =2); org.apache.phoenix.exception.PhoenixPar ..
发布时间:2020-11-22 18:59:26 其他开发

无法提交并发的Hadoop作业

我正在本地计算机上运行Hadoop 2.7,以及HBase 1.4和Phoenix 4.15.我编写了一个应用程序,该应用程序提交了通过Phoenix删除HBase中的数据的map reduce作业.每个作业都由ThreadPoolExecutor的单个线程运行,如下所示: public class MRDeleteTask extends Task { private final ..
发布时间:2020-11-22 02:42:31 Java开发

用于HBase/Phoenix的ODBC驱动程序

我需要将Tableau连接到HBase或Phoenix,并且Tableau不支持JDBC.糟透了! 我已经阅读了有关Simba专有驱动程序的信息,但尚未看到有关使用它的人的任何报道.在不理想的时候,我不想花钱,而我的雇主也有同样的感觉. 是否存在将Tableau连接到HBase或Phoenix的另一种方法?别人如何做?我不喜欢使用Hive连接到HBase的想法,因为离开Hive的主要原 ..
发布时间:2020-05-19 20:15:13 其他开发