NlsString转Timestamp在flinksql 当中有办法吗?

NlsString转Timestamp在flinksql 当中有办法吗?没有找到有相关资料

展开
收起
真的很搞笑 2023-09-13 17:00:02 118 分享 版权
1 条回答
写回答
取消 提交回答
  • 在 Flink SQL 中,目前没有内置的函数或操作符来直接将 NlsString 转换为 Timestamp。不过,您可以使用自定义函数(UDF)来实现这个转换。

    下面是一个示例,展示了如何编写一个自定义函数来将 NlsString 转换为 Timestamp:
    ```import org.apache.flink.table.functions.FunctionContext;
    import org.apache.flink.table.functions.ScalarFunction;

    import java.sql.Timestamp;
    import java.time.LocalDateTime;
    import java.time.format.DateTimeFormatter;

    public class NlsStringToTimestamp extends ScalarFunction {

    private transient DateTimeFormatter formatter;

    @Override
    public void open(FunctionContext context) {
    formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
    }

    public Timestamp

    ```

    2023-09-20 16:07:25
    赞同 展开评论

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

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