基础术语
中文 释义 API 应用程序编程接口，是一些预先定义的函数，或指软件系统不同组成部分衔接的约定。API 分组 用于将 API 进行逻辑的分组，同个分组下的 API 使用相同的分组标识做隔离。分组标识 是网关全局的唯一标识，用于定位在访问的 API。...
使用JDBC Connector导入
二者对Flink中以不同方式写入ClickHouse Sink的支持情况如下：API名称 flink-jdbc flink-connector-jdbc DataStream 不支持 支持 Table API(Legacy)支持 不支持 Table API(DDL)不支持 不支持 flink-connector-jdbc完全移除了对Table API...
接入VNode（手动）
kubeconfig的内容示例如下：TLS Bootstrap apiVersion:v1 kind:Config current-context:kubernetes-admin@kubernetes contexts:name:kubernetes-admin@kubernetes context:cluster:kubernetes-admin@kubernetes user:vnode namespace:kube-...
简介
API 应用程序编程接口 用户开放API，在API网关录入API，以提供接口的方式对外提供服务或者数据。Group API Group API分组 一组API。用户开放API，首先需要创建API分组 每个API分组拥有一个二级域名，两个Stage 用户需要将已经备案且解析至...
使用Flink SQL消费实时变更数据示例
Table API接入方式 Table API是Flink提供的API接口，支持使用Flink SQL进行数据查询。Lindorm CDC的变更消息采用Debezium Format格式。Table API支持Debezium-Json格式，相关内容请参见 解析说明。如果您在开源Flink上消费数据，需要配置...
模拟IDC Spark读写MaxCompute实践
datasource-v2.3/libs/cupid-table-api-1.1.5-SNAPSHOT.jar,${project.dir}/spark-datasource-v2.3/libs/table-api-tunnel-impl-1.1.5-SNAPSHOT.jar \-class DataReaderTest \${jar-path} \${maxcompute-project-name} \${aliyun-access-...
概述
如下功能时序图，以设备的应用程序./demos/bootstrap_posix_demo.c 为例，介绍应用程序实现该功能的流程。设备分发功能API的更多信息，请参见 aiot_bootstrap_api.h。使用示例 设备分发 功能的参考示例，请参见 使用示例。设备分发 功能...
使用示例
本文以C Link SDK中的Demo文件./demos/bootstrap_posix_demo.c 为例，介绍如何调用Link SDK的API，实现设备的分发功能。背景信息 设备分发功能的更多信息，请参见 概述。通过设备分发功能获取设备接入信息后，可将设备接入物联网平台。MQTT...
对接MaxCompute常见问题与诊断
set hg_experimental_enable_access_odps_with_table_api=on;报错：ERROR:not an ORC file 查询外部表时报错：ERROR:status { code:SERVER_INTERNAL_ERROR message:"hos_exception:Invalid argument:./././src/OrcFileMetaHelper.cc(234)-...
从Flink导入数据至ClickHouse
本文为您介绍如何将Flink中的数据导入至ClickHouse集群。前提条件 已创建Flink集群，详情请参见 创建集群。已创建ClickHouse集群，详情请参见 创建ClickHouse集群。背景信息 关于Flink的更多介绍，请参见 Apache Flink。...
元数据仓库共享模型（MaxCompute）
dim_dataphin_service_app APP表 dim_dataphin_service_logic_unit_column 已上线服务单元字段表 dim_dataphin_service_app_api APP与API对应关系表 dws_dataphin_service_api_mi 数据服务API调用分钟级别汇总表 dim_dataphin_service_api_...
继承
本文介绍了继承的相关内容。简介 本数据库实现了表继承，这对数据库设计者来说是一种有用的工具。让我们从一个例子开始：假设我们要为城市建立一个数据模型。...在决定使用旧继承进行分区是否对应用程序有用时，需要非常小心。
使用Flink写入数据（Transaction Table2.0）
import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;import org.apache.flink.table.data.RowData;public class Examples { public static void main(String[]args)throws Exception { StreamExecutionEnvironment env...
元数据仓库共享模型（Hadoop）
dim_dataphin_service_app APP表 dim_dataphin_service_logic_unit_column 已上线服务单元字段表 dim_dataphin_service_app_api APP与API对应关系表 dws_dataphin_service_api_mi 数据服务API调用分钟级别汇总表 dim_dataphin_service_api_...
通过Kafka导入数据
database.server.name=test123#需要同步的数据库和表，默认是同步所有数据库和表 database.include.list=test table.include.list=test.test_table database.history.kafka.bootstrap.servers=localhost:9092#用于存储数据库表结构变化的 ...
快速入门
records=[[111,'aaa'],[222,'bbb'],[333,'ccc'],[444,'中文']]o.write_table(table,records)#读取非分区表my_new_table中的数据。for record in o.read_table(table):print(record[0],record[1])#以运行SQL的方式读取表中的数据。result=o....
Hudi
API种类 Datastream和SQL 是否支持更新或删除结果表数据 是 特色功能 类别 详情 Hudi的核心特性 支持ACID：支持ACID语义，默认提供SNAPSHOT ISOLATION隔离级别。支持UPSERT语义：UPSERT语义是INSERT和UPDATE两种语义的合并。在UPSERT语义时...
区域统计
create area table CREATE TABLE regions(`rID` INT,`rName` STRING,`fence` GEOMETRY,PRIMARY KEY(`rID`)NOT ENFORCED)WITH('connector'='lindorm','seedServer'='宽表HBase Java API访问地址>','userName'='root','password'='test_...
快速入门
Lindorm Ganos时空服务提供了流引擎接口，适用于车联网、物联网、自动驾驶等场景。您可以通过Lindorm流引擎的实时计算和分析能力处理轨迹点数据，并结合时空函数，实现多种实时轨迹分析需求，例如电子围栏、区域统计、轨迹生成等。前提条件...
使用Kafka（离线与实时）
CREATE TABLE IF NOT EXISTS table_flatten(topic STRING,`partition` BIGINT,`offset` BIGINT,A BIGINT,B STRING,C JSON)PARTITIONED BY(pt STRING);配置并启动Kafka-connector服务 以Linux环境为例，在命令窗口执行以下命令或 下载链接，...
管理Kafka JSON Catalog
CREATE TABLE IF NOT EXISTS `some_catalog`.`some_database`.`some_table1` AS TABLE `kafka-catalog`.`kafka`.`topic1`/*+OPTIONS('scan.startup.mode'='earliest-offset')*/;CREATE TABLE IF NOT EXISTS `some_catalog`.`some_database`...
Upsert Kafka
numRecordsOut numRecordsOutPerSecond numBytesOut numBytesOutPerSecond currentSendTime API种类 SQL 是否支持更新或删除结果表数据 是 前提条件 您需要创建Kafka集群，详情请参见 创建DataFlow Kafka集群 或 在Kafka创建资源。...
通过Kafka写入数据
注意事项 如果您的应用部署在ECS实例，且想要通过专有网络访问Lindorm实例，则需要确保Lindorm实例和ECS实例满足以下条件，以保证网络的连通性。所在地域相同，并建议所在可用区相同（以减少网络延时）。ECS实例与Lindorm实例属于同一专有...
轨迹生成
注意事项 如果应用部署在ECS实例，通过专有网络访问Lindorm实例前，需要确保Lindorm实例和ECS实例满足以下条件，以保证网络的连通性。所在地域相同，并建议所在可用区相同（以减少网络延时）。ECS实例与Lindorm实例属于同一专有网络。步骤...
GetMetaTableBasicInfo
调用GetMetaTableBasicInfo接口获取表的基础信息。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。请求参数 名称 类型 是否必选 示例值 描述 Action String...
UpdateMetaTable
调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。请求参数 名称 类型 是否必选 示例值 描述 Action String 是 UpdateMetaTable 系统规定参数。取值：...
消息队列Kafka
API种类 SQL和Datastream 是否支持更新或删除结果表数据 不支持更新和删除结果表数据，只支持插入数据。说明 如果您需要更新和删除结果表数据，相关功能请参见 Upsert Kafka。前提条件 您可以根据需求选择以下任意一种方式连接集群：连接...
DescribeAppliedAdvices-显示已采纳的优化
调用DescribeAppliedAdvices接口来显示已应用的优化建议。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。调试 授权信息 下表是API对应的授权信息，可以在...
使用Kafka Connect将SQL Server数据同步至云消息队列 ...
所有table的变更数据，会记录在server1.$DATABASE.$TABLE的topic中，例如server1.testDB.products。因此您需要提前在云消息队列 Kafka 版控制台中创建所有相关Topic。database.server.name":"server1",#记录schema变化信息将记录在该Topic...
建表语句
本文为您介绍Spark SQL建表语法。语法 CREATE TABLE tbName[(columnName dataType[,columnName dataType]*)]...CREATE TABLE kafka_table USING kafka OPTIONS(kafka.bootstrap.servers="${BOOTSTRAP_SERVERS}",subscribe="${TOPIC_NAME}");
流式入库
use-emr-datasource SQL CREATE TABLE IF NOT EXISTS kafka_table USING kafka OPTIONS(kafka.bootstrap.servers='192.168.XX.XX:9092',subscribe='delta_stream_sample');CREATE TABLE IF NOT EXISTS delta_table(id LONG,`date` DATE,...
TableStore数据源
建表语法 CREATE TABLE tbName USING tablestore OPTIONS(propertyName=propertyValue[,propertyName=propertyValue]*);Table Schema 创建TableStore表时，无需显式定义表的字段信息，示例如下。CREATE DATABASE IF NOT EXISTS default;USE...
API 属性说明
应用以及 mPaas 移动应用：表示 API 发布后支持 web 浏览器、H5 容器、小程序、JS、业务系统的调用，同时也支持 mPaaS 移动客户端（iOS、Android）的调用。OperationType 是 针对 mPaaS 移动应用设置的 API 服务标识，用于定位要访问的资源...
设备分发
相关API API 描述 CreateDeviceDistributeJob 创建设备分发任务，默认同时分发设备所属产品。CreateProductDistributeJob 创建产品分发任务，分发指定产品到指定的目标实例。QueryDeviceDistributeDetail 获取设备分发任务执行完成后的结果...
SQL脚本模式
Script Mode的SQL语句书写便利，您只需要按照业务逻辑，用类似于普通编程语言的方式书写，无需考虑如何组织语句。语法结构-set set odps.sql.type.system.odps2=true;[set odps.stage.reducer.num=xxx;[.]-ddl create table table1 xxx;...
RegisterLineageRelation
xxx 根据用户需求，推荐使用如下类型(1)表：custom-table(2)API：custom-api(3)应用：custom-app(4)报表：custom-report(5)数据集：custom-dataset(6)数据源：custom-datasource 2:EntityGuid：在同一实体类型内部，唯一标识该实体的标识 ...
基础使用
CREATE TABLE IF NOT EXISTS kafka_topic USING kafka OPTIONS(kafka.bootstrap.servers="${BOOTSTRAP_SERVERS}",subscribe="${TOPIC_NAME}");说明 上述代码中的 kafka.bootstrap.servers 为Kafka集群中任一Kafka Broker组件的内网IP地址和...
Hive指标
Hive指标包含以下部分：HIVE-HiveServer2 HIVE-MetaStore HIVE-HiveServer2 参数 指标 描述 JVM MemHeapInit hive_server_memory_heap_init JVM初始化堆内存。单位：Byte。JVM MemHeapCommitted hive_server_memory_heap_committed JVM已...
作业上线问题
2478)at org.apache.flink.table.sqlserver.api.client.FlinkSqlServerProtoClientImpl.generateJobGraph(FlinkSqlServerProtoClientImpl.java:456)at org.apache.flink.table.sqlserver.api.client.ErrorHandlingProtoClient.lambda$...
Python SDK示例：Table
table=o.get_table('my_new_table')if table.schema.partitions:print('Table%s is partitioned.'%table.name)遍历表全部分区。table=o.get_table('my_new_table')for partition in table.partitions:#遍历所有分区 print(partition.name)#...
- 产品推荐
- 这些文档可能帮助您