求问flink1.14.5 table api 自定义函数 支持输入输出为泛型T吗?

求问flink1.14.5 table api 自定义函数 支持输入输出为泛型T吗?

展开
收起
真的很搞笑 2023-06-05 18:44:12 131 分享 版权
1 条回答
写回答
取消 提交回答
  • 存在即是合理

    Flink 1.14.5 Table API 支持自定义函数输入输出为泛型 T。您可以在自定义函数中使用泛型 T 作为输入和输出类型。例如:

    public static <T> TableResult<T> myCustomFunction(Table table) {
      // 实现您的自定义函数逻辑
    }
    

    在上面的示例中,我们定义了一个名为 myCustomFunction 的自定义函数,它接受一个 Table 类型的参数并返回一个 TableResult<T> 类型的值。在函数内部,可以使用泛型 T 作为输入和输出类型。

    2023-06-10 15:23:49
    赞同 展开评论

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

还有其他疑问?
咨询AI助理