[beam] branch master updated (54fe9f6 -> 5833667)

[am...@apache.org]

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

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


    from 54fe9f6  Fix link for S3FileSystem (#12450)
     new 4e56953  [BEAM-9543] built the basis for Match_Recog
     new 72232fc  [BEAM-9543] built the basis for Match_Recog
     new 064ada7  [BEAM-9543] implemented `partition by`
     new 9cd1a82  [BEAM-9543] implemented `order by`
     new c07b8a8  [BEAM-9543] fixed `order by` coder issue
     new cdb7e9f  [BEAM-9543] fixed `order by` coder issue
     new cc63e55  [BEAM-9543] applied regex pattern match
     new b2b189d  [BEAM-9543] applied regex pattern match
     new 08abbab  [BEAM-9543] fixed sortKey serialization problem
     new 03a33c6  [BEAM-9543] fixed sortKey serialization problem
     new ec7c929  [BEAM-9543] fixed serialization problem
     new f52d96f  [BEAM-9543] recognized simple pattern
     new 8d6ffcc  [BEAM-9543] recognized simple pattern
     new a7d111f  [BEAM-9543] fixed code style
     new f529b87  [BEAM-9543] supported regex quantifier
     new 0bf24db  [BEAM-9543] added javadoc
     new 422cbe2  [BEAM-9543] removed CEPTypeName.java
     new adc2354  [BEAM-9543] added Measures implementation (unfinished)
     new ebc41a2  [BEAM-9543] added Measures implementation
     new 8793574  [BEAM-9543] added Measures implementation
     new 040d1f4  [BEAM-9543] fixed minor issues
     new 799491b  [BEAM-9543] fixed minor style issues
     new 5833667  Merge pull request #12232 from Mark-Zeng/BEAM-9543-patternRecog

The 28207 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 .../beam/sdk/extensions/sql/impl/cep/CEPCall.java  |  83 ++++
 .../CEPFieldRef.java}                              |  35 +-
 .../beam/sdk/extensions/sql/impl/cep/CEPKind.java} |  22 +-
 .../sdk/extensions/sql/impl/cep/CEPLiteral.java    | 195 ++++++++
 .../sdk/extensions/sql/impl/cep/CEPMeasure.java    |  57 +++
 .../sdk/extensions/sql/impl/cep/CEPOperation.java  |  48 ++
 .../sdk/extensions/sql/impl/cep/CEPOperator.java   |  65 +++
 .../sdk/extensions/sql/impl/cep/CEPPattern.java    | 172 +++++++
 .../beam/sdk/extensions/sql/impl/cep/CEPUtil.java  | 249 ++++++++++
 .../beam/sdk/extensions/sql/impl/cep/OrderKey.java |  74 +++
 .../extensions/sql/impl/cep/PatternCondition.java} |  19 +-
 .../sdk/extensions/sql/impl/cep/Quantifier.java}   |  33 +-
 .../sdk/extensions/sql/impl/cep}/package-info.java |   9 +-
 .../extensions/sql/impl/planner/BeamRuleSets.java  |   4 +-
 .../sdk/extensions/sql/impl/rel/BeamMatchRel.java  | 529 +++++++++++++++++++++
 .../rule/{BeamSortRule.java => BeamMatchRule.java} |  41 +-
 .../extensions/sql/impl/rel/BeamMatchRelTest.java  | 264 ++++++++++
 17 files changed, 1844 insertions(+), 55 deletions(-)
 create mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/CEPCall.java
 copy sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/{utils/SerializableRexInputRef.java => cep/CEPFieldRef.java} (53%)
 copy sdks/java/{io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/CheckpointGenerator.java => extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/CEPKind.java} (70%)
 create mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/CEPLiteral.java
 create mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/CEPMeasure.java
 create mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/CEPOperation.java
 create mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/CEPOperator.java
 create mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/CEPPattern.java
 create mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/CEPUtil.java
 create mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/OrderKey.java
 copy sdks/java/{core/src/main/java/org/apache/beam/sdk/schemas/utils/RowSelector.java => extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/PatternCondition.java} (66%)
 copy sdks/java/{io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaTimestampType.java => extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/Quantifier.java} (51%)
 copy {runners/direct-java/src/main/java/org/apache/beam/runners/direct => sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep}/package-info.java (71%)
 create mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamMatchRel.java
 copy sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/{BeamSortRule.java => BeamMatchRule.java} (59%)
 create mode 100644 sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamMatchRelTest.java