Realtime Compute for Apache Flink:Regras CEP dinâmicas: formato JSON e uso

Definição de nó

Um nó representa um padrão único e completo.

Definição de quantificador

Um quantificador especifica quantas vezes os eventos devem corresponder a um padrão e a estratégia de contiguidade dentro desse padrão. Por exemplo, o padrão A* tem o valor properties definido como LOOPING e uma consumingStrategy de SKIP_TILL_ANY.

Exemplo de valor times:

"times": {
  "from": 3,
  "to": 3,
  "windowTime": {
    "unit": "MINUTES",
    "size": 12
  }
}

Os campos from e to são inteiros. O campo unit em windowTime aceita DAYS, HOURS, MINUTES, SECONDS ou MILLISECONDS. Defina windowTime como null para omitir a restrição de tempo por correspondência.

Definição de condição

Uma condição filtra eventos que atendem a critérios específicos. Por exemplo, "navegação por mais de 5 minutos" é uma condição que filtra clientes pela duração da sessão.

Definição de aresta

Uma aresta conecta dois nós de padrão e define a estratégia de seleção de eventos para essa transição.

Definição de GraphNode

Um GraphNode representa uma sequência completa de padrões. Ele estende o nó básico com campos de estrutura de grafo (nodes e edges) e campos de política (window e afterMatchSkipStrategy). Como GraphNode é tratado como subtipo de Node, é possível aninhar um GraphNode dentro de outro GraphNode para criar padrões agrupados (GroupPattern).

Campo Window:

O campo window restringe o tempo permitido para uma correspondência completa. O type controla a aplicação do limite de tempo:

• FIRST_AND_LAST: tempo máximo entre o primeiro e o último evento em uma correspondência completa.

• PREVIOUS_AND_CURRENT: tempo máximo entre correspondências de quaisquer dois padrões filhos adjacentes.

Exemplo:

"window": {
  "type": "FIRST_AND_LAST",
  "time": {
    "unit": "DAYS",
    "size": 1
  }
}

O campo unit aceita DAYS, HOURS, MINUTES, SECONDS ou MILLISECONDS. O valor size é um long ou integer.

Definição de estratégia de salto pós-correspondência

A estratégia de salto pós-correspondência controla quais correspondências parciais descartar após encontrar uma correspondência completa.

As estratégias apresentam os seguintes comportamentos:

• NO_SKIP (padrão): Emite todas as correspondências bem-sucedidas sem descartar nenhuma.

• SKIP_TO_NEXT: Descarta todas as correspondências parciais iniciadas com o mesmo evento da correspondência atual.

• SKIP_PAST_LAST_EVENT: Descarta todas as correspondências parciais iniciadas entre o início e o fim da correspondência atual.

• SKIP_TO_FIRST: Descarta todas as correspondências parciais iniciadas entre o início da correspondência atual e a primeira ocorrência do evento nomeado por patternName.

• SKIP_TO_LAST: Descarta todas as correspondências parciais iniciadas entre o início da correspondência atual e a última ocorrência do evento nomeado por patternName.

Para mais informações, consulte Estratégia de salto pós-correspondência.

Definição de contiguidade

A contiguidade controla o rigor com que os eventos devem se suceder dentro de um padrão ou ao longo de uma aresta.

Para mais informações, consulte FlinkCEP — Processamento complexo de eventos para Flink.

Valores de propriedade do quantificador

As propriedades do quantificador descrevem a cardinalidade e a estratégia de correspondência para um padrão.

Pattern<Event, Event> pattern =
    Pattern.<Event>begin("start")
            .where(new StartCondition())
            .optional()
            .followedBy("middle")
            .where(new MiddleCondition())
            .timesOrMore(3)
            .notFollowedBy("end")
            .where(new EndCondition())
            .within(Time.minutes(10));

{
  "name": "end",
  "quantifier": {
    "consumingStrategy": "SKIP_TILL_NEXT",
    "properties": [
      "SINGLE"
    ],
    "times": null,
    "untilCondition": null
  },
  "condition": null,
  "nodes": [
    {
      "name": "end",
      "quantifier": {
        "consumingStrategy": "SKIP_TILL_NEXT",
        "properties": [
          "SINGLE"
        ],
        "times": null,
        "untilCondition": null
      },
      "condition": {
        "className": "com.alibaba.ververica.cep.demo.condition.EndCondition",
        "type": "CLASS"
      },
      "type": "ATOMIC"
    },
    {
      "name": "middle",
      "quantifier": {
        "consumingStrategy": "SKIP_TILL_NEXT",
        "properties": [
          "LOOPING"
        ],
        "times": {
          "from": 3,
          "to": 3,
          "windowTime": null
        },
        "untilCondition": null
      },
      "condition": {
        "className": "com.alibaba.ververica.cep.demo.condition.MiddleCondition",
        "type": "CLASS"
      },
      "type": "ATOMIC"
    },
    {
      "name": "start",
      "quantifier": {
        "consumingStrategy": "SKIP_TILL_NEXT",
        "properties": [
          "SINGLE",
          "OPTIONAL"
        ],
        "times": null,
        "untilCondition": null
      },
      "condition": {
        "className": "com.alibaba.ververica.cep.demo.condition.StartCondition",
        "type": "CLASS"
      },
      "type": "ATOMIC"
    }
  ],
  "edges": [
    {
      "source": "middle",
      "target": "end",
      "type": "NOT_FOLLOW"
    },
    {
      "source": "start",
      "target": "middle",
      "type": "SKIP_TILL_NEXT"
    }
  ],
  "window": {
    "type": "FIRST_AND_LAST",
    "time": {
      "unit": "MINUTES",
      "size": 10
    }
  },
  "afterMatchStrategy": {
    "type": "NO_SKIP",
    "patternName": null
  },
  "type": "COMPOSITE",
  "version": 1
}

"condition": {
    "args": [
        "A", "B"
    ],
    "className": "org.apache.flink.cep.pattern.conditions.CustomMiddleCondition",
    "type": "CLASS"
}

"condition": {
    "args": [
        "A", "B", "C"
    ],
    "className": "org.apache.flink.cep.pattern.conditions.CustomMiddleCondition",
    "type": "CLASS"
}