как сделать подтип () для кортежа в flink cep?

Попробуйте этот код:

Pattern<Tuple, ?> pattern =
    Pattern.<Tuple>begin("start")
    .next("3")
        .subtype(Tuple3.class)
        .where(new FilterFunction<Tuple3>() {

            @Override
            public boolean filter(Tuple3 value) throws Exception {
                return value.f2.equals("3");
            }
        })
    .next("4")
        .subtype(Tuple2.class)
        .where(new FilterFunction<Tuple2>() {

            @Override
            public boolean filter(Tuple2 value) throws Exception {
                return value.f1.equals("3");
            }
        });

Начните с общего типа Tuple и используйте конкретные типы Tuple2 и Tuple3 для подсобытий. И поток данных для этого паттерна должен иметь тип Tuple.

что насчет этого:

    Pattern<Tuple, ?> pattern = Pattern.<Tuple>begin("start")
            .subtype(Tuple3.class)
            .where(evt -> evt.f2.equals("3"))
            .next("4")
            .subtype(Tuple2.class)
            .where(evt -> evt.f1.equals("3"))
            .within(Time.seconds(10));

1. вам не нужно добавлять следующий после начала
2. обратите внимание на буквальное значение подтипа, tuple3 и tuple2 должны расширять tuple.

Если вы хотите соединить два разных потока данных.

DataStream<Tuple2> someStream = //...
DataStream<Tuple3> otherStream = //...

ConnectedStreams<Tuple2, Tuple3> connectedStreams = someStream.connect(otherStream);

Затем вы можете использовать CoMap, CoFlatMap, чтобы получить тот же тип, например преобразовать Tuple2, Tuple3 в String: ConnectedStreams → DataStream

connectedStreams.flatMap(new CoFlatMapFunction<Tuple2, Tuple3, String>() {

   @Override
   public void flatMap1(Integer value, Collector<String> out) {
       out.collect(Tuple2.toString());
   }

   @Override
   public void flatMap2(String value, Collector<String> out) {
       for (String word: value.split(" ")) {
         out.collect(Tuple3.toString);
       }
   }
});

Вот несколько полезных ссылок, представляющих хороший вариант использования:

1. Введение в обработку сложных событий (CEP) с помощью Apache Flink
2. китайская версия, которую я перевожу