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 c0cf91c [FLINK-21894][hive] Update type of
HiveTablePartition#partitionSpec from Map<String, Object> to Map<String, String>
add 85abe70 [FLINK-21899][table] Introduce SOURCE_WATERMARK built-in
function to preserve watermark from source (#15326)
No new revisions were added by this update.
Summary of changes:
.../functions/BuiltInFunctionDefinitions.java | 10 +++++
.../runtime/stream/sql/TableSourceITCase.scala | 43 +++++++++++++++++++++-
...lFunction.java => SourceWatermarkFunction.java} | 27 ++++++++------
3 files changed, 68 insertions(+), 12 deletions(-)
copy
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/functions/scalar/{IfNullFunction.java
=> SourceWatermarkFunction.java} (53%)
