以RocketMQSource为例:Source方法需要实现Source和ParallelismComputable接口。 ![picture.image](https://p3-volc-community-sign.byteimg.com/tos-cn-i-tlddhu82om/e1f58c570ba34bee8a11fd754318a77a... 设置作业的处理方式,是采用流式处理方法、批式处理方法,或者是流批一体的处理方式,在流批一体的场景中,我们需要根据作业的不同类型设置不同的处理方式。 **具体对应关系如下:**| Job Type | B...
开发者首先需要创建`Sink`类,实现`Sink`接口,主要负责数据写入组件的生命周期管理,构架作业。通过`configure`方法定义`writerConfiguration`的配置,通过`createTypeInfoConverter`方法来进行数据类型转换,将内部类... getRestoreStates(); }}````### 构造方法根据writerConfiguration配置初始化数据源的连接对象。#### 示例````public RedisWriter(BitSailConfiguration writerConfiguration) { // initialize ttl ...
为大家带来详细全面的开发方法与场景示例,本篇将主要介绍SourceSplitCoordinator接口部分。** ![picture.image](https://p3-volc-community-sign.byteimg.com/tos-cn-i-tlddhu82om/67a27cb55f5d44989d... 开发者在构造方法中一般主要进行一些配置的设置和分片信息存储的容器的创建。 以ClickhouseSourceSplitCoordinator的构造为例:``` `public ClickhouseSourceSplitCoordinator(S...
### SourceReader接口````public interface SourceReader extends Serializable, AutoCloseable { void start(); void pollNext(SourcePipeline pipeline) throws Exception; void addSplits(List spli... [] getTypeInfos(); String[] getFieldNames(); int getIndexOfSubtask(); void sendSplitRequest(); }}````### 构造方法这里需要完成和数据源访问各种配置的提取,比如数据库库名表名、消息...
请求接口 说明 请求向量数据库 VikingDB 的 OpenAPI 接口时,需要构造签名进行鉴权,详细的 OpenAPI 签名调用方法请参见 API签名调用指南。 URI /api/collection/upsert_data 统一资源标识符 请求方法 POST 客户端对向量数据库服务器请求的操作类型 请求头 Content-Type: application/json 请求消息类型 Authorization: HMAC-SHA256 *** 鉴权 请求参数 参数名 类型 是否必选 参数说明 collection_name/collect...
概述 /collection/del_data 接口用于在指定的 Collection 删除数据,支持以下几种方法: 在指定的 Collection 中,根据主键删除单条或多条数据,单次最多允许删除100条数据。 删除指定的 Collection 下所有数据。 请求接口 说明 请求向量数据库 VikingDB 的 OpenAPI 接口时,需要构造签名进行鉴权,详细的 OpenAPI 签名调用方法请参见 API签名调用指南。 URI /api/collection/del_data 统一资源标识符 请求方法 POST 客户端对向...
概述 /collection/del_data 接口用于在指定的 Collection 删除数据,支持以下几种方法: 在指定的 Collection 中,根据主键删除单条或多条数据,单次最多允许删除100条数据。 删除指定的 Collection 下所有数据。 请求接口 说明 请求向量数据库 VikingDB 的 OpenAPI 接口时,需要构造签名进行鉴权,详细的 OpenAPI 签名调用方法请参见 API签名调用指南。 URI /api/collection/del_data 统一资源标识符 请求方法 POST 客户端对向...
概述 /collection/fetch_data 接口用于根据主键在指定的 Collection 中查询单条或多条数据,单次最多可查询100条数据。Collection 数据写入/删除后,可以实时查询数据。 请求接口 说明 请求向量数据库 VikingDB 的 OpenAPI 接口时,需要构造签名进行鉴权,详细的 OpenAPI 签名调用方法请参见 API签名调用指南。 URI /api/collection/fetch_data 统一资源标识符 请求方法 GET 客户端对向量数据库服务器请求的操作类型 请求头 ...
概述 /collection/fetch_data 接口用于根据主键在指定的 Collection 中查询单条或多条数据,单次最多可查询100条数据。Collection 数据写入/删除后,可以实时查询数据。 请求接口 说明 请求向量数据库 VikingDB 的 OpenAPI 接口时,需要构造签名进行鉴权,详细的 OpenAPI 签名调用方法请参见 API签名调用指南。 URI /api/collection/fetch_data 统一资源标识符 请求方法 GET 客户端对向量数据库服务器请求的操作类型 请求头 ...
概述 /index/drop 接口用于删除指定数据集 Collection 的指定索引 Index。 请求接口 说明 请求向量数据库 VikingDB 的 OpenAPI 接口时,需要构造签名进行鉴权,详细的 OpenAPI 签名调用方法请参见 API签名调用指南。 URI /api/index/drop 统一资源标识符 请求方法 POST 客户端对向量数据库服务器请求的操作类型 请求头 Content-Type: application/json 请求消息类型 Authorization: HMAC-SHA256 *** 鉴权 请求参数 参...
概述 /index/drop 接口用于删除指定数据集 Collection 的指定索引 Index。 请求接口 说明 请求向量数据库 VikingDB 的 OpenAPI 接口时,需要构造签名进行鉴权,详细的 OpenAPI 签名调用方法请参见 API签名调用指南。 URI /api/index/drop 统一资源标识符 请求方法 POST 客户端对向量数据库服务器请求的操作类型 请求头 Content-Type: application/json 请求消息类型 Authorization: HMAC-SHA256 *** 鉴权 请求参数 参...
概述 /index/list 接口用于查询和数据集 Collection 关联的索引 Index列表。 请求接口 说明 请求向量数据库 VikingDB 的 OpenAPI 接口时,需要构造签名进行鉴权,详细的 OpenAPI 签名调用方法请参见 API签名调用指南。 URI /api/index/list 统一资源标识符 请求方法 GET 客户端对向量数据库服务器请求的操作类型 请求头 Content-Type: application/json 请求消息类型 Authorization: HMAC-SHA256 *** 鉴权 请求参数 参...
概述 /index/list 接口用于查询和数据集 Collection 关联的索引 Index列表。 请求接口 说明 请求向量数据库 VikingDB 的 OpenAPI 接口时,需要构造签名进行鉴权,详细的 OpenAPI 签名调用方法请参见 API签名调用指南。 URI /api/index/list 统一资源标识符 请求方法 GET 客户端对向量数据库服务器请求的操作类型 请求头 Content-Type: application/json 请求消息类型 Authorization: HMAC-SHA256 *** 鉴权 请求参数 参...