如何在FlinkSQL中获取行的长度？

Question

sql：CREATE TABLE tab1 ( data Row<id BIGINT,name VARCHAR>) WITH ...;

我想知道行的长度，比如：select length(data) as size from tab1...输出长度是2。

我该怎么做呢？

Answer 1

Row类型有一个getArity()方法，您可以直接在Table API中使用该方法，也可以将其包装在用户定义的函数中以便在SQL中使用。

Answer 2

假设FlinkSQL使用普通的SQL，您可以尝试这样做：

SELECT COUNT(*) as size FROM tab1;