Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-13881

CEP within method should applied in every independent pattern

    XMLWordPrintableJSON

    Details

      Description

      When I write a Pattern like this:

      Pattern.begin("start").where()
        .followBy("middle0").where().within(Time.second(1))
        .followBy("middle1").where().within(Time.second(2))
        .followBy("middle2").where().within(Time.second(3))
      

      the actual within time is the smallest: 1 second.

      I created a TimeCondition extends IterativeCondition, and I can get timestamp of current event and previous computation state, then I compare them in condition filter. Also make some change in NFACompiler, transform within as StateTransition rather than a gobal property "windowTime" of NFA.
      It could work, but I dont know should I change the implementation of within or create another syntax.
      [~dawidwys] Is this meaningful?

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                Unassigned
                Reporter:
                liuyufei YufeiLiu
              • Votes:
                0 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated: