raminqaf commented on code in PR #28793:
URL: https://github.com/apache/flink/pull/28793#discussion_r3656173711
##########
flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/Catalog.java:
##########
@@ -1041,6 +1041,26 @@ default void alterConnection(
this.getClass()));
}
+ /**
+ * Rename an existing connection.
+ *
+ * @param connectionPath Path of the connection to be renamed
+ * @param newConnectionName the new name of the connection
+ * @param ignoreIfNotExists Flag to specify behavior when the connection
does not exist: if set
+ * to false, throw an exception, if set to true, do nothing.
+ * @throws ConnectionNotExistException if the connection does not exist
+ * @throws ConnectionAlreadyExistException if a connection with the new
name already exists
+ * @throws CatalogException in case of any runtime exception
+ */
+ default void renameConnection(
+ ObjectPath connectionPath, String newConnectionName, boolean
ignoreIfNotExists)
+ throws ConnectionNotExistException,
ConnectionAlreadyExistException, CatalogException {
+ throw new UnsupportedOperationException(
+ String.format(
+ "renameConnection(ObjectPath, String, boolean) is not
implemented for %s.",
+ this.getClass()));
+ }
+
Review Comment:
Moreover, in the PR description you mentioned:
> The public API, i.e., is any changed class annotated with
`@Public(Evolving)`: (yes / no) no
Which is not the case here
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
