[] getTypeInfos(); String[] getFieldNames(); int getIndexOfSubtask(); void sendSplitRequest(); }}````### 构造方法这里需要完成和数据源访问各种配置的提取,比如数据库库名表名、消息... pollTimeout = readerConfiguration.get(RocketMQSourceOptions.POLL_TIMEOUT); commitInCheckpoint = readerConfiguration.get(RocketMQSourceOptions.COMMIT_IN_CHECKPOINT); accessKey = readerConfigura...
LocalDateTime now = LocalDateTime.now(); DateTimeFormatter formatter = DateTimeFormatter.ISO_DATE; String currentDate = now.format(formatter); // 创建日期范围查询 sourceBuilder.query(QueryBuilders.rangeQuery("date_field") .gte("2022-01-01") .lte(currentDate));```反例:``` SearchSourceBuilder sourceBuilde...
source.type: date target.type: date.date - source.type: null target.type: void# BitSail Type to Clickhouse Typebitsail.type.to.engine.type.converter: - source.type: int targ... "split_field": "id", "split_config": "{"name": "id", "lower_bound": 0, "upper_bound": "10000", "split_num": 3}", "sql_filter": "( id % 2 == 0 )", "columns": [ { "name": "id", ...
source.type: date target.type: date.date - source.type: null target.type: void # BitSail Type to Clickhouse Type ... "split_field": "id", "split_config": "{\"name\": \"id\", \"lower_bound\": 0, \"upper_bound\": \"10000\", \"split_num\": 3}", "sql_filter": "( id % 2 == 0 )", ...
1080100000002 {"msg":"meta date error, code: 1080100000002, msg: 标签不存在, traceId: 439ced4d-3891-43b3-8ba3-293eadaec619","code":400} 更新标签的时候,标签不存在。确认标签ID是否正确。 1060040010001... 创建分群的入参fileDetail为空 1060340010002 {"msg":"Create Segment Field Empty","code":10002} 创建分群有入参为空 1060340010003 {"msg":"Segment File Invalid","code":10003} 分群文件无效 1060340010004 ...
[] getTypeInfos(); String[] getFieldNames(); int getIndexOfSubtask(); void sendSplitRequest(); }}````### 构造方法这里需要完成和数据源访问各种配置的提取,比如数据库库名表名、消息... pollTimeout = readerConfiguration.get(RocketMQSourceOptions.POLL_TIMEOUT); commitInCheckpoint = readerConfiguration.get(RocketMQSourceOptions.COMMIT_IN_CHECKPOINT); accessKey = readerConfigura...
"data": { "user_info": { "register_time": 1670310396, "first_event_time": 1670310396, "last_use": "2023-01-18", "city": "", "ssid": ... 字段含义说明 Field Type Description user_info object 用户信息,包含注册时间、首次事件发生时间、最近使用时间、最近ip所在城市、id信息等。*上述信息如果不存在会用null或空串填充。 device_info objec...
"data": { "user_info": { "register_time": 1670310396, "first_event_time": 1670310396, "last_use": "2023-01-18", "city": "", "ssid": ... 字段含义说明 Field Type Description user_info object 用户信息,包含注册时间、首次事件发生时间、最近使用时间、最近ip所在城市、id信息等。*上述信息如果不存在会用null或空串填充。 device_info objec...
"data": { "user_info": { "register_time": 1670310396, "first_event_time": 1670310396, "last_use": "2023-01-18", "city": "", "ssid": ... 字段含义说明 Field Type Description user_info object 用户信息,包含注册时间、首次事件发生时间、最近使用时间、最近ip所在城市、id信息等。*上述信息如果不存在会用null或空串填充。 device_info objec...
time_filter参数 类型 是否必选 示例值 描述 start_time i32 是 1665485413 起始时间,单位s。 granularity i32 否 3600 聚合时间粒度,单位s。 end_time i32 是 1665744613 终止时间,单位s。 filter_conditions参数 类型 是否必选 示例值 描述 type string 是 and 筛选条件类型,可选值为and和rule,只支持两层,第一层的type必须为and,第二层的type必须为rule。 field string 否 pid 条件字段...
time_filter参数 类型 是否必选 示例值 描述 start_time i32 是 1665485413 起始时间,单位s。 granularity i32 否 3600 聚合时间粒度,单位s。 end_time i32 是 1665744613 终止时间,单位s。 filter_conditions参数 类型 是否必选 示例值 描述 type string 是 and 筛选条件类型,可选值为and,rule,只支持两层,第一层的type必须为and,第二层的type必须为rule。 field string 否 pid 条件字段...
[,...]) over([partition_clause] [orderby_clause] [frame_clause]) 计算记录数。 all] ) FIELD sql T field(struct , string )sql --样例select (named_struct('f1', 'hello', 'f2', 3).f1) 获取STRUCT对象中成... 计算字符串str的长度。str:必填。STRING类型。如果输入为BIGINT、DOUBLE、DECIMAL或DATETIME类型,则会隐式转换为STRING类型后参与运算。 REPLACE plain string replace(string , string ,string ) 将字符串中与指...
partition 对应 field 的字段值。 partition_by 划分的子索引 partition 数量建议不超过1000个。 partition_by 参数未设置时,则子索引 partition 默认为 “default”。 适用场景:适用于将数据集划分为多个子数据集,在某个子数据集/子索引内部检索等检索模式固定的场景。比如,根据国家ID将数据集拆分,针对某个国家ID的子索引检索场景,无需对国家ID进行过滤,提升检索性能。 vector_index index_type string 显示向量索引类型。...