You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by di...@apache.org on 2022/06/28 09:52:26 UTC

[flink] branch master updated (6f7c273be14 -> 4a82df07d70)

This is an automated email from the ASF dual-hosted git repository.

dianfu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


    from 6f7c273be14 [FLINK-27304][hive] Calcite's varbinary type should be converted to Hive's binary type.
     add 4a82df07d70 [FLINK-27392][cep] CEP Pattern supports definition of the maximum time gap between events

No new revisions were added by this update.

Summary of changes:
 .../org/apache/flink/cep/nfa/ComputationState.java |  31 ++-
 .../org/apache/flink/cep/nfa/MigrationUtils.java   |   2 +-
 .../main/java/org/apache/flink/cep/nfa/NFA.java    |  47 +++-
 .../apache/flink/cep/nfa/NFAStateSerializer.java   |  31 ++-
 .../flink/cep/nfa/NFAStateSerializerSnapshot.java  |  40 ++-
 .../apache/flink/cep/nfa/compiler/NFACompiler.java |  81 ++++--
 .../cep/nfa/compiler/NFAStateNameHandler.java      |   2 +-
 .../java/org/apache/flink/cep/pattern/Pattern.java | 100 ++++++-
 .../org/apache/flink/cep/pattern/Quantifier.java   |  29 +-
 ...formedPatternException.java => WithinType.java} |  17 +-
 .../test/java/org/apache/flink/cep/CEPITCase.java  | 131 ++++++++-
 .../apache/flink/cep/NFASerializerUpgradeTest.java |   5 +-
 .../java/org/apache/flink/cep/nfa/NFAITCase.java   | 305 ++++++++++++++++++++-
 .../java/org/apache/flink/cep/nfa/NFATest.java     |  49 +++-
 .../org/apache/flink/cep/nfa/NotPatternITCase.java |  26 +-
 .../apache/flink/cep/nfa/TimesOrMoreITCase.java    | 136 +++++----
 .../org/apache/flink/cep/nfa/TimesRangeITCase.java | 145 ++++++----
 .../flink/cep/nfa/compiler/NFACompilerTest.java    |  41 +++
 18 files changed, 1015 insertions(+), 203 deletions(-)
 copy flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/{MalformedPatternException.java => WithinType.java} (70%)