本文整理了Java中org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator.filter()方法的一些代码示例，展示了SingleOutputStreamOperator.filter()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。SingleOutputStreamOperator.filter()方法的具体详情如下：
包路径：org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator
类名称：SingleOutputStreamOperator
方法名：filter

SingleOutputStreamOperator.filter介绍

暂无

代码示例

代码示例来源：origin: apache/flink

.filter(dummyFilter).slotSharingGroup("default").disableChaining()
.filter(dummyFilter).slotSharingGroup("group 1")
.filter(dummyFilter).startNewChain()
.print().disableChaining();
  .filter(dummyFilter).slotSharingGroup("default").disableChaining()
  .filter(dummyFilter).slotSharingGroup("group 2")
  .filter(dummyFilter).startNewChain()
  .print().disableChaining();

代码示例来源：origin: apache/flink

@Test
public void testUserProvidedHashing() {
  StreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironment();
  List<String> userHashes = Arrays.asList("aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa", "bbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbb");
  env.addSource(new NoOpSourceFunction(), "src").setUidHash(userHashes.get(0))
      .map(new NoOpMapFunction())
      .filter(new NoOpFilterFunction())
      .keyBy(new NoOpKeySelector())
      .reduce(new NoOpReduceFunction()).name("reduce").setUidHash(userHashes.get(1));
  StreamGraph streamGraph = env.getStreamGraph();
  int idx = 1;
  for (JobVertex jobVertex : streamGraph.getJobGraph().getVertices()) {
    List<JobVertexID> idAlternatives = jobVertex.getIdAlternatives();
    Assert.assertEquals(idAlternatives.get(idAlternatives.size() - 1).toString(), userHashes.get(idx));
    --idx;
  }
}

代码示例来源：origin: apache/flink

.filter(new NoOpFilterFunction())
.addSink(new NoOpSinkFunction());
.map(new NoOpMapFunction())
.startNewChain()
.filter(new NoOpFilterFunction())
.addSink(new NoOpSinkFunction());

代码示例来源：origin: apache/flink

.map(new NoOpMapFunction()).name("map")
.startNewChain()
.filter(new NoOpFilterFunction())
.addSink(new NoOpSinkFunction());
.map(new NoOpMapFunction()).name("map")
.startNewChain()
.filter(new NoOpFilterFunction())
.startNewChain()
.addSink(new NoOpSinkFunction());

代码示例来源：origin: apache/flink

@Test
public void testUserProvidedHashingOnChainSupported() {
  StreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironment();
  env.addSource(new NoOpSourceFunction(), "src").setUidHash("aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa")
      .map(new NoOpMapFunction()).setUidHash("bbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbb")
      .filter(new NoOpFilterFunction()).setUidHash("cccccccccccccccccccccccccccccccc")
      .keyBy(new NoOpKeySelector())
      .reduce(new NoOpReduceFunction()).name("reduce").setUidHash("dddddddddddddddddddddddddddddddd");
  env.getStreamGraph().getJobGraph();
}

代码示例来源：origin: apache/flink

.addSource(new NoOpSourceFunction(), "src0")
.map(new NoOpMapFunction())
.filter(new NoOpFilterFunction())
.keyBy(new NoOpKeySelector())
.reduce(new NoOpReduceFunction()).name("reduce");
.addSource(new NoOpSourceFunction(), "src0")
.map(new NoOpMapFunction())
.filter(new NoOpFilterFunction())
.keyBy(new NoOpKeySelector())
.reduce(new NoOpReduceFunction()).name("reduce");

代码示例来源：origin: dataArtisans/flink-training-exercises

.filter((Tuple4<Integer, Long, Boolean, Integer> count) -> (count.f3 >= popThreshold))

代码示例来源：origin: wuchong/my-flink-project

.filter(new FilterFunction<UserBehavior>() {
  @Override
  public boolean filter(UserBehavior userBehavior) throws Exception {

代码示例来源：origin: dataArtisans/flink-training-exercises

.filter((Tuple4<Integer, Long, Boolean, Integer> count) -> (count.f3 >= popThreshold))

代码示例来源：origin: dataArtisans/flink-dataflow

intermDataStream.filter(new FilterFunction<WindowedValue<RawUnionValue>>() {
  @Override
  public boolean filter(WindowedValue<RawUnionValue> value) throws Exception {

代码示例来源：origin: dataArtisans/flink-training-exercises

.filter((Tuple4<Integer, Long, Boolean, Integer> count) -> (count.f3 >= popThreshold))

代码示例来源：origin: com.alibaba.blink/flink-examples-streaming

filter(
    (FilterFunction<Customer>) c -> c.getMktsegment().equals("AUTOMOBILE")).
  setParallelism(customParallelism).
orders = orders.filter(
          new FilterFunction<Order>() {
            private final DateFormat format = new SimpleDateFormat("yyyy-MM-dd");
lineitems = lineitems.filter(
            new FilterFunction<Lineitem>() {
              private final DateFormat format = new SimpleDateFormat("yyyy-MM-dd");