raminqaf commented on code in PR #27292:
URL: https://github.com/apache/flink/pull/27292#discussion_r2577018876
##########
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/SqlNodeConverters.java:
##########
@@ -59,63 +59,84 @@ public class SqlNodeConverters {
static {
// register all the converters here
- register(new SqlCreateCatalogConverter());
- register(new SqlAlterCatalogOptionsConverter());
- register(new SqlAlterCatalogResetConverter());
- register(new SqlAlterCatalogCommentConverter());
- register(new SqlCreateViewConverter());
- register(new SqlAlterViewRenameConverter());
- register(new SqlAlterViewPropertiesConverter());
- register(new SqlAlterViewAsConverter());
- register(new SqlAlterTableAddPartitionConverter());
- register(new SqlAlterTableDropPartitionConverter());
register(new SqlQueryConverter());
register(new SqlShowPartitionsConverter());
- register(new SqlTruncateTableConverter());
register(new SqlShowFunctionsConverter());
- register(new SqlShowModelsConverter());
- register(new SqlShowCreateModelConverter());
register(new SqlShowProcedureConverter());
- register(new SqlReplaceTableAsConverter());
register(new SqlProcedureCallConverter());
register(new SqlShowDatabasesConverter());
- register(new SqlShowCreateCatalogConverter());
- register(new SqlDescribeCatalogConverter());
register(new SqlDescribeJobConverter());
- register(new SqlCreateOrAlterMaterializedTableConverter());
- register(new SqlCreateModelConverter());
- register(new SqlAlterMaterializedTableRefreshConverter());
- register(new SqlAlterMaterializedTableSuspendConverter());
- register(new SqlAlterMaterializedTableResumeConverter());
- register(new SqlAlterMaterializedTableAsQueryConverter());
- register(new SqlAlterMaterializedTableAddDistributionConverter());
- register(new SqlAlterMaterializedTableModifyDistributionConverter());
- register(new SqlAlterMaterializedTableDropDistributionConverter());
- register(new SqlAlterModelRenameConverter());
- register(new SqlAlterModelResetConverter());
- register(new SqlAlterModelSetConverter());
- register(new SqlDropMaterializedTableConverter());
- register(new SqlDropModelConverter());
- register(new SqlShowTablesConverter());
- register(new SqlShowCatalogsConverter());
- register(new SqlDescribeFunctionConverter());
- register(new SqlDescribeModelConverter());
- register(new SqlCreateTableAsConverter());
- register(new SqlCreateTableConverter());
- register(new SqlCreateTableLikeConverter());
+
+ registerCatalogConverters();
+ registerMaterializedTableConverters();
+ registerModelConverters();
+ registerTableConverters();
+ registerViewConverters();
Review Comment:
Nice!
--
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]
