Details

    • Type: Sub-task
    • Status: Closed
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 1.3.0
    • Fix Version/s: 1.3.0
    • Component/s: CEP
    • Labels:
      None

      Description

      Currently the keyed and non-keyed operators in the CEP library have different implementations. This issue targets to unify them into one.

      This new implementation will always be applied on a keyed stream, and in the case of non-keyed usecases, the input stream will be keyed on a dummy key, as done in the case of the DataStream.windowAll() method, where the input stream is keyed using the NullByteKeySelector.

      This is a first step towards making the CEP operators rescalable.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                kkl0u Kostas Kloudas
                Reporter:
                kkl0u Kostas Kloudas
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: