请求处理程序(Handler)

处理程序接口 您在使用Java编程时,必须要实现 函数计算 提供的接口类,fc-java-core 库为请求处理程序定义了以下两个接口。StreamRequestHandler 以流的方式接收输入的 event 事件并返回执行结果。您需要从输入流中读取调用函数时的输入,...

删除Collection

接口定义 Java/class DashVectorClient public Response<Void>delete(String name);使用示例 说明 需要使用您的api-key替换示例中的YOUR_API_KEY、您的Cluster Endpoint替换示例中的YOUR_CLUSTER_ENDPOINT,代码才能正常运行。本示例会删除...

新建Client

接口定义 Java package com.aliyun.dashvector;通过apiKey和endpoint构造 DashVectorClient(String apiKey,String endpoint);通过DashVectorClientConfig构造 DashVectorClient(DashVectorClientConfig config);使用示例 说明 需要使用您的...

删除Partition

接口定义 Java/class DashVectorCollection public Response<Void>deletePartition(String name);使用示例 说明 需要使用您的api-key替换示例中的YOUR_API_KEY、您的Cluster Endpoint替换示例中的YOUR_CLUSTER_ENDPOINT,代码才能正常运行...

获取Partition列表

接口定义 Java/class DashVectorCollection public Response<List<String>>listPartitions();使用示例 说明 需要使用您的api-key替换示例中的YOUR_API_KEY、您的Cluster Endpoint替换示例中的YOUR_CLUSTER_ENDPOINT,代码才能正常运行。本...

统计Partition

接口定义 Java/class DashVectorCollection public Response<PartitionStats>statsPartition(String name);使用示例 说明 需要使用您的api-key替换示例中的YOUR_API_KEY、您的Cluster Endpoint替换示例中的YOUR_CLUSTER_ENDPOINT,代码才能...

获取Collection列表

接口定义 Java/class DashVectorClient public Response<List<String>>list();接口使用 说明 需要使用您的api-key替换示例中的YOUR_API_KEY、您的Cluster Endpoint替换示例中的YOUR_CLUSTER_ENDPOINT,代码才能正常运行。Java import ...

新建Partition

接口定义 Java/class DashVectorCollection public Response<Void>createPartition(String name,Integer timeout);使用示例 说明 需要使用您的api-key替换示例中的YOUR_API_KEY、您的Cluster Endpoint替换示例中的YOUR_CLUSTER_ENDPOINT,...

获取Collection

接口定义 Java/class DashVectorClient public DashVectorCollection get(String name);使用示例 说明 需要使用您的api-key替换示例中的YOUR_API_KEY、您的Cluster Endpoint替换示例中的YOUR_CLUSTER_ENDPOINT,代码才能正常运行。本示例...

描述Partition

接口定义 Java/class DashVectorCollection public Response<Status>describePartition(String name);使用示例 说明 需要使用您的api-key替换示例中的YOUR_API_KEY、您的Cluster Endpoint替换示例中的YOUR_CLUSTER_ENDPOINT,代码才能正常...

统计Collection

接口定义 Java/class DashVectorClient public Response<CollectionStats>stats();使用示例 说明 需要使用您的api-key替换示例中的YOUR_API_KEY、您的Cluster Endpoint替换示例中的YOUR_CLUSTER_ENDPOINT,代码才能正常运行。本示例需要...

删除Doc

