This is an automated email from the ASF dual-hosted git repository.
fhueske pushed a change to branch
fhueske-FLINK-36642-Fix_SqlNames_of_builtin_functions
in repository https://gitbox.apache.org/repos/asf/flink.git
omit 8a1be872847 Address reviewer feedback
omit e81232e7dda [FLINK-36642][table] Fix SQL names of built-in functions
add a6c4dc50b41 [FLINK-36622] Remove the dependency of StateBenchmark on
RocksDBKeyedStateBackend APIs. (#25587)
add ed50ae21fc7 [FLINK-36571][web] Fix issue to allow Busy and
Backpressure numbers on Flink dashboard
add 03c8185090e [FLINK-36639] Use table aliases in Table API
asSerializableString (#25597)
add a5b65b9bd34 [FLINK-36644] TIMESTAMPDIFF can not be string serialized
(#25599)
add f22c50aab1f [FLINK-33722] Fix events ordering in MATCH_RECOGNIZE in
batch mode (#24699)
add f1bff1ef791 [FLINK-36011][runtime] Improved logging in
StateTransitionManager
add 0aa95e00736 [FLINK-36642][table] Fix SQL names of built-in functions
add 097d4982959 Address reviewer feedback
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (8a1be872847)
\
N -- N -- N
refs/heads/fhueske-FLINK-36642-Fix_SqlNames_of_builtin_functions (097d4982959)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.../dagre/components/node/node.component.ts | 6 +-
.../adaptive/DefaultStateTransitionManager.java | 9 +-
.../table/operations/AggregateQueryOperation.java | 21 +-
.../table/operations/CalculatedQueryOperation.java | 7 +-
.../table/operations/DistinctQueryOperation.java | 8 +-
.../table/operations/FilterQueryOperation.java | 10 +-
.../flink/table/operations/JoinQueryOperation.java | 29 +-
.../flink/table/operations/OperationUtils.java | 15 +-
.../table/operations/ProjectQueryOperation.java | 7 +-
.../flink/table/operations/SetQueryOperation.java | 2 +-
.../flink/table/operations/SortQueryOperation.java | 13 +-
.../table/operations/SourceQueryOperation.java | 12 +-
.../table/operations/ValuesQueryOperation.java | 9 +-
.../operations/WindowAggregateQueryOperation.java | 14 +-
.../utils/OperationExpressionsUtils.java | 54 +++
.../expressions/ExpressionSerializationTest.java | 101 +++--
.../expressions/FieldReferenceExpression.java | 26 +-
.../functions/BuiltInFunctionDefinitions.java | 14 +
.../plan/nodes/exec/batch/BatchExecMatch.java | 72 ++-
.../plan/nodes/exec/common/CommonExecMatch.java | 24 +-
.../plan/nodes/exec/stream/StreamExecMatch.java | 16 +-
.../table/api/QueryOperationSqlExecutionTest.java | 3 +-
.../api/QueryOperationSqlSerializationTest.java | 3 +-
.../table/api/QueryOperationTestPrograms.java | 190 +++++---
.../runtime/batch/sql/MatchRecognizeITCase.java | 495 +++++++++++++++++----
.../benchmark/StateBackendBenchmarkUtils.java | 18 +-
26 files changed, 936 insertions(+), 242 deletions(-)
