This is an automated email from the ASF dual-hosted git repository.
jark pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from dfb4c00 [FLINK-22054][dist] Suppress the verbose log in kubernetes
informer
add cd7ca29 [FLINK-21911][table-api] Add built-in greatest/least
functions support
No new revisions were added by this update.
Summary of changes:
docs/data/sql_functions.yml | 8 +-
docs/data/sql_functions_zh.yml | 4 +
.../typeutils/runtime/NullAwareComparator.java | 2 +-
.../main/java/org/apache/flink/types/RowUtils.java | 2 +-
.../apache/flink/types/NormalizableKeyTest.java | 2 +-
.../utils/AggregateOperationFactory.java | 6 +-
.../apache/flink/table/data/GenericMapData.java | 2 +-
.../functions/BuiltInFunctionDefinitions.java | 30 +++++-
.../table/types/inference/InputTypeStrategies.java | 6 +-
.../strategies/ComparableTypeStrategy.java | 26 ++---
.../strategies/SpecificInputTypeStrategies.java | 4 +-
.../flink/table/types/logical/LogicalTypeRoot.java | 2 +-
.../flink/table/types/logical/StructuredType.java | 32 +++---
.../types/logical/utils/LogicalTypeDuplicator.java | 2 +-
.../flink/table/types/utils/DataTypeUtils.java | 2 +-
.../inference/ComparableInputTypeStrategyTest.java | 42 ++++----
.../exec/serde/LogicalTypeJsonDeserializer.java | 10 +-
.../exec/serde/LogicalTypeJsonSerializer.java | 4 +-
.../planner/plan/schema/StructuredRelDataType.java | 4 +-
.../table/planner/codegen/ExprCodeGenerator.scala | 27 +++--
.../table/planner/codegen/GenerateUtils.scala | 2 +-
.../planner/codegen/calls/ScalarOperatorGens.scala | 51 +++++++++
.../functions/GreatestLeastFunctionsITCase.java | 118 +++++++++++++++++++++
.../nodes/exec/serde/LogicalTypeSerdeTest.java | 2 +-
.../nodes/exec/serde/RelDataTypeSerdeTest.java | 2 +-
...stDistinctAggCalls[isMiniBatchEnabled=true].out | 8 +-
.../testIncrementalAggregate.out | 4 +-
.../testDistinctSplitEnabled.out | 4 +-
.../testEventTimeTumbleWindow.out | 16 +--
.../testEventTimeTumbleWindowWithOffset.out | 16 +--
.../testEventTimeTumbleWindow.out | 8 +-
.../stream/PartitionTimeCommitPredicate.java | 2 +-
.../runtime/operators/sort/SortLimitOperator.java | 2 +-
33 files changed, 332 insertions(+), 120 deletions(-)
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/GreatestLeastFunctionsITCase.java