接口定义 Java/class DashVectorCollection/同步接口 public Response<List<DocOpResult>>delete(DeleteDocRequest deleteDocRequest);异步接口 public ListenableFuture<Response<List<DocOpResult>>>deleteAsync(DeleteDocRequest ...

新建Collection

接口定义 Java/class DashVectorClient/通过名称和向量维度进行创建Collection public Response<Void>create(String name,int dimension);通过CreateCollectionRequest创建Collection public Response<Void>create(CreateCollectionRequest...

更新Doc

接口定义 Java/class DashVectorCollection/同步接口 public Response<List<DocOpResult>>update(UpdateDocRequest updateDocRequest);异步接口 public ListenableFuture<Response<List<DocOpResult>>>updateAsync(UpdateDocRequest ...

插入Doc

接口定义 Java/class DashVectorCollection/同步接口 public Response<List<DocOpResult>>insert(InsertDocRequest insertDocRequest);异步接口 public ListenableFuture<Response<List<DocOpResult>>>insertAsync(InsertDocRequest ...

插入或更新Doc

接口定义 Java/class DashVectorCollection/同步接口 public Response<List<DocOpResult>>upsert(UpsertDocRequest upsertDocRequest);异步接口 public ListenableFuture<Response<List<DocOpResult>>>upsertAsync(UpsertDocRequest ...

获取Doc

接口定义 Java/class DashVectorCollection/同步接口 public Response,Doc>>fetch(FetchDocRequest fetchDocRequest);异步接口 public ListenableFuture,Doc>>>fetchAsync(FetchDocRequest fetchDocRequest);使用示例 说明 需要使用您的api...

检索Doc

接口定义 Java/class DashVectorCollection/同步接口 public Response<List<Doc>>query(QueryDocRequest queryDocRequest);异步接口 public ListenableFuture<Response<List<Doc>>>queryAsync(QueryDocRequest queryDocRequest);使用示例 ...

Paho-MQTT Java接入示例

MqttSign.java 文件定义了 MqttSign 类,类说明如下:原型:class MqttSign 功能:用于计算设备接入物联网平台的MQTT连接参数 username、password 和 clientid。成员:类型定义 方法描述 public void calculate(String productKey,String ...

LLM-扩展LaTeX宏定义

支持的 计算资源 MaxCompute 算法说明 LLM-扩展LaTeX宏定义组件内联扩展所有无参数的宏,正则表达式如下:对比项 不带参数的 ewcommand宏 不带参数的\def宏 正则表达式 r'\\\bnewcommand\b\*?\{(\\[a-zA-Z0-9]+?\}\{(.*?\}$' r'\\def\s*(\\...

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 ...

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开发自定义Processor

接口定义 使用Java开发自定义Processor仅需要定义一个类,该类中除构造函数以外,只需要 Load()和 Process()函数即可。类的原型如下。package com.alibaba.eas;import java.util.*;public class TestProcessor { public TestProcessor...

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 ...

HikariCP 连接池连接 OceanBase 数据库示例程序

Main.java 代码介绍 Main.java 文件是示例程序的一部分,用于演示通过 HikariCP 连接池获取数据库连接,并执行一系列数据库操作,包括创建表、插入数据、删除数据、更新数据、查询数据,并将查询结果打印出来。本文 Main.java 文件的代码...

Proxool 连接池连接 OceanBase 数据库示例程序

通过定义依赖项:添加 mysql-connector-java 库,用于连接和操作数据库:通过指定依赖项所属的组织为 mysql。通过指定依赖项的名称为 mysql-connector-java。通过指定依赖项的版本号为 5.1.47。代码如下:<dependency><groupId>mysql...

打包、上传及注册

Java程序中定义的类。Function name MaxCompute Studio基于JAR包资源注册的MaxCompute UDF名称。及后续在SQL中调用的函数名称。Force update if already exists 选中该项,表示当MaxCompute项目中存在同名函数或资源时,新函数或资源会...

动态CEP中规则的JSON格式定义

string 是 形如 price>5.0&name.contains("mid")这样的表达式字符串(price、name 等变量名来自于Java代码中定义的字段)。您可以将该字符串在数据库中的值进行修改。例如修改为 price>20&name.contains("end"),Flink CEP作业会动态加载新...

环境说明

版本 操作系统 架构 Java 11 Linux x86_64 Java 8 Linux x86_64 函数计算 为Java运行时提供以下依赖库:com.aliyun:fc-java-core :定义了请求处理程序中使用的handler接口和context对象等信息。com.aliyun:fc-java-events :提供了常用的...

环境说明

版本 操作系统 架构 Java 11 Linux x86_64 Java 8 Linux x86_64 函数计算 为Java运行时提供以下依赖库:com.aliyun:fc-java-core :定义了请求处理程序中使用的handler接口和context对象等信息。com.aliyun:fc-java-events :提供了常用的...

编译部署代码包

本文介绍如何在Java运行环境(Maven或Serverless Devs工具)编译程序,并打包为ZIP包或JAR包。编译打包完成后,您可以在 函数计算 控制台或使用Serverless Devs工具上传代码包。Java运行时依赖库 要创建部署代码包,请将函数代码和依赖库...

编译部署代码包

您可以在本地Java运行环境(Maven或Serverless Devs工具)编译程序,打包为ZIP包或JAR包,然后在 函数计算 控制台或使用Serverless Devs工具上传代码包,并正确运行您的代码。Java运行时依赖库 要创建部署代码包,请将函数代码和依赖库共同...

连接方式概述

JDBC 标准由 Sun Microsystems 定义,通过标准 java.sql 接口实现,支持各个提供程序使用自己的 JDBC 驱动程序来实现和扩展标准。JDBC 是基于 X/Open SQL 的调用级别接口(Call Level Interface,CLI)。OceanBase Connector/J 驱动程序...

UDT示例

定义函数时使用java.util.Map?extends Object,?extends Object>。2.调用时做强制转换,例如UDTClass.mapSize(cast(mapObj as java.util.Map,Object>))。public static Long mapSize(java.util.Map,Object>input){ return input.size();} } ...

实践教程

针对各种业务需求,Dataphin提供相关实践教程,您可根据不同场景查看最佳实践教程进行参考。Dataphin 面向零售店铺的模型构建与管理 自定义RDBMS数据库及同步数据 DataX同步数据 使用Python读文件 Java UDF最佳实践 规范定义最佳实践

DescribeAppServiceDetail

格式如下:/path ParameterDefinitions Array of ParameterDefinition 参数定义。Type String java.lang.String 参数类型。Description String description 参数描述。Name String arg0 参数名称。ErrorCode String 空 错误码。取值说明...

C3P0 连接池连接 OceanBase 数据库示例程序

通过定义依赖项:添加 mysql-connector-java 依赖库:通过指定依赖项所属的组织为 mysql。通过指定依赖项的名称为 mysql-connector-java。通过指定依赖项的版本号为 8.0.25。添加 c3p0 依赖库:通过指定依赖项所属的组织为 com.mchange 。...

Alibaba Blink实时模式资源自定义

direct_memory 单位为MB,direct_memory并不是虚拟机运行时数据区的一部分,也不是Java虚拟机规范中定义的内存区域。但是这部分内存也被频繁的使用,而且也可能导致OutOfMemoryError异常出现。如果您的程序有使用igraph或者swift,可以适当...

Alibaba Blink实时模式资源自定义

direct_memory 单位为MB,direct_memory并不是虚拟机运行时数据区的一部分,也不是Java虚拟机规范中定义的内存区域。但是这部分内存也被频繁的使用,而且也可能导致OutOfMemoryError异常出现。如果您的程序有使用igraph或者swift,可以适当...

UDF(SQL自定义函数)

背景信息 功能介绍 SQL语言定义函数作为一种用户自定义函数(UDF),弥补了MaxCompute只能用Java或Python创建UDF的不足,还扩展了UDF入参的参数类型,可支持函数类型的入参参数,提升表达业务逻辑的灵活性。您可以通过该函数实现简单功能,...
共有200条 < 1 2 3 4 ... 200 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
NAT网关 云监控 专有宿主机 弹性公网IP 短信服务 人工智能平台 PAI
新人特惠 爆款特惠 最新活动 免费试用