-
Notifications
You must be signed in to change notification settings - Fork 107
Open
Description
Version
latest
Which SQL?
Flink
SQL content
SELECT * FROM orders ORDER BY price * quantity ASC LIMIT 10;
INSERT INTO Paimon.iov_paimon_prd.ods_track_vcos_log_prs_hi
SELECT
vin AS vin, -- 车架号
-- Kafka时间戳转毫秒级(含毫秒精度)
UNIX_TIMESTAMP(DATE_FORMAT(kafka_timestamp, 'yyyy-MM-dd HH:mm:ss')) * 1000
+ EXTRACT(MILLISECOND FROM kafka_timestamp) AS kafka_ts -- Kafka时间戳(毫秒)
FROM ods_track_vcos_log_prs_rt2
WHERE JSON_VALUE(parse_track_pb(data), '$.eid') = '1570001000';
INSERT INTO Paimon.iov_paimon_prd.ods_track_vcos_log_prs_hi
SELECT
vin AS vin, -- 车架号
-- Kafka时间戳转毫秒级(含毫秒精度)
UNIX_TIMESTAMP(DATE_FORMAT(kafka_timestamp, 'yyyy-MM-dd HH:mm:ss')) * 1000
+ EXTRACT(MILLISECOND FROM kafka_timestamp) AS kafka_ts -- Kafka时间戳(毫秒)
FROM ods_track_vcos_log_prs_rt2
WHERE JSON_VALUE(parse_track_pb(data), '$.eid' RETURNING STRING) = '1570001000';JavaScript/TypeScript code
What happened?
- ORDER BY + expression
- EXTRACT 函数
- JSON_VALUE RETURNING
https://nightlies.apache.org/flink/flink-docs-release-1.16/docs/dev/table/functions/systemfunctions/
Relevant log output
Reactions are currently unavailable
Metadata
Metadata
Assignees
Labels
No labels