CDC问题
使用MySQL CDC，增量阶段读取出来的timestamp字段时区相差8小时，怎么回事呢？MySQL CDC支持监听从库吗？从库需要如何配置？怎么获取数据库中的DDL事件？Flink CDC支持MySQL整库同步吗？怎么做？同一个实例下，某个库的表无法同步增量数据...
基于HBase Java API的应用开发
所有的数据将存储在同一个分区中，无法实现在多个分区间的并行处理和负载均衡。这可能导致性能瓶颈和数据热点问题。admin.createTable(htd);如果需要创建多个分区的表/示例如下，预分区包含两个分区，分别为:[-∞,10),[10,∞),实际使用时请...
UDT示例
Java中实现 java.util.List 或 java.util.Map 接口类的对象，都可参与MaxCompute SQL的复杂类型操作。MaxCompute中ARRAY或MAP的数据，能够直接调用List或者MAP的接口。set odps.sql.type.system.odps2=true;set odps.sql.session.java....
Java UDTF
MaxCompute Type Java Type Java Writable Type TINYINT java.lang.Byte ByteWritable SMALLINT java.lang.Short ShortWritable INT java.lang.Integer IntWritable BIGINT java.lang.Long LongWritable FLOAT java.lang.Float ...
Java UDAF
MaxCompute Type Java Type Java Writable Type TINYINT java.lang.Byte ByteWritable SMALLINT java.lang.Short ShortWritable INT java.lang.Integer IntWritable BIGINT java.lang.Long LongWritable FLOAT java.lang.Float ...
UDF开发（Java）
MaxCompute Type Java Type Java Writable Type TINYINT java.lang.Byte ByteWritable SMALLINT java.lang.Short ShortWritable INT java.lang.Integer IntWritable BIGINT java.lang.Long LongWritable FLOAT java.lang.Float ...
UDT概述
例如，只需调用一次Java内置类的方法即可实现，但MaxCompute却没有提供简单的方法实现这个功能。如果使用UDF实现，整个过程会过于繁杂。SQL中需要调用第三方库实现相关功能。希望能够在SQL中直接调用，而不需要再Wrap一层UDF。SQL中需要...
函数实例生命周期回调方法
Initializer回调只有一个 context 输入参数，使用方法同事件请求处理程序。使用Initializer回调需要继承 FunctionInitializer接口，并实现该接口的 initialize 方法，接口定义如下。package com.aliyun.fc.runtime;import java.io....
函数实例生命周期回调方法
Initializer回调只有一个 context 输入参数，使用方法同事件请求处理程序。使用Initializer回调需要继承 FunctionInitializer接口，并实现该接口的 initialize 方法，接口定义如下。package com.aliyun.fc.runtime;import java.io....
DBCP 连接池连接 OceanBase 数据库示例程序
本文将介绍如何使用 DBCP 连接池、MySQL Connector/J 和 OceanBase 数据库构建一个应用程序，实现基本的数据库操作，包括创建表、插入、删除、更新和查询数据等。点击下载 dbcp-mysql-client 示例工程 前提条件 您已安装 OceanBase 数据库...
约束规范
服务发布的参数名：只能使用数字，字母和下划线（_）。协议转换种类 CSB支持常用协议服务的接入和开放（RESTful/SpringCloud/HSF/WebService/Dubbo/JDBC），可扩展支持定制化的协议转换。服务接入：在CSB上注册某个服务并且提供足够的信息...
常见报错
若您希望将多个Key写入到一个Slot中，您可以使用Hash Tags，但该方法若使用不当容易造成数据倾斜，请谨慎使用，更多信息请参见 Hash tag。ERR for redis cluster,eval/evalsha number of keys can't be negative or zero 可能原因：执行 ...
常见报错
若您希望将多个Key写入到一个Slot中，您可以使用Hash Tags，但该方法若使用不当容易造成数据倾斜，请谨慎使用，更多信息请参见 Hash tag。ERR for redis cluster,eval/evalsha number of keys can't be negative or zero 可能原因：执行 ...
为应用配置路由规则（MSE）
如果您的业务请求需要分发给其他服务或者应用，您可以为应用配置网关路由功能，实现请求路由分发。本文介绍如何通过 微服务引擎 MSE（Microservices Engine）云原生网关为您的应用设置路由规则。背景信息 MSE 云原生网关兼容K8s Ingress，...
构造请求
说明 当使用GET方法提交请求时，这些参数就是请求URL中的参数部分，即URL中?之后由&连接的部分。编码参数。使用UTF-8字符集按照RFC3986规则编码请求参数和参数取值，编码规则如下：字符A~Z、a~z、0~9以及字符-、_、.不编码。其它字符...
函数实例生命周期
函数实例生命周期回调方法 Java 通过Java运行时实现函数实例生命周期回调的方法。函数实例生命周期回调方法 C#通过C#运行时实现函数实例生命周期回调的方法。函数实例生命周期回调方法 Go 通过Go实现函数实例生命周期回调的方法。函数实例...
UDF示例：复杂数据类型
Java UDF通过重载的方式使用同一个自定义函数名。Python UDF需要分别注册 UDF_COMPLEX_DATA_ARRAY、UDF_COMPLEX_DATA_MAP 和 UDF_COMPLEX_DATA_STRUCT 实现上述三种数据类型的使用。命令格式：array<string>UDF_COMPLEX_DATA(array<bigint>...
服务端SDK
客户端初始化 为了增加连接池的复用，建议不要多次创建 Client，尽量使用同一个 Client 对象。配置客户端 Cluster.Builder builder=Cluster.build();必选配置，指定endpoint、用户名、密码 builder.addContactPoint("your_endpoint")....
使用MSE的Nacos注册中心
Docker镜像制作方法，请参见 制作Java镜像。示例代码如下：RUN echo 'eval exec java-Dnacos.use.endpoint.parsing.rule=false-Dnacos.use.cloud.namespace.parsing=false-jar$CATALINA_OPTS/home/admin/app/hello-edas-0.0.1-SNAPSHOT.jar...
Spring Cloud Gateway应用路由
EDAS使用Java Agent技术以无侵入的方式增强托管的Spring Cloud Gateway应用，支持动态路由和插件配置能力。本文介绍如何在EDAS中进行Spring Cloud Gateway的常见两类配置：路由（Route）和插件（GatewayFilter）。使用限制 支持Spring ...
使用SDK示例代码消费订阅数据
完成数据订阅通道的配置后，您可以使用DTS提供的SDK示例代码来订阅数据变更信息，本文介绍该示例代码的使用说明。操作步骤 重要 若数据源是PolarDB-X 1.0或DMS LogicDB，消费订阅数据的操作步骤请参见 使用SDK示例代码消费PolarDB-X 1.0...
配置实例生命周期
函数实例生命周期回调 Java 通过Java运行时实现函数实例生命周期回调的方法。函数实例生命周期回调 C#通过C#运行时实现函数实例生命周期回调的方法。函数实例生命周期回调 Go 通过Go实现函数实例生命周期回调的方法。函数实例生命周期回调 ...
Hive作业调优
您可以通过调整内存、CPU和Task个数等，实现对Hive作业的调优。本文为您介绍如何调优Hive作业。作业调优方案 作业调优方向 调优方案 参数调优 内存参数 CPU参数 Task数量优化 并行运行 Fetch task 开启向量化 合并小文件 代码优化 代码优化...
高级配置：模型服务预热
为了解决模型初次请求耗时较长的问题，EAS 提供了模型预热功能，使模型服务在上线之前得到预热，从而实现模型服务上线后即可进入正常服务状态。本文介绍如何使用模型预热功能。背景信息 通常向模型发送初次请求时，不同的Runtime会进行不同...
Java SDK使用说明
添加依赖项 使用Java编写客户端代码时，在Maven工程中使用 EAS Java SDK，必须在 pom.xml 文件中添加 eas-sdk 的依赖，示例如下，最新版本以 Maven仓库 中显示的为准。groupId>...
Ark 服务通信
为了解决 Biz 之间的通信问题，SOFAArk 引入了 SOFABoot 提供的 SofaService/SofaReference 编程界面，本文介绍它的使用方法。说明 如果要解决 Plugin 和 Biz 的通信问题，可发布和引用插件服务。操作方式，请参见 Ark 服务机制。引入依赖 ...
Tunnel命令常见问题
本文为您介绍使用Tunnel命令过程中的常见问题。问题类别 常见问题 Tunnel Upload Tunnel Upload是否支持通配符或正则表达式？Tunnel Upload对文件大小是否有限制？记录大小是否有限制？是否要使用压缩？同一个表或分区是否可以并行上传数据...
如何使用Java SDK快速删除存储空间及其中的历史版本
本文是基于OSS的Java SDK来实现直接完全删除存储空间，您可以直接通过代码进行删除，也可以直接运行JAR包来删除存储空间，同时该代码也实现了只删除旧版本数据保留最新版本数据的功能。详细信息 说明 如果您对实例或数据有修改、变更等风险...
使用SDK示例代码消费订阅数据
在完成数据订阅通道的配置（创建好订阅任务和消费组）后，您可以自行编写SDK示例代码或使用DTS提供的SDK示例代码来订阅数据变更信息，本文介绍示例代码的使用方法。操作步骤 重要 如果数据源是PolarDB-X 1.0或DMS LogicDB，消费订阅数据的...
部署链码
链码是Hyperledger Fabric技术框架中对智能合约的实现，支持业界流行的编程语言Golang，Node.js和Java，并不断完善其他编程语言。本文介绍如何为通道部署新的链码。说明 本章节适用于购买Fabric 2.2版本实例的用户，如果您是Fabric 1.4版本...
TableTunnel
同一Session中，使用同一Block ID多次打开RecordWriter的行为会导致数据覆盖，最后一个调用 close()的RecordWriter上传的数据会被保留。该特性可用于Block的上传失败重传。TableTunnel的UploadSession中：如果没有指定 boolean overwrite ...
VPC高速直连调用
调用方式 为方便用户调用服务，EAS 提供了以下两种方式实现VPC高速直连调用：使用官方SDK调用 EAS 封装了调用逻辑并提供了Python SDK、Java SDK和Golang SDK的调用方法，您可以直接使用SDK实现VPC高速直连调用。自行实现调用逻辑 推荐使用...
常见问题
此外，如果Classpath中存在多个版本的JAR包，作业实际使用的Class版本和类的加载顺序有关，为了确认某个类具体是从哪个JAR加载而来，可以在flink-conf.yaml中设置JVM参数 env.java.opts:verbose:class 或者通过指定动态参数-Denv.java.opts...
Saga 状态机配置
Saga 模式事务是基于 状态机引擎 来实现的。分布式事务控制台提供了一个状态设计器，您可以通过该设计器自编排设计状态图，定义各节点的详细信息与属性配置等。具体的实现机制如下：通过状态图定义服务调用的流程，并生成 JSON 状态语言...
使用Aliyun Log Java Producer写入日志数据
本文介绍日志服务Aliyun Log Java Producer类库的使用方法。前提条件 已创建RAM用户并完成授权。具体操作，请参见 创建RAM用户并完成授权。已配置环境变量 ALIBABA_CLOUD_ACCESS_KEY_ID 和 ALIBABA_CLOUD_ACCESS_KEY_SECRET。具体操作，请...
SDK FAQ
使用Java SDK调用SpeechRecognizer.stop方法时出现连接超时，提示timeout after 10 seconds waiting for complete confirmation.state:STATE_STOP_SENT如何解决？state:STATE_STOP_SENT 代表数据断开连接。如果10秒内系统未接到数据，请...
Commons Pool 连接 OceanBase 数据库示例程序
本文将介绍如何使用 Commons Pool、MySQL Connector/J 和 OceanBase 数据库构建一个应用程序，实现基本的数据库操作，包括创建表、插入数据、更新数据、删除数据、查询数据和删除表等。点击下载 commonpool-mysql-client 示例工程 前提条件...
初始化OTSClient
OTSClient是 表格存储 服务的客户端，它为调用者提供了一系列的方法，可以用来操作表、读写单行数据、读写多行数据等。如果要使用宽表模型的操作数据表、读写单行数据、读写多行数据等功能，您需要初始化一个OTSClient实例，并可以根据需要...
Java JDBC Driver开发手册
支持的方法 Connection close()createStatement(int,int)createStatement(int,int,int)getSchema()prepareStatement(String,int,int)prepareStatement(String,int,int,int)setSchema(String)说明 由于Lindorm JDBC Driver的Connection接口...
MapReduce常见问题
FAILED:ODPS-0123131:User defined function exception-Traceback:java.lang.ExceptionInInitializerError.Caused by:java.security.AccessControlException:access denied("java.lang.RuntimePermission""getProtectionDomain")at java....
- 产品推荐
- 这些文档可能帮助您