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/)来提交作业监控集群的状态和正在运行的作业。