Flink SQL 支持 long 类型数据。您可以在 Flink SQL 中使用 long 类型来定义字段、计算和聚合操作。以下是一个示例:

CREATE TABLE myTable ( id INT, timestamp BIGINT, value DOUBLE ) WITH ( 'connector.type' = 'kafka', 'connector.version' = 'universal', 'connector.topic' = 'myTopic', 'connector.properties.bootstrap.servers' = 'localhost:9092', 'format.type' = 'json' );

SELECT id, timestamp, value FROM myTable WHERE timestamp > 1609459200000;

在上面的示例中,我们定义了一个名为 myTable 的表,其中包含 id、timestamp 和 value 三个字段。timestamp 字段的数据类型为 BIGINT,可以存储 long 类型的时间戳数据。然后我们使用 SELECT 语句从 myTable 中选择 id、timestamp 和 value 字段,并使用 WHERE 子句过滤出 timestamp 大于指定时间戳的记录。

因此,可以确信 Flink SQL 支持 long 类型数据。

flinksql不支持long

原文地址: https://www.cveoy.top/t/topic/i805 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录