AMashenkov commented on code in PR #2441:
URL: https://github.com/apache/ignite-3/pull/2441#discussion_r1294899809
##########
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/schema/CatalogSqlSchemaManager.java:
##########
@@ -141,20 +133,20 @@ private static SchemaPlus createSqlSchema(int version,
CatalogSchemaDescriptor s
assert descriptor != null;
IgniteStatistic statistic = new IgniteStatistic(() -> 0.0d,
descriptor.distribution());
- Map<String, IgniteSchemaIndex> tableIndexMap =
schemaTableIndexes.getOrDefault(tableId, Collections.emptyMap());
+ Map<String, IgniteIndex> tableIndexMap =
schemaTableIndexes.getOrDefault(tableId, Collections.emptyMap());
- IgniteSchemaTable schemaTable = new IgniteSchemaTable(tableName,
tableId, version, descriptor, statistic, tableIndexMap);
+ IgniteTable schemaTable = new IgniteTableImpl(tableName, tableId,
version, descriptor, statistic, tableIndexMap);
- schemaTables.put(tableName, schemaTable);
+ schemaTables.add(schemaTable);
}
// create root schema
SchemaPlus rootSchema = Frameworks.createRootSchema(false);
- IgniteCatalogSchema igniteSchema = new IgniteCatalogSchema(schemaName,
version, schemaTables);
+ IgniteSchema igniteSchema = new IgniteSchema(schemaName, version,
schemaTables);
return rootSchema.add(schemaName, igniteSchema);
}
- private static IgniteSchemaIndex createSchemaIndex(CatalogIndexDescriptor
indexDescriptor, TableDescriptor tableDescriptor) {
+ private static IgniteIndex createSchemaIndex(CatalogIndexDescriptor
indexDescriptor, TableDescriptor tableDescriptor) {
Review Comment:
I've just replace old class content with a new one.
--
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]
