Apache Flink：使用filter（）或split（）来分割流？

我有一个来自Kafka的DataStream，它对MyModel中的一个字段有两个可能的值。MyModel是一个pojo，其中包含来自Kafka的消息解析的特定于域的字段。

DataStream stream = env.addSource(myKafkaConsumer);
我想分别在每个键a1，a2上应用窗口和运算符。将它们分开的好方法是什么？我有2个选项过滤器并选择，但不知道哪个更快。

过滤方式

stream

    .filter(<MyModel.a == a1>)
    .keyBy()
    .window()
    .apply()
    .addSink()

stream

    .filter(<MyModel.a == a2>)
    .keyBy()
    .window()
    .apply()
    .addSink()

拆分并选择方法

SplitStream split = stream.split(…)

split
    .select(<MyModel.a == a1>)
    …
    .addSink()

split
    .select<MyModel.a == a2>()
    …
    .addSink()

如果split和select更好，如果我想根据MyModel中字段的值进行拆分，如何实现它们？