0
点赞
收藏
分享

微信扫一扫

【Flink1.14实战】Flink DataStream 算子快速开始 Filter

whiteMu 2022-04-13 阅读 63

Filter

DataStream → DataStream

过滤流。过滤掉零值的过滤器

package quick;

import org.apache.flink.api.common.functions.FilterFunction;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

public class FilterExample {

    public static void main(String[] args) throws Exception {

        final StreamExecutionEnvironment env =     StreamExecutionEnvironment.getExecutionEnvironment();

        DataStream<Integer> dataStream = env
                .fromElements(0,1, 2, 3, 4, 5)
                .filter(new FilterFunction<Integer>() {
                    @Override
                    public boolean filter(Integer value) throws Exception {
                        return value != 0;
                    }
                });

        dataStream.print();

        env.execute("FilterExample job");
    }

}

修改pom

1.0.1
quick.FilterExample


然后,将打包应用程序提交,Flink 的[Web UI](http://localhost:8081/)来提交作业监控集群的状态和正在运行的作业。

举报

相关推荐

0 条评论