问题标签 [apache-calcite]

我正在尝试使用 Calcite 在同一查询中查询 MySql 和 Vertica：

MySql 表：CREATE TABLE tableA (id INT(11), name VARCHAR(5), PRIMARY KEY(id));

立式桌：CREATE TABLE tableB (id INTEGER NOT NULL, name VARCHAR(20), PRIMARY KEY (id));

使用 Calcite 运行以下查询时：

我越来越：

转换 MySql 表中的 id 列可以解决它，但我无法转换，因为我正在处理无法更改的现有表。

关于如何解决这个问题的任何想法？

谢谢

我正在使用 Calcite 从 MySql 和 Vertica 进行查询。

运行此查询时：

出于某种原因，我看到 Calcite 使用正确的谓词正确访问 tableA，但SELECT * FROM verticaschema.tableB由于某种原因它在第二个表上做。

有没有办法优化它，所以 Calcite 也会b.id=1在 tableB 上运行谓词？

谢谢

我没有找到任何第一手资料，方解石能否以类似于https://devth.com/2017/compiled-queries-in-scala的方式处理一般 Scala 案例类？

我正在尝试公开大型机文件，以便从 COBOL 程序和 Java 中的外部程序中更动态地使用。

我的阅读表明我可以将 COBOL 配置为使用 JDBC 连接。这可能只是 JCL 中的配置，但我认为它更像是一个预处理。

我还发现 JzOS 库将提供从 JAVA 访问 VSAM 数据存储本身的权限。

所以从技术上讲，我认为这是可能的，但找不到一个帖子。我知道这将成为一个边缘案例，但我喜欢 Calcite 将这些作为标准 JDBC 对象公开的想法。

想法？问题 ？担忧？

我目前正在做一个项目来扩展 SQL 的功能，以支持更多基于 Apache Flink 的流计算功能。

经过大量搜索，我发现 Calcite 是一个很好的工具，可以帮助我解析、验证和优化这些 SQL 查询，但是 Calcite 的流式支持仍然不成熟，所以我必须对其进行改进以满足我的需求。

因此，我想知道是否有办法添加自定义子句，例如

它使用 PARAMS 来定义如何从 Kafka 连接器接收数据，并将其视为动态表作为 Flink 的数据源。

由于这方面的信息很少，如果有人能提供一些提示，我将不胜感激。

谢谢 ： ）

我正在使用elasticsearch version-6.1.1。我已经下载了方解石框架项目并按照（https://calcite.apache.org/docs/tutorial.html）上的教程在我的机器中构建它，当我尝试连接时使用此处给出的方解石的 Elasticsearch2adaptor 进行弹性搜索（https://calcite.apache.org/docs/elasticsearch_adapter.html）。我收到以下错误 错误：

这是 mymodel.json 文件：

需要有关 apache 方解石的建议。我们在 Teradata 上运行了一些 SQL 查询。现在我们想在 Hadoop/Spark 上运行这些 sql 查询（原样），也许使用 Apache calcite。

我们在 Spark SQL (2.6.3) 和 Apache calcite 中尝试了这些 SQL 查询（原样） - 但很少有查询不运行。问题是如果我们定义一个派生变量 (AS) 并尝试在同一级别的同一查询中使用它，它在 SparkSQL 和 calcite 中不起作用，但在 Teradata 中起作用。示例查询：

但是这在 SparkSQL 和 Calcite 中不起作用。引发以下错误：

执行 SQL 时出错“选择 EMPNO, sum(deptno) as sum_dept, case when sum_dept > 10 then 1 else 0 end as tmp from emps group by EMPNO”：从第 1 行第 50 列到第 1 行第 57 列：列'SUM_DEPT ' 在任何表中都找不到 (state=,code=0)

有人（SparkSQL/Calcite 专家）知道是否有办法让它在 sparkSQL 或方解石中工作？

我正在尝试使用 apache calcite geode 采用者连接 Gemfire 8.2。根据以下日志，它已正确连接，但在尝试执行查询时出现异常。

注意：http ://calcite.apache.org/news/2018/03/19/release-1.16.0/

此外，此版本中添加了一个从 Apache Geode 读取数据的新适配器。此外，现有适配器也取得了更多进展

1) 连接类

2）JSON“myModel.json”

罐子

Gemfire 8.2（晶洞）

使用此查询时出现以下异常

(1) ResultSet resultset = statement.executeQuery("select * from account");

例外 ：

2）当使用以下样式时，出现以下异常

例外 ：

更新

我已经尝试过 Christian 提供的旧代码和 git 示例代码与 Gemfire 9.0 和 9.2.2，但得到相同的异常

1) git 中的示例

2）git中的例子

我正在尝试使用 avatica jar 连接到 druid 数据库以下是代码。

我收到以下异常，有人可以告诉我出了什么问题吗？我已将运行时属性设置为启用 sql。

我正在尝试实现Apache Beam 文档中的 DSL API 示例。我正在使用最新版本的 apache 梁库 (2.4.0)

我正在运行的代码与文档中的代码相同：

这总是失败并出现以下错误：

运行此测试的正确方法是什么，或者这是一个错误并且 dsl api 不起作用？