You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by if...@apache.org on 2024/11/26 14:19:01 UTC
(cassandra-accord) 05/06: make CommandStoreCaches interface for integration
This is an automated email from the ASF dual-hosted git repository.
ifesdjeen pushed a commit to branch CASSANDRA-20112
in repository https://gitbox.apache.org/repos/asf/cassandra-accord.git
commit d153932f3a7ad4840a70b427477bdca24c8ea4a3
Author: Benedict Elliott Smith <be...@apache.org>
AuthorDate: Fri Nov 22 15:24:47 2024 +0000
make CommandStoreCaches interface for integration
---
.../src/main/java/accord/impl/AbstractSafeCommandStore.java | 10 +++++-----
.../src/main/java/accord/impl/InMemoryCommandStore.java | 2 +-
2 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/accord-core/src/main/java/accord/impl/AbstractSafeCommandStore.java b/accord-core/src/main/java/accord/impl/AbstractSafeCommandStore.java
index 6698a5ed..bc053ad7 100644
--- a/accord-core/src/main/java/accord/impl/AbstractSafeCommandStore.java
+++ b/accord-core/src/main/java/accord/impl/AbstractSafeCommandStore.java
@@ -42,13 +42,13 @@ extends SafeCommandStore
this.context = context;
}
- protected static abstract class CommandStoreCaches<C, TFK, CFK> implements AutoCloseable
+ public interface CommandStoreCaches<C, TFK, CFK> extends AutoCloseable
{
- abstract public void close();
+ void close();
- public abstract C acquireIfLoaded(TxnId txnId);
- public abstract CFK acquireIfLoaded(RoutingKey key);
- public abstract TFK acquireTfkIfLoaded(RoutingKey key);
+ C acquireIfLoaded(TxnId txnId);
+ CFK acquireIfLoaded(RoutingKey key);
+ TFK acquireTfkIfLoaded(RoutingKey key);
}
protected abstract Caches tryGetCaches();
diff --git a/accord-core/src/main/java/accord/impl/InMemoryCommandStore.java b/accord-core/src/main/java/accord/impl/InMemoryCommandStore.java
index 04ea28f4..17f16842 100644
--- a/accord-core/src/main/java/accord/impl/InMemoryCommandStore.java
+++ b/accord-core/src/main/java/accord/impl/InMemoryCommandStore.java
@@ -666,7 +666,7 @@ public abstract class InMemoryCommandStore extends CommandStore
}
}
- public class InMemoryCommandStoreCaches extends AbstractSafeCommandStore.CommandStoreCaches<InMemorySafeCommand, InMemorySafeTimestampsForKey, InMemorySafeCommandsForKey>
+ public class InMemoryCommandStoreCaches implements AbstractSafeCommandStore.CommandStoreCaches<InMemorySafeCommand, InMemorySafeTimestampsForKey, InMemorySafeCommandsForKey>
{
@Override
public void close() {}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@cassandra.apache.org
For additional commands, e-mail: commits-help@cassandra.apache.org