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

Posted to commits@flink.apache.org by yu...@apache.org on 2023/06/29 09:34:40 UTC

[flink] branch master updated (ccb8e9f291d -> c11fd82e0cc)

This is an automated email from the ASF dual-hosted git repository.

yuxia pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


    from ccb8e9f291d [FLINK-17398][connector/filesystem] Filesystem sources support flexible path reading (#22249)
     add c11fd82e0cc [FLINK-32351][table] Introduce base interfaces for call procedure (#22821)

No new revisions were added by this update.

Summary of changes:
 flink-python/pyflink/table/catalog.py              |  26 ++++-
 .../flink/table/procedure/ProcedureContext.java}   |  26 ++---
 .../{FunctionHint.java => ProcedureHint.java}      |  93 +++++++---------
 .../{FunctionHints.java => ProcedureHints.java}    |   6 +-
 .../org/apache/flink/table/catalog/Catalog.java    |  16 +++
 ...eption.java => ProcedureNotExistException.java} |  16 +--
 .../apache/flink/table/procedures/Procedure.java   | 117 +++++++++++++++++++++
 7 files changed, 218 insertions(+), 82 deletions(-)
 copy flink-table/{flink-table-api-java/src/main/java/org/apache/flink/table/api/TumbleWithSizeOnTimeWithAlias.java => flink-table-api-java-bridge/src/main/java/org/apache/flink/table/procedure/ProcedureContext.java} (60%)
 copy flink-table/flink-table-common/src/main/java/org/apache/flink/table/annotation/{FunctionHint.java => ProcedureHint.java} (61%)
 copy flink-table/flink-table-common/src/main/java/org/apache/flink/table/annotation/{FunctionHints.java => ProcedureHints.java} (90%)
 copy flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/exceptions/{FunctionAlreadyExistException.java => ProcedureNotExistException.java} (64%)
 create mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/procedures/Procedure.java