Java UDF最佳实践
为了满足复杂的数据开发场景，Dataphin智能研发版支持自定义Java UDF函数。本教程以Java自带函数（toLowerCase）为例，为您介绍如何基于Dataphin自定义Java UDF函数。前提条件 下载 JAR包。背景信息 本教程基于下载的JAR包自定义的Java UDF...
示例代码
云消息队列 RocketMQ 版 5.x版本实例可兼容Java ONS 1.x SDK客户端接入，您可以使用ONS 1.x SDK的接入5.x实例进行消息收发。本文为您介绍Java ONS 1.x SDK消息收发示例代码。重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力...
Java UDF最佳实践
为了满足复杂的数据开发场景，Dataphin智能研发版支持自定义Java UDF函数。本教程以Java自带函数（toLowerCase）为例，为您介绍如何基于Dataphin自定义Java UDF函数。前提条件 下载 JAR包。背景信息 本教程基于下载的JAR包自定义的Java UDF...
收发普通消息
import java.util.Date;public class Producer { public static void main(String[]args){ MQClient mqClient=new MQClient(/设置HTTP协议客户端接入点，进入消息队列RocketMQ版控制台实例详情页面的接入点区域查看。{HTTP_ENDPOINT}",/...
安装宽表SQL Driver
本文面向应用开发者概要介绍了Lindorm宽表引擎提供的SQL应用开发的开发套件与工具。数据库驱动 Lindorm面向目前主流的应用开发语言分别提供了以下数据库驱动（Database Driver，可以简单理解为执行SQL的SDK）。Java Lindorm面向Java语言...
使用Java JDBC接口的应用开发
本文介绍通过Java语言的标准JDBC接口使用SQL开发Lindorm宽表应用的方法和示例。前提条件 已安装Java环境，要求安装JDK 1.8及以上版本。已将客户端IP地址添加至Lindorm白名单，具体操作请参见 设置白名单。使用限制 本文操作仅适用于Lindorm...
基于Java JDBC接口的应用开发
本文介绍通过Java语言的标准JDBC接口使用SQL开发Lindorm宽表应用的方法和示例。前提条件 已安装Java环境，要求安装JDK 1.8及以上版本。已将客户端IP地址添加至Lindorm白名单，具体操作请参见 设置白名单。使用限制 本文操作仅适用于Lindorm...
分库分表（Alias功能）
router.maxFutureMs 8640000000 代表最大容忍写入的时间字段your_date_dt与当前时间的差值，防止写入过大的时间字段或者过小的时间值，样例中给出的是100天，即不能写入一条数据的时间比当前时间大100天或小100天。collection.collection....
快速入门
import java.util.Date;import java.util.HashMap;import java.util.List;import java.util.Map;public class Demo { public static final String ZK="localhost;Zookeeper地址 public static void main(String args[]){ try{ DataStore ds...
org.postgresql.util.PSQLException:ERROR
errMsg:数据源执行SQL失败:INTERNAL:java.lang.RuntimeException:SQL execute error by datasource.org.postgresql.util.PSQLException:ERROR:zero-length delimited identifier at or near""""位置：10856 org.postgresql.core.v3....
Java SDK Demo
演示如何使用Java SDK操作数据湖分析的spark作业*@author aliyun*/public class Demo {/*提交一个SQL作业到数据湖分析Serverless Spark*@param virtualClusterName 数据湖分析虚拟集群名称*@param sql sql内容*@return Spark JobId,提交...
Dataphin即席查询报错“Metering data exceed max ...
511)at java.util.concurrent.FutureTask.run(FutureTask.java:266)at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1152)at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java...
概述
MaxCompute JDBC驱动是MaxCompute提供的Java数据库连接（Java Database Connectivity）接口。您可以通过标准的JDBC接口基于MaxCompute执行海量数据的分布式计算查询。MaxCompute JDBC驱动还可以用于连接MaxCompute和支持JDBC的工具。JDBC...
Dataphin计算源为CDH,代码任务运行报错“java.lang....
问题描述 Dataphin计算源为CDH,代码任务和即席SQL运行报错“java.lang.IllegalArgumentException:Bucket ID out of range:1”。完整的异常信息如下：2022-03-24 16:05:08.652 Task failed:java.sql.SQLException:Error while compiling ...
分库分表（Alias功能）
date_dt与当前时间的差值，防止写入过大的时间字段或者过小的时间值，样例中给出的是100天，即不能写入一条数据的时间比当前时间大100天或小100天 collection.collection.configName_indexer_default 代表创建的索引表依赖的配置集，可以...
API调用-加密身份认证
import java.util.Date;import java.util.Locale;import java.util.TimeZone;public abstract class SignUtils { public static final String EMPTY_STRING_MD5;private static FastDateFormat DATE_FORMAT;static { DATE_FORMAT=...
视频审核
本文介绍了如何使用Java SDK视频审核接口，检测视频中是否包含风险内容。功能描述 视频审核接口支持同步检测和异步检测两种方式。同步检测只支持传递视频的截帧图片序列。关于参数的详细介绍，请参见 同步检测。（推荐）异步检测支持对原始...
Druid 连接池连接 OceanBase 数据库示例程序
添加 mysql-connector-java 依赖库，用于与数据库进行交互：通过指定依赖项所属的组织为 mysql。通过指定依赖项的名称为 mysql-connector-java。通过指定依赖项的版本号为 5.1.40。代码如下：<dependency><groupId>mysql</groupId>...
Java SDK调用示例
本文介绍了卡证核身方案银行卡二三四要素认证的Java SDK调用示例。SDK使用说明 如果需要其他语言的SDK示例代码，您可以通过 OpenAPI开发者门户 在线调试工具调试API接口。该工具会自动生成相应API的SDK调用示例代码，详细信息，请参见：...
DBCP 连接池连接 OceanBase 数据库示例程序
本文将介绍如何使用 DBCP 连接池、MySQL Connector/J 和 OceanBase 数据库构建一个应用程序，实现基本的数据库操作，包括创建表、插入、删除、...Main.java 代码介绍 Main.java 文件是示例程序的一部分，用于演示通过 DBCP 连接池获取数据库...
日期与时间函数
select date1,add_months(date1,1)as date1_add_months,datetime1,add_months(datetime1,2)as datetime1_add_months,timestamp1,add_months(timestamp1,3)as timestamp1_add_months,date3,add_months(date3,4)as date3_add_months from mf_...
更新数据
本文档介绍如何使用Java、Python语言进行更新表数据，支持的更新操作有add、delete。相关依赖 Java异步<dependency><groupId>...
DBMS_SQL
DBMS_SQL包提供查询 PolarDB PostgreSQL版（兼容Oracle）动态SQL的功能，可以在应用运行时构建查询。PolarDB PostgreSQL版（兼容Oracle）支持查询动态SQL，且以与Oracle兼容的方式来使用动态SQL。表 1.DBMS_SQL函数/存储过程 函数/存储过程...
Quick BI数据集报错“division by zero”
errMsg:数据源执行SQL失败:INTERNAL:java.lang.RuntimeException:SQL execute error by datasource.org.postgresql.util.PSQLException:ERROR:division by zero org.postgresql.core.v3.QueryExecutorImpl.receiveErrorResponse...
使用JDBC提交Presto作业
import java.util.Properties;public class TrinoSqlConnection { public static void main(String[]args)throws SQLException {/连接地址 String url="jdbc:trino:/trino-cli.c-xxx.xxx.cn-hangzhou.alicontainer.com:443";Properties ...
DTS全量迁移报“java.sql.BatchUpdateException:...
java.sql.BatchUpdateException:INSERT,DELETE command denied to user 'user' 问题原因 全量迁移如果报INSERT、CREATE或DELETE等命令的权限问题，一般都是由于目标RDS实例被锁定了，导致账号写权限被回收。解决方案 首先 回收目标RDS实例...
HTTPS原生调用
import java.util.Date;import java.util.HashMap;import java.util.List;import java.util.Map;import java.util.Map.Entry;import java.util.SimpleTimeZone;import java.util.UUID;import com.google.common.io.BaseEncoding;import org...
HTTPS原生调用
import java.util.Date;import java.util.HashMap;import java.util.List;import java.util.Map;import java.util.Map.Entry;import java.util.SimpleTimeZone;import java.util.UUID;import com.google.common.io.BaseEncoding;import org...
UDF示例：复杂数据类型
本例中 evaluate 方法定义了三个 string 类型的入参和 string 类型的返回值，输入参数和返回值的数据类型将作为SQL语句中UDF的函数签名Signature，其他代码规范和要求请参考：UDF开发规范与通用流程（Java）。Python3 UDF 代码示例 下面...
Dataphin实践Java UDF报错“ODPS-0130071:[1,8]...
产品名称 Dataphin 产品模块 数据研发 概述 为您介绍在数据研发过程中报错“ODPS-0130071:[1,8]Semantic analysis exception-function or view 'JAVA' cannot be resolved”的处理办法 问题描述 客户为解决数据开发场景，使用Dataphin智能...
数据推送 Demo
本文将介绍通过召回引擎版Java SDK客户端将数据实时同步到召回引擎版的实例中，支持的更新操作有：add、delete。add 操作示例 package com.aliyun.ha3engine;import com.aliyun.ha3engine.Client;import com.aliyun.ha3engine.models.*;...
dbcp 连接池连接示例
import java.util.Properties;import javax.sql.DataSource;import org.apache.commons.dbcp2.BasicDataSourceFactory;DBCP 配置类*@author SUN*/public class KCYDBCPUtil { private static Properties properties=new Properties();...
授权访问
import java.util.Date;public class Demo { public static void main(String[]args)throws Throwable {/以华东1（杭州）的外网Endpoint为例，其它Region请按实际情况填写。String endpoint="https://oss-cn-hangzhou.aliyuncs.com";从环境...
数据推送 Demo
本文将介绍通过向量检索版Java SDK客户端将数据实时同步到向量检索版的实例中，支持的更新操作有：add、delete。add 操作示例 package com.aliyun.ha3engine;import com.aliyun.ha3engine.Client;import com.aliyun.ha3engine.models.*;...
异步处理
线程中使用 java.lang.Runnable 如果您在代码中通过 java.lang.Runnable 新启动了线程或者采用了线程池去异步地处理一些业务，那么需要将 SOFATracer 日志上下文从父线程传递到子线程中去，SOFATracer 提供的 ...您可以按照以下方式使用：...
Zeppelin概述
Long=new java.util.Date(2020-1900,0,1).getTime var sleepInterval=100 override def run(ctx:SourceFunction.SourceContext[(Long,String)]):Unit={ val lock=ctx.getCheckpointLock while(count){ lock.synchronized({ ctx.collect(...
打包、上传及注册
当您完成Java程序开发及调试后，您需要将Java程序打包为JAR包并以资源形式上传至MaxCompute项目后，才可以注册MaxCompute UDF，供后续在数据开发中调用。本文为您介绍在MaxCompute Studio中一键完成Java程序打包为JAR包、上传JAR包为...
通过Java SDK使用SQL独享版
import java.util.Date;public class SlsSample { public static void main(String args[])throws LogException,InterruptedException {/本示例从环境变量中获取AccessKey ID和AccessKey Secret。String accessId=System.getenv("ALIBABA_...
模型应用
import java.util.ArrayList;import java.util.Arrays;import java.util.Collections;import java.util.List;public class ApplicationClientTest {/*官方模型调用应用、自训练模型应用示例*/public void testModelCompletions(){ String ...
SQL脚本模式
当您面对大数据集的ETL任务、自动化定期任务、复杂查询编排等场景时，可以使用MaxCompute当前SQL引擎支持的脚本模式（Script Mode SQL）。在脚本模式下，一个多语句的SQL脚本文件将被作为一个整体进行编译，无需对单个语句进行编译；提交...
- 产品推荐
- 这些文档可能帮助您