杂项 SQL 函数

InfluxDB 3 Core SQL 实现支持以下杂项函数，用于执行各种操作

• arrow_cast
• arrow_typeof
• interpolate
• locf

arrow_cast

将值强制转换为特定的 Arrow 数据类型。

arrow_cast(expression, datatype)

参数

• expression：要转换的表达式。可以是常量、列或函数，以及算术或字符串运算符的任意组合。
• datatype：要转换成的 Arrow 数据类型。

SELECT
  arrow_cast(time, 'Int64') AS time,
  arrow_cast(temp, 'Utf8') AS temp,
  arrow_cast(co, 'Float64')AS co
FROM home
LIMIT 1

arrow_typeof

返回表达式的底层 Arrow 数据类型

arrow_typeof(expression)

参数

• expression：要评估的表达式。可以是常量、列或函数，以及算术或字符串运算符的任意组合。

SELECT
  arrow_typeof(time) AS time,
  arrow_typeof(room) AS room,
  arrow_typeof(temp) AS temp,
  arrow_typeof(co) AS co
FROM home
LIMIT 1

interpolate

通过从现有值插值来填充指定聚合列中的空值。必须与 date_bin_gapfill 一起使用。

interpolate(aggregate_expression)

参数

• aggregate_expression：对指定表达式执行聚合操作。该操作可以使用任何聚合函数。表达式可以是常量、列或函数，以及聚合函数支持的算术运算符的任意组合。

相关函数

date_bin_gapfill, locf

SELECT
  date_bin_gapfill(INTERVAL '30 minutes', time) as _time,
  room,
  interpolate(avg(temp))
FROM home
WHERE
    time >= '2022-01-01T08:00:00Z'
    AND time <= '2022-01-01T10:00:00Z'
GROUP BY _time, room

locf

通过向前携带最后观察到的值来填充指定聚合列中的空值。必须与 date_bin_gapfill 一起使用。

LOCF 是 “last observation carried forward”（最后一次观测值向前结转）的首字母缩写。

locf(aggregate_expression)

参数

• aggregate_expression：对指定表达式执行聚合操作。该操作可以使用任何聚合函数。表达式可以是常量、列或函数，以及聚合函数支持的算术运算符的任意组合。

相关函数

date_bin_gapfill, interpolate

SELECT
  date_bin_gapfill(INTERVAL '30 minutes', time) as _time,
  room,
  locf(avg(temp))
FROM home
WHERE
    time >= '2022-01-01T08:00:00Z'
    AND time <= '2022-01-01T10:00:00Z'
GROUP BY _time, room