flink的udtf中String[]转String数组

因爲udtf需要進1出3

於是就有了String[]转String数组的需要，

具體實現如下:

 

    public void eval(String str) {
        String[] split = str.split("#");
//        for (String s : split)
//        {
//            collect(s);
//        }

        Tuple3<String,String,String> tuple3=Tuple3.of(split[0],split[1],split[2]);
        collect(tuple3);

    }

总结

以上是生活随笔为你收集整理的flink的udtf中String[]转String数组的全部内容，希望文章能够帮你解决所遇到的问题。

如果觉得生活随笔网站内容还不错，欢迎将生活随笔推荐给好友。