Moved executeDDL

BodoSQL/bodosql/context.py

@@ -1416,7 +1416,7 @@ def execute_ddl(
 
         if bodo.get_rank() == 0:
             try:
-                ddl_result = generator.executeDDL(sql)
+                ddl_result = JavaEntryPoint.executeDDL(generator, sql)
                 # Convert the output to a DataFrame.
                 column_names = list(ddl_result.getColumnNames())
                 column_types = [

BodoSQL/calcite_sql/bodosql-calcite-application/src/main/java/com/bodosql/calcite/application/PythonEntryPoint.kt

@@ -1,5 +1,6 @@
 package com.bodosql.calcite.application
 
+import com.bodosql.calcite.ddl.DDLExecutionResult
 import com.bodosql.calcite.table.ColumnDataTypeInfo
 
 /**
@@ -113,5 +114,19 @@ class PythonEntryPoint {
             generator: RelationalAlgebraGenerator,
             sql: String,
         ): String = generator.getWriteType(sql)
+
+        /**
+         * Execute the given DDL statement in an interpreted manner. This
+         * assumes/requires that sql is a DDL statement, which should have
+         * already been checked.
+         * @param generator The generator to use.
+         * @param sql The DDL statement to execute
+         * @return The result of the DDL execution.
+         */
+        @JvmStatic
+        fun executeDDL(
+            generator: RelationalAlgebraGenerator,
+            sql: String,
+        ): DDLExecutionResult = generator.executeDDL(sql)
     }
 }

BodoSQL/calcite_sql/bodosql-calcite-application/src/main/java/com/bodosql/calcite/application/RelationalAlgebraGenerator.java

@@ -685,6 +685,15 @@ PandasCodeSqlPlanPair getPandasAndPlanString(
     }
   }
 
+  /**
+   * Return the Python code generated for the given SQL query.
+   *
+   * @param sql The SQL query to process.
+   * @param dynamicParamTypes The dynamic parameter types.
+   * @param namedParamTypeMap The named parameter types.
+   * @return The Python code generated for the given SQL query.
+   * @throws Exception If an error occurs while processing the SQL query.
+   */
   String getPandasString(
       @NonNull String sql,
       @NonNull List<ColumnDataTypeInfo> dynamicParamTypes,
@@ -732,9 +741,14 @@ String getWriteType(String sql) throws Exception {
     }
   }
 
-  // ~~~~~~~~~~~~~PYTHON EXPOSED APIS~~~~~~~~~~~~~~
-
-  public DDLExecutionResult executeDDL(String sql) throws Exception {
+  /**
+   * Execute the given DDL statement in an interpreted manner. This assumes/requires that sql is a
+   * DDL statement, which should have already been checked.
+   *
+   * @param sql The DDL statement to execute
+   * @return The result of the DDL execution.
+   */
+  DDLExecutionResult executeDDL(String sql) throws Exception {
     try {
       // DDL doesn't support dynamic or named parameters at this time.
       SqlNode validatedSqlNode = validateQuery(sql, List.of(), Map.of());
@@ -751,6 +765,8 @@ public DDLExecutionResult executeDDL(String sql) throws Exception {
     }
   }
 
+  // ~~~~~~~~~~~~~PYTHON EXPOSED APIS~~~~~~~~~~~~~~
+
   /**
    * Determine if the active query is a DDL query that is not treated like compute (not CTAS).
    *