我正在編寫一個簡單的示例，用於在Flink中使用最新的Github版本1.1-SNAPSHOT測試新的Scala API for CEP。 該模式只是一個值的檢查，併爲匹配的每個模式輸出一個字符串作爲結果。代碼如下： val pattern : Pattern[(String, Long, Int), _] = Pattern.begin("start").where(_._3 < 4)
va
我是Flink Streaming API的新手，我想完成以下簡單（IMO）任務。我有兩個流，我想使用基於計數的窗口來加入它們。我到目前爲止的代碼如下： public class BaselineCategoryEquiJoin {
private static final String recordFile = "some_file.txt";
private static class