allelismComputable 接口。 ![picture.image](https://p6-volc-community-sign.byteimg.com/tos-cn-i-tlddhu82om/d1bf4afd66eb47488c7199804ecac5a4~tplv-tlddhu82om-image.image?=&rk3s=8031ce6d&x-expires=1... getSplitCoordinatorCheckpointSerializer() { return new SimpleBinarySerializer<>(); } /** * Create type info converter for the source, default value {@link BitSailTypeInfoConverter} */...
=&rk3s=8031ce6d&x-expires=1716049291&x-signature=9CC8YdanNp36c2R2I9yHF48tHXU%3D)3. Mapping 准备```PUT langchain_faq{ "mappings": { "properties": { "message": { "type": "text" }, "message_embedding": { "type": "knn_vector", "dimension": 768 }, "metadata": { "type": "text" } } }, "settings": { "index": { "refresh_interval": "10s", "number_of_s...
以RocketMQSource为例:Source方法需要实现Source和ParallelismComputable接口。 ![picture.image](https://p6-volc-community-sign.byteimg.com/tos-cn-i-tlddhu82om/e1f58c570ba34bee8a11fd754318a77a... getSplitCoordinatorCheckpointSerializer() { return new SimpleBinarySerializer<>(); } /** * Create type info converter for the sourc...
才能成功从 Checkpoint 中恢复作业的状态。在 DataStream 作业中,可以通过为有状态算子设置 UID / UID Hash 来保证 OperatorID 的一致性,通过自定义 State Serializer 来解决 Serializer 的兼容问题,因此,即使作业进行迭代,逻辑改变,也很容易在作业版本间平滑地迁移状态。但是在 SQL 作业中,用户直观可见的只有 SQL 这一层,SQL 层往下的 Table 层, Datastream API 层 以及 Runtime 层,用户都是无法直接控制的。因此 SQL 作业...
Paths Array of String 否 / 采集路径列表。 最多能够创建 10 个采集路径。 采集路径必须指定为绝对路径,暂不支持相对路径。 当 InputType=0 或 InputType=2 时:采集路径支持完整匹配和通配符模式匹配,通配符... Value 表示一个目录。 当 Type 是 File 时,Value 表示一个文件名称。 UserDefineRule参数 类型 是否必选 示例值 描述 Fields JSON Map 否 {"ClusterID":"dabaad5f-7a10-4771-b3ea-d821f73e****"} 为日志添加常...
RuleName String testname 采集配置的名称。 InputType Integer 0 采集类型。 0:宿主机日志文件 1:K8s 容器标准输出 2:K8s 容器内日志文件 LogSample String 2018-05-22 15:35:53.850 INFO XXXX 日志样例。 TopicName String testname 采集配置所属于的日志主题的名称。 CreateTime String 2021-08-18 13:32:23 采集配置创建的时间。 ModifyTime String 2021-08-18 13:32:23 采集配置修改的时间。 ExtractRule Object of Ex...
=&rk3s=8031ce6d&x-expires=1716049291&x-signature=9CC8YdanNp36c2R2I9yHF48tHXU%3D)3. Mapping 准备```PUT langchain_faq{ "mappings": { "properties": { "message": { "type": "text" }, "message_embedding": { "type": "knn_vector", "dimension": 768 }, "metadata": { "type": "text" } } }, "settings": { "index": { "refresh_interval": "10s", "number_of_s...
"type": "Nullable(String)", "prepType": "string", "comment": null, "isSourceTableField": false, "is_se... { "name": "p_date", "valueList": null } ], "chQueryParams": { "openStrongConsistencyCheck": false }, "clusterName": "c...
请求说明请求方式:PUT 请求地址:https://tls-{Region}.ivolces.com/ModifyIndex 请求参数下表仅列出该接口特有的请求参数和部分公共参数。更多信息请见公共参数。 Body参数 类型 是否必选 示例值 描述 TopicId String 是 4a********* 日志主题 ID。 FullText Object of FullTextInfo 否 / 全文索引配置。 此字段为 null 或者未配置,表示不开启全文索引。 全文索引配置和键值索引配置至少配置一项,即 FullText 和 KeyValue...
Version String 是 2023-01-01 接口版本。当前 API 的版本为 2023-01-01。 Body参数 类型 是否必选 示例值 描述 DomainList Array of String 否 ["pull.example.com", "pull2.example.com"] 拉流域名列表,默认... DetailField Array of String 否 20 数据拆分的维度,默认为空表示不按维度进行数据拆分,支持的维度如下所示。 Domain:域名; ISP:运营商。 说明 配置数据拆分的维度时,对应的维度参数传入多个值时才会返回按此...
以RocketMQSource为例:Source方法需要实现Source和ParallelismComputable接口。 ![picture.image](https://p6-volc-community-sign.byteimg.com/tos-cn-i-tlddhu82om/e1f58c570ba34bee8a11fd754318a77a... getSplitCoordinatorCheckpointSerializer() { return new SimpleBinarySerializer<>(); } /** * Create type info converter for the sourc...
RuleName String testname 采集配置的名称。 InputType Integer 0 采集类型。 0:宿主机日志文件 1:K8s 容器标准输出 2:K8s 容器内日志文件 LogSample String 2018-05-22 15:35:53.850 INFO XXXX 日志样例。 TopicName String testname 采集配置所属于的日志主题的名称。 CreateTime String 2021-08-18 13:32:23 采集配置创建的时间。 ModifyTime String 2021-08-18 13:32:23 采集配置修改的时间。 ExtractRule Object of Ex...
RuleName String testname 采集配置的名称。 InputType Integer 0 采集类型。 0:宿主机日志文件 1:K8s 容器标准输出 2:K8s 容器内日志文件 LogSample String 2018-05-22 15:35:53.850 INFO XXXX 日志样例。 TopicName String testname 采集配置所属于的日志主题的名称。 CreateTime String 2021-08-18 13:32:23 采集配置创建的时间。 ModifyTime String 2021-08-18 13:32:23 采集配置修改的时间。 ExtractRule Object of Ex...