tkalkirill commented on code in PR #2500:
URL: https://github.com/apache/ignite-3/pull/2500#discussion_r1319480239
##########
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/TableManager.java:
##########
@@ -1233,20 +1130,77 @@ public boolean
removeAssignmentsChangeListener(Consumer<IgniteTablesInternal> li
return assignmentsChangeListeners.remove(listener);
}
+ /**
+ * Creates local structures for a table.
+ *
+ * @param causalityToken Causality token.
+ * @param catalogVersion Catalog version on which the table was created.
+ * @param tableDescriptor Catalog table descriptor.
+ * @return Future that will be completed when local changes related to the
table creation are applied.
+ */
+ private CompletableFuture<?> createTableLocally(long causalityToken, int
catalogVersion, CatalogTableDescriptor tableDescriptor) {
+ int tableId = tableDescriptor.id();
+
+ if (!busyLock.enterBusy()) {
+ fireEvent(TableEvent.CREATE, new
TableEventParameters(causalityToken, tableId), new NodeStoppingException());
Review Comment:
Now no one is listening to this event, we will get rid of it in
[IGNITE-20339](https://issues.apache.org/jira/browse/IGNITE-20339)
--
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]
