KSQL UDF访问ROWPARTITION等信息
KSQL UDF access ROWPARTITION and similar information
我有一个可以将结构传递给的自定义 UDF：
select my_udf(a.my_data) from MY_STREAM a;
我想做的是将所有信息从我的流传递到该自定义 UDF：
select my_udf(a) from MY_STREAM a;
这样我就可以访问行分区、时间、偏移量等。不幸的是，KSQL 不理解我的意图：
SELECT column 'A' cannot be resolved
知道如何解决这个问题吗？
无法将整行传递到 UDF，只能传递列，并且 a 是流的名称，而不是列名称。
您可以更改您的 UDF，以接受多个参数，例如，my_udf(my_data, ROWTIME, ROWPARTITION) 以单独传递所需的元数据。
我有一个可以将结构传递给的自定义 UDF：
select my_udf(a.my_data) from MY_STREAM a;
我想做的是将所有信息从我的流传递到该自定义 UDF：
select my_udf(a) from MY_STREAM a;
这样我就可以访问行分区、时间、偏移量等。不幸的是，KSQL 不理解我的意图：
SELECT column 'A' cannot be resolved
知道如何解决这个问题吗？
无法将整行传递到 UDF，只能传递列，并且 a 是流的名称，而不是列名称。
您可以更改您的 UDF，以接受多个参数，例如，my_udf(my_data, ROWTIME, ROWPARTITION) 以单独传递所需的元数据。