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

Posted to commits@flink.apache.org by tw...@apache.org on 2020/03/13 09:40:51 UTC

[flink] branch master updated (d6038cc -> 6126600)

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 d6038cc  [FLINK-16524][python] Optimize the Python UDF execution to use generator to eliminate unnecessary function calls (#11374)
     add 6126600  [FLINK-16261][table] Use type compatibility consistently to avoid casting

No new revisions were added by this update.

Summary of changes:
 .../resolver/rules/ResolveCallByArgumentsRule.java |   4 +-
 .../strategies/AndArgumentTypeStrategy.java        |   4 +-
 .../strategies/ExplicitArgumentTypeStrategy.java   |   8 +-
 .../inference/strategies/MappingTypeStrategy.java  |   6 +-
 .../strategies/OrArgumentTypeStrategy.java         |   6 +-
 .../inference/strategies/OrInputTypeStrategy.java  |  10 +-
 .../types/logical/utils/LogicalTypeCasts.java      | 115 +++++++++++++++++++++
 .../types/logical/utils/LogicalTypeChecks.java     |  60 -----------
 .../apache/flink/table/utils/TypeMappingUtils.java |   3 +-
 ...Test.java => LogicalTypeCastAvoidanceTest.java} |  80 ++++++++++----
 .../types/inference/InputTypeStrategiesTest.java   |   7 ++
 .../table/types/inference/TypeStrategiesTest.java  |   7 ++
 .../inference/TypeInferenceOperandChecker.java     |  13 ++-
 .../codegen/calls/BridgingSqlFunctionCallGen.scala |   8 +-
 .../flink/table/planner/sinks/TableSinkUtils.scala |  23 ++---
 .../planner/runtime/stream/sql/FunctionITCase.java |  37 ++++++-
 16 files changed, 268 insertions(+), 123 deletions(-)
 rename flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/{LogicalTypeCompatibleCheckTest.java => LogicalTypeCastAvoidanceTest.java} (76%)