refactor: Renamed MemKeyValueFilter

redis · Jun 13, 2024 · ffa77b8 · ffa77b8
1 parent 1b938f1
commit ffa77b8
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/...ava/com/redis/riot/MemKeyValueFilter.java → ...n/java/com/redis/riot/KeyValueFilter.java b/...ava/com/redis/riot/MemKeyValueFilter.java → ...n/java/com/redis/riot/KeyValueFilter.java
@@ -11,12 +11,12 @@
 
 import io.lettuce.core.codec.RedisCodec;
 
-public class MemKeyValueFilter<K, T extends KeyValue<K, ?>> implements ItemProcessor<T, T> {
+public class KeyValueFilter<K, T extends KeyValue<K, ?>> implements ItemProcessor<T, T> {
 
 	private final Function<K, String> keyToString;
 	private final Logger log;
 
-	public MemKeyValueFilter(RedisCodec<K, ?> codec, Logger log) {
+	public KeyValueFilter(RedisCodec<K, ?> codec, Logger log) {
 		this.keyToString = BatchUtils.toStringKeyFunction(codec);
 		this.log = log;
 	}

diff --git a/plugins/riot/src/main/java/com/redis/riot/Replicate.java b/plugins/riot/src/main/java/com/redis/riot/Replicate.java
@@ -76,7 +76,7 @@ protected boolean isIgnoreStreamMessageId() {
 	}
 
 	private ItemProcessor<KeyValue<byte[], Object>, KeyValue<byte[], Object>> processor() {
-		return RiotUtils.processor(new MemKeyValueFilter<>(ByteArrayCodec.INSTANCE, log), keyValueProcessor());
+		return RiotUtils.processor(new KeyValueFilter<>(ByteArrayCodec.INSTANCE, log), keyValueProcessor());
 	}
 
 	private ItemProcessor<KeyValue<byte[], Object>, KeyValue<byte[], Object>> keyValueProcessor() {