在Flink像这种既要split 又要where的，where条件放在那里？

在Flink中，如果您需要同时执行split和where操作，可以按照以下方式进行处理：

1. 使用split()函数将流拆分为多个流。该函数接受一个OutputSelector参数，根据指定的条件将记录发送到不同的流中。例如：

   DataStream<Integer> input = ...;
   SplitStream<Integer> splitStream = input.split(new OutputSelector<Integer>() {
    @Override
    public Iterable<String> select(Integer value) {
        List<String> outputNames = new ArrayList<>();
        if (value % 2 == 0) {
            outputNames.add("even");
        } else {
            outputNames.add("odd");
        }
        return outputNames;
    }
   });
   

   在上面的示例中，根据输入整数值的奇偶性，我们将其拆分为"even"和"odd"两个流。

2. 对拆分后的流应用filter()函数来实现where条件过滤。这将对每个流应用过滤器，只保留满足指定条件的记录。例如：

   DataStream<Integer> evenStream = splitStream.select("even");
   DataStream<Integer> filteredStream = evenStream.filter(value -> value > 10);
   

楼主你好，看了你的描述，个人觉得在 Flink 中，要同时使用 split 和 where 条件，可以使用 filter 操作符来过滤数据。

具体操作如下：

// 定义一个 SplitStream
SplitStream<String> splitStream = ...

// 根据条件对 SplitStream 进行分流
OutputTag<String> outputTag = new OutputTag<String>("side-output"){};

SingleOutputStreamOperator<String> mainStream = splitStream.filter(new FilterFunction<String>() {
     @Override
     public boolean filter(String value) throws Exception {
         // 这里可以根据条件过滤需要的数据
         return ...
     }
});

// 获取切分出来的侧输出流
SingleOutputStreamOperator<String> sideStream = mainStream.getSideOutput(outputTag);

上面代码中，如果需要根据某些条件过滤数据，可以在 filter 操作符里面实现。然后，可以使用 getSideOutput 方法获取被切分到侧输出流中的数据。