Skip to content

Commit 43ea689

Browse files
authored
Revert "[Kernel] [CC Refactor #2] Add TableDescriptor and CommitCoordinatorClient API" (delta-io#3917)
This reverts commit 6ae4b62 We seem to be rethinking our Coordinated Commits CUJ / APIs, and we don't want these APIs leaked in Delta 3.3.
1 parent d4ced37 commit 43ea689

File tree

5 files changed

+1
-374
lines changed

5 files changed

+1
-374
lines changed

kernel/kernel-api/src/main/java/io/delta/kernel/TableIdentifier.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,7 @@ public boolean equals(Object o) {
6161
if (o == null || getClass() != o.getClass()) {
6262
return false;
6363
}
64-
final TableIdentifier that = (TableIdentifier) o;
64+
TableIdentifier that = (TableIdentifier) o;
6565
return Arrays.equals(getNamespace(), that.getNamespace()) && getName().equals(that.getName());
6666
}
6767

kernel/kernel-api/src/main/java/io/delta/kernel/coordinatedcommits/CommitCoordinatorClient.java

Lines changed: 0 additions & 170 deletions
This file was deleted.

kernel/kernel-api/src/main/java/io/delta/kernel/coordinatedcommits/TableDescriptor.java

Lines changed: 0 additions & 99 deletions
This file was deleted.

kernel/kernel-api/src/main/java/io/delta/kernel/engine/Engine.java

Lines changed: 0 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,6 @@
1717
package io.delta.kernel.engine;
1818

1919
import io.delta.kernel.annotation.Evolving;
20-
import io.delta.kernel.coordinatedcommits.CommitCoordinatorClient;
2120
import java.util.Map;
2221

2322
/**
@@ -57,23 +56,6 @@ public interface Engine {
5756
*/
5857
ParquetHandler getParquetHandler();
5958

60-
/**
61-
* Retrieves a {@link CommitCoordinatorClient} for the specified commit coordinator name.
62-
*
63-
* @param commitCoordinatorName The name (identifier) of the underlying commit coordinator client
64-
* to instantiate
65-
* @param commitCoordinatorConf The configuration settings for the underlying commit coordinator
66-
* client, taken directly from the Delta table property {@link
67-
* io.delta.kernel.internal.TableConfig#COORDINATED_COMMITS_TABLE_CONF}
68-
* @return A {@link CommitCoordinatorClient} implementation corresponding to the specified commit
69-
* coordinator name
70-
* @since 3.3.0
71-
*/
72-
default CommitCoordinatorClient getCommitCoordinatorClient(
73-
String commitCoordinatorName, Map<String, String> commitCoordinatorConf) {
74-
throw new UnsupportedOperationException("Not implemented");
75-
}
76-
7759
/**
7860
* Retrieves a {@link CommitCoordinatorClientHandler} for the specified commit coordinator client.
7961
*

kernel/kernel-api/src/test/scala/io/delta/kernel/coordinatedcommits/TableDescriptorSuite.scala

Lines changed: 0 additions & 86 deletions
This file was deleted.

0 commit comments

Comments
 (0)