You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@ignite.apache.org by GitBox <gi...@apache.org> on 2021/12/03 16:31:01 UTC

[GitHub] [ignite-3] zstan commented on a change in pull request #484: IGNITE-15107-2 Integrate DDL into Ignite 3.0

zstan commented on a change in pull request #484:
URL: https://github.com/apache/ignite-3/pull/484#discussion_r762080473



##########
File path: modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/ddl/CreateTableCommand.java
##########
@@ -18,284 +18,125 @@
 package org.apache.ignite.internal.processors.query.calcite.prepare.ddl;
 
 import java.util.List;
+import java.util.Set;
+import org.apache.ignite.schema.definition.ColumnDefinition;
 import org.jetbrains.annotations.Nullable;
 
 /**
  * CREATE TABLE statement.
  */
-public class CreateTableCommand implements DdlCommand {
-    /**
-     * Schema name upon which this statement has been issued - <b>not</b> the name of the schema where this new table will be created.
-     */
-    private String schemaName;
-
-    /** Table name. */
-    private String tblName;
-
-    /** Cache name upon which new cache configuration for this table must be based. */
-    private String templateName;
-
-    /** Name of new cache associated with this table. */
-    private String cacheName;
-
-    /** Name of cache key type. */
-    private String keyTypeName;
-
-    /** Name of cache value type. */
-    private String valTypeName;
-
-    /** Group to put new cache into. */
-    private String cacheGrp;
-
-    //    /** Atomicity mode for new cache. */
-    //    private CacheAtomicityMode atomicityMode;
-    //
-    //    /** Write sync mode. */
-    //    private CacheWriteSynchronizationMode writeSyncMode;
-
-    /** Backups number for new cache. */
-    private Integer backups;
-
+public class CreateTableCommand extends AbstractDdlCommand {
+    /** Replicas number. */
+    private Integer replicas;
+    
+    /** Number of partitions for the new table. */
+    private Integer partitions;

Review comment:
       null means default.

##########
File path: modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/ddl/CreateTableCommand.java
##########
@@ -18,284 +18,125 @@
 package org.apache.ignite.internal.processors.query.calcite.prepare.ddl;
 
 import java.util.List;
+import java.util.Set;
+import org.apache.ignite.schema.definition.ColumnDefinition;
 import org.jetbrains.annotations.Nullable;
 
 /**
  * CREATE TABLE statement.
  */
-public class CreateTableCommand implements DdlCommand {
-    /**
-     * Schema name upon which this statement has been issued - <b>not</b> the name of the schema where this new table will be created.
-     */
-    private String schemaName;
-
-    /** Table name. */
-    private String tblName;
-
-    /** Cache name upon which new cache configuration for this table must be based. */
-    private String templateName;
-
-    /** Name of new cache associated with this table. */
-    private String cacheName;
-
-    /** Name of cache key type. */
-    private String keyTypeName;
-
-    /** Name of cache value type. */
-    private String valTypeName;
-
-    /** Group to put new cache into. */
-    private String cacheGrp;
-
-    //    /** Atomicity mode for new cache. */
-    //    private CacheAtomicityMode atomicityMode;
-    //
-    //    /** Write sync mode. */
-    //    private CacheWriteSynchronizationMode writeSyncMode;
-
-    /** Backups number for new cache. */
-    private Integer backups;
-
+public class CreateTableCommand extends AbstractDdlCommand {
+    /** Replicas number. */
+    private Integer replicas;

Review comment:
       null means default.




-- 
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: notifications-unsubscribe@ignite.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org