Apache Calcite -似乎无法解析DDL语句
Apache Calcite是一个开源的动态数据管理框架，它提供了一种统一的方式来解析、优化和执行SQL查询。它可以与各种数据源集成，包括关系型数据库、NoSQL数据库、文件系统等。
Apache Calcite的主要特点和优势包括：
- 动态查询优化：Calcite可以根据查询的特性和数据源的特点，动态地优化查询计划，以提高查询性能。
- 多数据源支持：Calcite支持与多种数据源的集成，包括关系型数据库（如MySQL、PostgreSQL）、NoSQL数据库（如MongoDB、Elasticsearch）、文件系统（如HDFS、S3）等。
- 扩展性：Calcite提供了灵活的扩展机制，可以自定义和添加新的优化规则、数据源适配器等，以满足不同场景下的需求。
- SQL兼容性：Calcite支持标准的SQL语法，并且提供了一些扩展功能，如窗口函数、聚合函数等，使得开发人员可以使用熟悉的SQL语言进行数据查询和处理。
- 社区活跃：作为Apache软件基金会的项目，Calcite拥有一个活跃的社区，提供了丰富的文档、示例和支持。
Apache Calcite的应用场景包括：
- 数据集成和查询：通过Calcite可以将多个数据源进行统一管理，实现跨数据源的查询和分析。
- 数据仓库和OLAP：Calcite可以与OLAP引擎（如Apache Kylin）结合，提供高性能的多维分析能力。
- 实时数据处理：Calcite可以与流处理引擎（如Apache Flink、Apache Kafka）结合，实现实时数据的查询和分析。
- 数据虚拟化：通过Calcite可以将分布在不同数据源中的数据虚拟化为一个统一的视图，简化数据访问和管理。
腾讯云相关产品中与Apache Calcite相关的产品和服务暂无明确信息。您可以参考Apache Calcite的官方网站（https://calcite.apache.org/）获取更多详细信息和文档。
相关·内容
1回答
当我尝试验证包含"CREATE TABLE“的sql语句时，它抛出一个错误： java.lang.AssertionError: Was not expecting value 'CREATE_TABLE' for enumeration 'org.apache.calcite.sql.SqlKind' in this context
at org.apache.calcite.util.Util.unexpected(Util.java:1773)
at org.apache.calcite.sql.validate.SqlVali
浏览 33提问于2019-12-16得票数 1
回答已采纳
我有一个项目，需要使用方解石的SQL Parser来解析大量的MySQL方言中的动态链接库语句。
我已经隔离了一个问题，可以用这个具体的例子来说明：
create table `t1` (x int(11))
敏锐的读者可能会认出int(11)是MySQL方言。我需要能够解析它。删除本例中的(11)不是可接受的修复方法。
下面是一个重现这个问题的Java JUnit测试：
public class SqlParserMysqlTest {
private static final Config CONFIG = SqlParser.Config.DEFAULT
.wi
浏览 44提问于2020-11-16得票数 0
我正在运行这个beam tutorial的简化版本，但是在我的本地机器上使用DirectRunner运行它。 import apache_beam as beam
from apache_beam.transforms.sql import SqlTransform
import os
with beam.Pipeline() as p:
rows = (p |
beam.Create([
beam.Row(col1="val1", col2="col2_val1"),
浏览 29提问于2021-09-01得票数 0
回答已采纳
在处理依赖项(根据问题)时，应该使用依赖项中链接的存储库。不幸的是，这在我的情况下没有发生。
我的项目有依赖org.apache.calcite:calcite-avatica:1.0.0-incubating。方解石-avatica的pom需要依赖eigenbase:eigenbase-properties:1.1.4，并在<repositories>中添加了conjar存储库，因为这是唯一可以找到特征基属性1.1.4的地方。当我试图构建这个项目时，我会得到一个错误：
找不到伪影特征基:特征基:pom:1.1.4在中心()
为什么没有从conjar存储库中提取eigenbase
浏览 22提问于2022-02-09得票数 0
3回答
我需要向Calcite添加一个用户定义的函数，该函数接受一个整数作为参数并返回一个整数。
public class SquareFunction {
public int eval(int a) {
return a*a;
}
}
创建模式并添加函数的相关代码为
SchemaPlus rootSchema = Frameworks.createRootSchema(false);
rootSchema.add("SQUARE_FUNC",
Sc
浏览 50提问于2017-05-24得票数 7
我希望实现一个org.apache.calcite.schema.Table，它既可以用作流，也可以用作表。
我正在浏览方解石文档，提到了Orders表的一个例子，它既是流又是表。它还提到，以下两个查询都适用于此Orders表/流，
SELECT STREAM * FROM Orders;
和
SELECT * FROM Orders;
我正在尝试实现一个类，其实例就是这样的表。我实现了接口和接口，但仍然无法让它以两种方式工作。当我尝试执行非流查询(如SELECT * FROM TEST_TABLE)时，我得到以下错误：
Caused by: org.apache.calcite.runtim
浏览 15提问于2022-01-31得票数 0
我试图在同一个查询中使用方解石查询MySql和Vertica：
MySql表：CREATE TABLE tableA (id INT(11), name VARCHAR(5), PRIMARY KEY(id));
Vertica表：CREATE TABLE tableB (id INTEGER NOT NULL, name VARCHAR(20), PRIMARY KEY (id));
使用方解石运行以下查询时：
statement.executeQuery(
"SELECT a.\"name\", b.\"name\" "
浏览 2提问于2017-11-15得票数 0
回答已采纳
我试图设置一个Maven项目，该项目将包含我希望在Hive查询中使用的用户定义函数(UDF)。我从一个不包含任何源文件的Maven项目开始，下面的POM：
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.
浏览 10提问于2014-12-30得票数 5
我正在试用shell中的BeamSQL，并想测试无界源代码在可用性和性能方面是如何工作的。通过阅读here上的文档，我创建了一个外部表，如下所示- CREATE EXTERNAL TABLE pubsub_table (event_timestamp TIMESTAMP, attributes MAP<VARCHAR, VARCHAR>, payload ROW<id INTEGER, location VARCHAR>)
TYPE pubsub
LOCATION 'projects/test-project/topics/test-topic'; 现
浏览 23提问于2019-05-16得票数 1
回答已采纳
1回答
我正在试着从我的abc表中读取数据，abc是在蜂巢中使用钻头的。为此，我使用下面提到的配置创建了单元存储插件。
{
"type": "hive",
"enabled": true,
"configProps": {
"hive.metastore.uris": "thrift://<ip>:<port>",
"fs.default.name": "hdfs://<ip>:<port>/",
"hive.metas
浏览 3提问于2018-06-28得票数 0
我正在尝试使用PreparedStatement占位符作为SQL聚合函数的参数。如果我用一个数值替换?占位符并去掉setDouble调用，查询就能正常工作。
public static String QUERY = """
SELECT DS_GET_QUANTILE(DS_QUANTILES_SKETCH("logins"), ?) as "rank"
FROM (SELECT ip, sum("login-counts") AS "attempts
浏览 2提问于2021-03-15得票数 2
回答已采纳
1回答
下面有一个beamSql查询：
PCollectionTuple query0 = PCollectionTuple.of(
new TupleTag<BeamRecord>("temp2"), temp2).and(new TupleTag<BeamRecord>("temp3"), temp3)"));
PCollection<BeamRecord> rec_3 = query0.apply(
BeamSql.queryMulti(&
浏览 0提问于2018-07-09得票数 0
回答已采纳
我有一个定义为2字段的表:整数id，varchar名称
我可以像这样执行常见的查询：
ResultSet resultSet = statement.executeQuery("select \"id\",\"name\" from test.test01 where \"id\" in (1,2)");
现在，我希望在select语句中使用"if“条件，执行以下查询：
ResultSet resultSet = statement.executeQuery("select \"id\",IF(\&
浏览 6提问于2022-09-05得票数 1
回答已采纳
org.apache.kylin.jdbc.KylinMeta.prepareAndExecute (Lorg/apache/calcite/avatica/Meta$ConnectionHandle;Ljava/lang/String;ILorg/apache/calcite/avatica/Meta$PrepareCallback;)Lorg/apache/calcite/avatica/Meta$ExecuteResult；org.apache.calcite.avatica.AvaticaConnection.prepareAndExecuteInternal(AvaticaConne
浏览 1提问于2017-08-30得票数 0
1回答
我试图使用Apache方解石查询Postgres。我可以通过方解石JDBC驱动程序阅读有关数据库的元数据，所以我肯定能够连接到它，但是每当我查询一个表时，方解石总是用‘没找到表x’来响应。如果我将代码改为使用Hsqldb，则一切正常。下面是代码(改编自这个方解石测试用例：)
package org.apache.calcite;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.S
浏览 4提问于2016-06-07得票数 6
回答已采纳
我是Apache Drill的新手。我需要使用Apache Drill查询我的PostgreSQL数据库。我浏览了，可以为我的Postgres数据库配置一个存储插件。
{
"type": "jdbc",
"driver": "org.postgresql.Driver",
"url": "jdbc:postgresql://localhost/mydb",
"username": <username>,
"password":
浏览 1提问于2017-09-11得票数 0
2回答
我正在尝试创建一个基本的流程序与方解石使用CSV的数据源。我可以运行查询与sqlline，但我不能通过编程来做。我的代码是：
example.json
{
version: '1.0',
defaultSchema: 'STREAM',
schemas: [
{
name: 'SS',
tables: [
{
name: 'ORDERS',
type: 'custom',
factory:
浏览 0提问于2016-09-04得票数 1
回答已采纳
我编写了一个适配器，并添加了一些规则来向下推谓词。
但是，当我添加FilterRule以向下按压过滤器时，测试中出现了以下问题：
Caused by: java.lang.ClassCastException: org.apache.calcite.plan.volcano.RelSubset cannot be cast to org.apache.calcite.plan.hep.HepRelVertex
at org.apache.calcite.plan.hep.HepPlanner.addRelToGraph(HepPlanner.java:840)
at org.a
浏览 2提问于2020-01-07得票数 0
回答已采纳
我目前正在尝试用方解石连接mysql。但是，我在执行SQL语句时遇到问题。
当我使用这个sql来执行时，它是有效的。
ResultSet resultSet = statement.executeQuery( "select * from ex.depts")；
但是我想访问一个名为"primary_test“的表，它失败了。
在执行SQL "select * from ex.primary_test“时出现线程"main”ex.primary_test: Error中的异常:从第1行第15列到第1行，第29栏:在org.apache.calc
浏览 1提问于2019-02-26得票数 0
回答已采纳
我使用maven-assembly-plugin创建了一个Scala应用程序的jar。现在，当我使用java -jar path\to\jar\myapp.jar执行jar时，它抛出了以下错误： Exception in thread "main" Exception in thread "Timer-0" java.lang.RuntimeException: java.sql.SQLException: No suitable driver found for jdbc:calcite:
at org.apache.calcite.tool
浏览 80提问于2019-01-19得票数 0
回答已采纳
我在使用方解石的时候收到了NPE。我的代码如下
@Autowired
public CalciteBootstrap(DatasourceProvider datasourceProvider) throws SQLException {
this.datasource = datasourceProvider.fetchDatasource();
log.debug("Datasource fetched - {}", datasource);
this.connection = createRootSchema();
this.schema
浏览 0提问于2017-09-28得票数 0
我有一个在本地运行良好的Flink作业，但是当我尝试在集群上flink run作业时失败了。它基本上是读卡夫卡，做一些转换，并写到一个水槽。当试图通过'connector' = 'kafka'从Kafka加载数据时，会发生错误。
这是我的pom.xml，包括flink-connector-kafka。
<!--
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements. See the NOTICE file
dist
浏览 16提问于2021-03-10得票数 0
回答已采纳
1回答
我试着用方解石做一些基本的事情来理解这个框架。我已经设置了一个简单的示例，它应该从2个json文件中读取。我的模特看起来
{
version: '1.0',
defaultSchema: 'PEOPLE',
schemas: [
{
name: 'PEOPLE',
type: 'custom',
factory: 'demo.JsonSchemaFactory',
operand: {
directory: '/..../c
浏览 4提问于2015-06-29得票数 2
回答已采纳
在Hadoop 3.2.0上运行hive 3.1.1时，使用以下命令运行'select * from employee‘时崩溃
java.lang.IncompatibleClassChangeError: Class com.google.common.collect.ImmutableSortedMap does not implement the requested interface java.util.NavigableMap
像show tables这样的命令都运行得很好，而且从命令行界面加载数据也是正常的。
已检查各种其他命令，例如已加载数据等。使用MySQL作为MySQ
浏览 24提问于2019-04-02得票数 3
1回答
我在尝试通过Java Web App执行getConnection时遇到以下错误。有人遇到过这个问题吗？
com.fasterxml.jackson.databind.JsonMappingException: Class
org.apache.calcite.avatica.remote.Service$ResultSetResponse not subtype of
[simple type, class
org.apache.calcite.avatica.remote.Service$RpcMetadataResponse]
at [Source: {"response&
浏览 3提问于2018-11-29得票数 1
我有菲尼克斯，它与HBase集成。我正在尝试使用pythondb库从python代码中访问凤凰城，并且我已经使用
bin/queryserver.py start
但是，在connect语句之后，我得到以下错误：
database_url = 'http://localhost:8765/'
conn = phoenixdb.connect(database_url, autocommit=True)
InternalError：(“找不到解析器”，“无，无，无”)
这是日志中的错误：
2016-08-10 14:24:07,987警告org.eclipse.jetty.se
浏览 1提问于2016-08-10得票数 0
回答已采纳
尝试使用apache sql中的聚合函数ApproximateDistinct.ApproximateDistinctFn，但失败了。 我的SQL： SELECT
ApproximateDistinct(user_id) as distinct_count,
profile,
country_code,
FROM PCOLLECTION
GROUP BY profile,country_code 以及我在Apache-Beam中调用此查询的代码： events.apply(SqlTransform.query(query)
浏览 16提问于2019-04-08得票数 0
我正在使用elasticsearch版本-6.1.1.我已经下载了方解石框架项目并在我的机器中构建了它，遵循了的教程，并且当我试图使用给定的方解石Elasticsearch2adaptor连接到elasticsearch时(得到了以下错误错误：)
*E:\calcite\elasticsearch2>sqlline
sqlline version 1.3.0
sqlline> !connect jdbc:calcite:model=target/test-classes/mymodel.json admin admin
SLF4J: Failed to load class
浏览 0提问于2018-01-19得票数 1
回答已采纳
1回答
我想确保flink在设置方面起作用，然后尝试使使用复杂化。在最简单的例子中，我试着做这件事。输入包含
column_a，column_b 1,2
输出存在。为了在我的应用程序中使用docker下载pyflink版本的1.10，我使用了以下代码片段：
jobmanager:
image: pyflink/playgrounds:1.10.0
volumes:
- ./examples:/opt/examples
hostname: "jobmanager"
expose:
- "6123"
port
浏览 21提问于2021-07-20得票数 0
我试图在Spark中创建一个Dataframe，它将包含Apache中一个表中的所有记录，并且我正在使用JDBC进行此操作。德鲁伊似乎正在使用方解石-Avatica驱动程序(提到)。
df = spark.read.format('jdbc').option('url', 'jdbc:avatica:remote:url=http://172.31.5.20:8082/druid/v2/sql/avatica/').option('driver', 'org.apache.calcite.avatica.remot
浏览 21提问于2020-10-17得票数 0
我正在尝试使用ReflectiveSchema创建一个简单的模式，然后尝试使用Groovy作为编程语言来投影一个雇员“表”。下面的代码。
class CalciteDemo {
String doDemo() {
RelNode node = new CalciteAlgebraBuilder().build()
return RelOptUtil.toString(node)
}
class DummySchema {
public final Employee[]
浏览 3提问于2017-04-04得票数 1
回答已采纳
我能够获得MongoDB连接，并且能够获得节点
(LogicalTableScan(table=[[enlivenDev, collection1]]))
但是当我执行节点时，我得到了空指针异常。
完整代码：
private void executeMongoDB(){
final FrameworkConfig config = mongoConfig().build();
final RelBuilder builder = RelBuilder.create(config);
final RelNode node = builder.sc
浏览 1提问于2017-07-28得票数 3
我有一个程序可以将一个新患者插入到服务器内的docker容器中的HBase中。在我尝试更改到phoenix查询服务器的连接IP以运行JUnit测试之前，一切都运行正常。我在属性文件中设置URL，如下所示：
java.lang.RuntimeException: com.fasterxml.jackson.core.JsonParseException: Unexpected character ('<' (code 60)): expected a valid value (number, String, array, object, 'true', &#
浏览 1提问于2016-05-05得票数 14
回答已采纳
1回答
我使用Flink流数据，这是在csv文件。我想用特定的模式把它转换成表格格式。为此目的，我使用的是Flink_2.10-1.1.3.jar(表api)，但是我得到了以下错误：
log4j:WARN No appenders could be found for logger (org.apache.flink.api.java.typeutils.TypeExtractor).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/fa
浏览 1提问于2016-12-21得票数 2
2回答
我连接到两个不同的DB，他们的JDBC客户端都需要org.apache.calcite.avatica包，一个使用1.6版，另一个使用1.8版，所以我需要安装这两个版本(1.6和1.8)，并且1.8版似乎与1.6版不兼容，当我使用1.8版而不是1.6版时，抛出了以下异常：
java.lang.AbstractMethodError
org.apache.calcite.avatica.AvaticaConnection.<init>(AvaticaConnection.java:117)
org.apache.kylin.jdbc.KylinConnection.&
浏览 0提问于2016-07-14得票数 0
我正在尝试构建一个从SQL到某种我可以使用我的代码解析和执行的格式的翻译器。是否可以通过Apache Calcite解析查询并获得某种可解析格式的输出，如JSON？
浏览 2提问于2018-11-09得票数 0
在https://calcite.apache.org/docs/tutorial.html之后，我使用SqlLine运行了Apache Calcite。我尝试按照https://calcite.apache.org/docs/howto.html#tracing中的指示激活跟踪。但是，我没有得到任何日志记录。以下是我的会话内容(希望包含所有相关信息)： root@3b8279cda4cd:~/calcite/example/csv# egrep "^[^#]" ../../core/src/test/resources/log4j.properties
log4j.roo
浏览 44提问于2019-06-17得票数 0
回答已采纳
我想使用apache calcite api raw，而不使用jdbc连接。我可以很好地使用jdbc api，但是在尝试使用该api时，我得到了null ptr异常。到目前为止，我所做的是：
package calcite.examples
import java.util.Properties
import calcite.demo.DemoSchema
import org.apache.calcite.DataContext
import org.apache.calcite.config.CalciteConnectionConfigImpl
import org.apache.c
浏览 4提问于2016-03-29得票数 6
1回答
对嵌套数据结构使用行()
、、、
我已经成功地使用了来自flink-json工件的JsonRowSerializationSchema来创建TableSink<Row>，并使用行从SQL输出json。它可以很好地释放平面数据：
INSERT INTO outputTable
SELECT
ROW(col1, col1)
FROM inputTable
>>>> OK:
{"outCol1":"dasdasdas","outCol2":"dasdasdas"}
现在，我正在尝试一个嵌套模式，它以一种奇怪的方式分离开来：
I
浏览 0提问于2019-01-16得票数 2
回答已采纳
我读取了一个csv文件。我想使用一个长类型的列来翻滚。我使用UDF传输长类型到时间戳类型，但是无法工作错误消息:窗口只能在时间属性列上定义。
我试着调试。TimeIndicatorRelDataType不是时间戳，我不知道怎么转，为什么？
def isTimeIndicatorType(relDataType: RelDataType): Boolean = relDataType match {
case ti: TimeIndicatorRelDataType => true
case _ => false
}
码
public static void mai
浏览 0提问于2019-11-27得票数 2
回答已采纳
我正在尝试使用apache方解石geode采用器连接Gemfire 8.2。如下所示，它的连接正常，但在执行查询时得到异常。
注：
此外，在这个版本中添加了一个从Apache读取数据的新适配器。此外，现有的适配器也取得了更大的进展。
1)连接类
package com.khan.vaquar;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLExcepti
浏览 1提问于2018-03-21得票数 0
回答已采纳
我已经在Kafka connect中集成了debezium连接器来流式传输我的mysql数据库更改。对于某些过程，它无法读取binlog文件。有什么建议或变通办法吗？坚持这个问题。我可以在mysql中指定不将ddl日志放到binlog文件中吗？
2017-10-10 15:20:22,314 ERROR MySQL|dbStreamer|binlog Failed due to error: Error processing binlog event [io.debezium.connector.mysql.BinlogReader]
org.apache.kafka
浏览 10提问于2017-10-10得票数 0
final RelBuilder builder = RelBuilder.create(config().build());
RelNode root =
builder.scan("EMP")
.as("e")
.scan("EMP")
.as("m")
.scan("DEPT")
.join(JoinRelType.INNER)
.join(J
浏览 1提问于2017-06-05得票数 1
回答已采纳
我想使用TableAPI定义Kafka连接器，并在这样的表上运行SQL (由Kafka支持)。不幸的是，Rowtime定义似乎并不像预期的那样工作。
下面是一个可重复使用的示例：
object DefineSource extends App {
import org.apache.flink.streaming.api.scala._
import org.apache.flink.table.api.scala._
val env = StreamExecutionEnvironment.getExecutionEnvironment
env.setStreamTime
浏览 8提问于2020-06-01得票数 0
1回答
我从来没有遇到过在RDBMS上创建表的问题。但是这个钻子真的很奇怪，我不能创建新的空表。
我跟踪来创建表，但我不明白为什么它不像
第一：
0: jdbc:drill:zk=local> USE s3XXXXX.dss;
+-------+---------------------------------------------+
| ok | summary |
+-------+---------------------------------------------+
| true | Default s
浏览 0提问于2017-06-11得票数 2
回答已采纳
Apache Calcite似乎有一个有趣的功能，可以解析SQL并使用适配器连接到多个数据源，包括非关系数据源。
我看到了足够多的关于方解石本身开发的文档，但没有将其作为第三方应用程序中的库使用。
我想在我的应用程序中使用Apache Calcite以及它的一些适配器作为库，并使用它的功能。
例如，Apache Drill在其后端使用方解石。第三方应用程序是否可以嵌入方解石并使用其功能？如果是，我该怎么做？谢谢!
浏览 3提问于2016-01-13得票数 3
1回答
我的用例是接受Azure Synapse DW DDL作为输入，解析它并从中提取SQL语句。此外，我不仅可以受益于基语句(即，声明、创建、更改、选择、.)还有其他DDL结构，如PK约束、索引、分发、分区等。
去了解是否有一种已知的方法来实现这一点？事先非常感谢。
我尝试过的事情：
(所有8个可用版本80、90、100、110、120、130、140、150)，但它无法解析DDL并在少数特定于DW的令牌上出错。
将自定义的传递给TSqlFragment，但它也没有检测到Create语句(虽然它可以访问SELECT语句，但这里的DDL中没有显示)
使用从DDL读取SQ
浏览 4提问于2020-12-30得票数 3
我使用Apache Calcite解析一个简单的SQL语句并返回它的关系树。我使用到一个简单的SQLite数据库的JDBC连接获得了一个数据库模式。然后使用FrameworkConfig添加该模式。然后修改解析器配置以处理标识符引用和大小写(不敏感)。但是，SQL验证器无法在SQL语句中找到带引号的表标识符。不知何故，解析器忽略了配置设置，并将表转换为大写。将引发SqlValidatorException，声明找不到表名。我怀疑，配置没有正确更新？我已经验证了表名是否正确地包含在模式的元数据中。
公共类ParseSQL {
public static void main(String[] ar
浏览 7提问于2016-01-22得票数 0
我正在尝试使用avatica jar连接到德鲁伊数据库，下面是代码。
String url = "jdbc:avatica:remote:url=http://localhost:8082/druid/v2/sql/avatica";
Properties connectionProperties = new Properties();
try (Connection connection = DriverManager.getConnection(url, connectionProperties))
{
try (
final Statem
浏览 1提问于2018-04-06得票数 0
我正在使用下面的方法查询我的HBase，这个查询有一个嵌套的查询，问题是当使用setString()方法添加内联参数时，它是不是替换了？在查询中。
我得到了一个例外
参数值未绑定。索引1处的参数是无界的。
我正在使用菲尼克斯queryserver和avatica驱动程序连接到我的HBase。
以下是我的职责。
public ResultSet getTopRiskEntitiesCount(String tenantId, String entityType){
ResultSet resultSet = null;
try{String query =
浏览 0提问于2019-07-12得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
