MRS Kafka输入流 功能描述 创建source流从Kafka获取数据，作为作业的输入数据。 Apache Kafka是一个快速、可扩展的、高吞吐、可容错的分布式发布订阅消息系统，具有高吞吐量、内置分区、支持数据副本和容错的特性，适合在大规模消息处理场景中使用。MRS基于Apache

查看更多 →

开源Kafka输入流 功能描述 创建source流从Kafka获取数据，作为作业的输入数据。 Apache Kafka是一个快速、可扩展的、高吞吐、可容错的分布式发布订阅消息系统，具有高吞吐量、内置分区、支持数据副本和容错的特性，适合在大规模消息处理场景中使用。 前提条件 Kaf

查看更多 →

EdgeHub输入流（EOS） 功能描述 创建边缘作业source流，从EdgeHub中获取数据。用户数据写入EdgeHub中，Flink边缘作业从中读取数据，作为流计算的数据输入。 适用于物联网IOT场景，将实时流计算能力从云端延伸到边缘，在边缘快速实现对流数据实时、快速、准确

查看更多 →

输入输出定义 连接参数 连接器无需认证，无连接参数。 定义输入 输入参数 此触发事件在流类型执行动作中使用，它的输入是在创建流类型执行动作的第二步“配置输入”中定义的，在该触发事件中单击右下角“mock数据”可以填写数据用于mock测试。 输出参数 和输入参数相同。 定义输出 输入参数

查看更多 →

自拓展输入流 用户可通过编写代码实现从想要的云生态或者开源生态获取数据，作为Flink作业的输入数据。 语法格式 1 2 3 4 5 6 7 CREATE SOURCE STREAM stream_id (attr_name attr_type (',' attr_name attr_type)*

查看更多 →

固定宽度文件输入 概述 “固定宽度文件输入”算子，将文件的每一行，按可配置长度的字符或字节，转换成多个输入字段。 输入与输出 输入：文本文件 输出：多个字段 参数说明 表1 算子参数说明 参数 含义 类型 是否必填 默认值 换行符 用户根据数据实际情况，填写字符串作为换行符。支持任何字符串。默认使用操作系统的换行符。

查看更多 →

条数据。 图3 设置数字输入框数据联动 输入框最小值：输入数字的最小值。 输入框最大值：输入数字的最大值。 当数字输入框为数据联动时，最大/最小值按组件默认配置，即最大值为253-1。 最大值不建议超过最大安全整数，若需填写更大数值，建议使用单行文本输入。 展示小数位：设置数字小数点后的位数。

查看更多 →

STRING 返回字符串的大写形式 LOWER(string) STRING 返回字符串的小写形式 POSITION(string1 IN string2) INT 返回第一个字符串在第二个字符串中首次出现的位置。若第一个字符串不存在与第二个字符串，则返回0 TRIM([ BOTH |

查看更多 →

字符串处理 对字符串内容进行处理。 连接参数 字符串处理连接器无需认证，无连接参数。 去除数字 输入参数 输入参数说明如表1所示。 表1 去除数字输入参数说明 参数 必填 说明 输入字符串 是 输入字符串。 输出参数 输出参数说明如表2所示。 表2 去除数字输出参数说明 参数 说明

查看更多 →

字符串类型 概述 MySQL以字符单位解释字符列定义中的长度规范。这适用于 CHAR、VARCHAR和TEXT类型。DSC工具支持以下列出类型转换。 类型对照 表1 字符串类型对照表 MySQL字符串类型 MySQL INPUT GaussDB (DWS) OUTPUT CHAR CHAR[(0)]

查看更多 →

照上限或下限数值处理。 字符串传参有限制，入参text类型字符串长度最大为2^30-5字节，入参bytea类型字符串长度最大为2^30-512字节。 s1和s2任意参数为bytea类型时，涉及到结果出现非法字符的情况可能展示结果与MySQL有差异但是字符编码与MySQL是一致的。

查看更多 →

在不同字符集下，最大填充长度会有差异，例如字符集为GBK时，GaussDB默认最大长度为2097152。 当 GaussDB使用 的字符编码是SQL_ASCII时， 服务器 会根据ASCII标准对字节值0~127进行解释，而字节值128~255则当作无法解析的字符。如果该函数的输入输出包

查看更多 →

STRING 返回字符串的大写形式 LOWER(string) STRING 返回字符串的小写形式 POSITION(string1 IN string2) INT 返回第一个字符串在第二个字符串中首次出现的位置。若第一个字符串不存在与第二个字符串，则返回0 TRIM([ BOTH |

查看更多 →

false str_isprintable 判断字符串中是否所有字符都是可打印字符。 函数格式 str_isprintable(value) 参数说明 参数名称 参数类型 是否必填 说明 value 任意（自动转为String） 是 需要被检测的字符串。 返回结果 true/false。 函数示例

查看更多 →

Java Java客户端接入示例 Java开发环境搭建

查看更多 →

LargeFileUploadDemo.java HttpClientDemo.java 引用类: Constant.java SSLCipherSuiteUtil.java UnsupportProtocolException.java IDEA的配置方式 支持以下几种配置方式，用户可根据业务需求选择。

查看更多 →

Element; import java.io.File; import java.io.FileInputStream; import java.io.IOException; import java.security.MessageDigest; import java.time.LocalDateTime;

查看更多 →

可使用原生Base64类 import java.util.Base64; import java.util.Date; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.UUID;

查看更多 →

Java 公共要求 代码样例 父主题： 语音验证码代码样例

查看更多 →

ObjectMapper; import java.io.BufferedReader; import java.io.InputStream; import java.io.InputStreamReader; import java.io.OutputStreamWriter;

查看更多 →

src\com\apig\sdk\demo\OkHttpDemo.java src\com\apig\sdk\demo\LargeFileUploadDemo.java src\com\apig\sdk\demo\WebSocketDemo.java .classpath Java工程配置文件 .project

查看更多 →