This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 209a975 Revert "[hotfix] Disable e2e execution in PRs"
add 92d3f8c [hotfix][table] Reduce friction around logical type roots
add 567baea [hotfix][table] Update FLIP-65 functions to new data
structure converters
add c1e3f15 [hotfix][table-planner-blink] Fix exception for invalid
function signature
add 11b5330 [FLINK-17541][table] Support inline structured types
No new revisions were added by this update.
Summary of changes:
.../flink/table/types/logical/LogicalTypeRoot.java | 10 +
.../flink/table/types/logical/StructuredType.java | 19 +-
.../types/logical/utils/LogicalTypeCasts.java | 2 +-
.../types/logical/utils/LogicalTypeChecks.java | 13 +
.../types/logical/utils/LogicalTypeUtils.java | 38 +-
.../flink/table/types/utils/DataTypeUtils.java | 10 +
.../flink/table/types/utils/DataTypeUtilsTest.java | 12 +
.../inference/TypeInferenceOperandInference.java | 3 +
.../planner/plan/schema/StructuredRelDataType.java | 137 +++++
.../table/planner/calcite/FlinkTypeFactory.scala | 10 +
.../flink/table/planner/codegen/CodeGenUtils.scala | 631 ++++++++++++++-------
.../planner/codegen/CodeGeneratorContext.scala | 33 +-
.../planner/codegen/EqualiserCodeGenerator.scala | 17 +-
.../table/planner/codegen/ExpressionReducer.scala | 15 +-
.../table/planner/codegen/GenerateUtils.scala | 237 +++++---
.../codegen/agg/batch/AggCodeGenHelper.scala | 34 +-
.../codegen/calls/BridgingSqlFunctionCallGen.scala | 30 +-
.../planner/runtime/stream/sql/FunctionITCase.java | 106 ++++
.../conversion/ArrayBooleanArrayConverter.java | 2 +-
.../data/conversion/ArrayByteArrayConverter.java | 2 +-
.../data/conversion/ArrayDoubleArrayConverter.java | 2 +-
.../data/conversion/ArrayFloatArrayConverter.java | 2 +-
.../data/conversion/ArrayIntArrayConverter.java | 2 +-
.../data/conversion/ArrayLongArrayConverter.java | 2 +-
.../data/conversion/ArrayObjectArrayConverter.java | 2 +-
.../data/conversion/ArrayShortArrayConverter.java | 2 +-
.../table/data/conversion/DateDateConverter.java | 2 +-
.../data/conversion/DateLocalDateConverter.java | 2 +-
.../DayTimeIntervalDurationConverter.java | 2 +-
.../conversion/DecimalBigDecimalConverter.java | 2 +-
.../table/data/conversion/IdentityConverter.java | 2 +-
.../LocalZonedTimestampInstantConverter.java | 2 +-
.../LocalZonedTimestampIntConverter.java | 2 +-
.../LocalZonedTimestampLongConverter.java | 2 +-
.../table/data/conversion/MapMapConverter.java | 2 +-
.../data/conversion/RawByteArrayConverter.java | 2 +-
.../table/data/conversion/RawObjectConverter.java | 2 +-
.../table/data/conversion/RowRowConverter.java | 2 +-
.../data/conversion/StringByteArrayConverter.java | 2 +-
.../data/conversion/StringStringConverter.java | 2 +-
.../data/conversion/StructuredObjectConverter.java | 2 +-
.../data/conversion/TimeLocalTimeConverter.java | 2 +-
.../table/data/conversion/TimeLongConverter.java | 2 +-
.../table/data/conversion/TimeTimeConverter.java | 2 +-
.../TimestampLocalDateTimeConverter.java | 2 +-
.../conversion/TimestampTimestampConverter.java | 2 +-
.../YearMonthIntervalPeriodConverter.java | 2 +-
.../table/runtime/typeutils/TypeCheckUtils.java | 18 +-
48 files changed, 1036 insertions(+), 397 deletions(-)
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/schema/StructuredRelDataType.java
