没有合适的资源？快使用搜索试试~ 我知道了~

文库首页行业互联网【全】kafak ksql 函数用法大全.doc

【全】kafak ksql 函数用法大全.doc

ksqlDB

confluent

kafka

需积分: 50 1 下载量 81 浏览量 2021-04-01 15:15:02 上传评论收藏 445KB DOC 举报

温馨提示

试读

24页

kafak ksql 函数，基于Confluent的ksqlDB各个函数的用法使用，本文档对官方英文文档进行了汉化和补充，翻译并测试。

资源推荐

资源详情

资源评论

conuent 中 ksqlDB 各个函数的作用与用

法（包含测试用例）

0.readme

 本文档对官方英文文档进行了汉化和补充

 本文档内容<=官网内容，如有未找到的函数，请查找官

网

 若对函数的用法作用存在争议，请查找官网

 Since: - 表示自某版本开始使用（针对 ksqlDB 版本）

 时间与版本

官网最新更新时间: 2020-04-20 版本：0.15.0-ksqldb

本文档创建时间：2021-02-24

 参考以下内容时，在进行简单测试时，请使用单引号来

替代双引号。单引号表示字符串。（针对 Strings 类函

数）

 例如

MASK("My Test $123")将返回 Xx-Xxxx- nnn，应用所有默认掩码。

 测试时应将双引号换为单引号，且保证 STREAM_NAME 中存在至少一行

数据

select MASK('My Test $123') from STREAM_NAME emit

changes;

 Epoch 指的是一个特定的时间：1970-01-01 00:00:00 UTC

1.Scalar functions

1.1 Numeric functions

**1.1.1 ABS

Since: -

用法：ABS(col1)

作用：一个值的绝对值。

例子：

**1.1.2 CEIL

Since: -

用法：CEIL(col1)

作用：值向上取整

例子：

1.1.3 ENTRIES

Since: 0.6.0

用法：ENTRIES(map MAP, sorted BOOLEAN)

作用：Constructs an array of structs from the entries in a map. Each struct has a eld

named K containing the key, which is a string, and a eld named V, which holds the

value.

If sorted is true, the entries are sorted by key.

例子：

**1.1.4 EXP

Since: 0.6.0

用法：EXP(col1)

作用：底数为 e，指数为 col1 的值，返回的数为 e 的 col1 值次方

例子：

**1.1.5 FLOOR

Since: -

用法：FLOOR(col1)

作用：值向下取整

例子：

1.1.6 GENERATE_SERIES

Since: 0.6.0

用法：GENERATE_SERIES(start, end)

GENERATE_SERIES(start, end, step)

作用：构造一个数组，值在 start 和 end(包括)之间

参数 start 和 end 可以是 INT 或 BIGINT。

step(如果提供的话)指定步长。这个步骤可以是正的，也可以是负的。如果没有提供，则

步骤默认为 1。参数 step 必须为 INT 类型。

例子：

1.1.7 GEO_DISTANCE

Since: 0.6.0

用法：GEO_DISTANCE(lat1, lon1, lat2, lon2, unit)

作用：两个坐标点之间的大圆距离，均以十进制度表示。最后一个参数是可选的，指定了

KM(默认值)或 miles。lat1 和 lon1 是 longitudeandlatitude经纬度

例子：

**1.1.8 LN

Since: 0.6.0

用法：LN(col1)

作用：返回一个值的自然对数.。自然对数以常数项 e 为底。

例子：

**1.1.9 RANDOM

Since: -

用法：RANDOM()

作用：返回 0.0 到 1.0 之间的双精度随机数。

例子：

**1.1.10 ROUND

Since: 0.6.0

用法：ROUND(col1)

ROUND(col1, scale)

作用：将 col1 中的值四舍五入到 scale 所指定的小数点位数，scale 值为 0 对应小数点左

侧整数部分的个位数字，从 0 开始 scale 值-1、-2、-3 分别对应整数部分十位、百位、千

位，依次类推，从 0 开始 scale 值为 1、2、3 分别对应小数点右侧小数位置小数点后一位、

小数点后两位、小数点后三位，依次类推。

当 scale 为正数时，如果 scale 大于小数位数，则多出来的部分用 0 补足

当 scale 为负数时，如果 scale 绝对值大于整数位数，则返回 0，等于整数位数时，需要根

据整数部分最左边数值大小四舍五入判断返回值。

根据距离值右边（正方向）最近的数字四舍五入。如果没有提供 scale，则默认为零。

举例如 ROUND(225.55,0) 将返回 226 ； ROUND(225.55,1) 将返回 225.6 ；

ROUND(225.55,-1)将返回 230 ；ROUND(225.55,-3)将返回 0 ；ROUND(525.55,-3)将返

回 1000

ksqlDB 中-1.5 四舍五入的值为-1。

例子：

**1.1.11 SIGN

Since: 0.6.0

用法：SIGN(col1)

作用：只会返回- 1,1,0，null 值

如果参数为负，则返回-1

如果参数为 0，则返回 0

剩余23页未读，继续阅读

评论收藏

内容反馈

资源评论

资源反馈

评论星级较低，若资源使用遇到问题可联系上传者，3个工作日内问题未解决可申请退款~

idataduck

粉丝: 5
资源: 4

上传资源快速赚钱

我的内容管理展开

我的资源快来上传第一个资源

我的收益

登录查看自己的收益

我的积分登录查看自己的积分

我的C币登录后查看C币余额

我的收藏

我的下载

下载帮助

前往需求广场，查看用户热搜

【全】kafak ksql 函数用法大全.doc

Kafka KSQL实战.docx

Apache Kafka的流式SQL引擎——ksql.docx

KSQL参考手册

kafka-manager-1.3.3.22.zip

下载慢？给你Kafka 2.xx所有版本下载的百度网盘链接

最新版kafka kafka_2.13-2.6.0.tgz

大数据笔记，包含Hadoop、Spark、Flink、Hive、Kafka、Flume、ZK......

kafka-2.10-0.8.1.1

KAFKA-3.1.1-1.3.1.1.p0.2-el7.parcel

kafka_2.10-0.8.2.1.tgz

kafka_2.11-0.10.1.0.tgz

KAFKA-3.0.0-1.3.0.0.p0.40-el7

kafka-manager-2.0.0.2.zip

kafka_2.11-0.9.0.1.tgz

kafka-manager-1.3.3.16.zip(已编译)

Kafka分布式集群安装部署.doc

Kafka急速入门与实战.doc

kafka-clients-0.10.0.1-API文档-中英对照版.zip

Kafka 分区（详细）.doc

kafka_2.11-0.10.2.0.tar.gz

kafka-manager-1.3.2.1.zip

Java 面经手册·小傅哥.pdf

解压后拖入浏览器扩展程序使用.zip

103套PPT模板.zip

Beyond Compare 免安装直接使用

notepad++.exe官网下载

Mars4_5.zip

QT自制精美Ui模板系列（一）桃子风格模板 - 二次开发专用

Postman9.12.2安装包

最新资源