deps: Upgraded spring batch redis

redis · Jul 14, 2023 · 90d6d3f · 90d6d3f
1 parent f543750
commit 90d6d3f
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 6 deletions.
diff --git a/plugins/riot/src/main/java/com/redis/riot/cli/common/AbstractOperationImportCommand.java b/plugins/riot/src/main/java/com/redis/riot/cli/common/AbstractOperationImportCommand.java
@@ -114,9 +114,9 @@ protected RiotStep<Map<String, Object>, Map<String, Object>> step(CommandContext
 	private ItemWriter<Map<String, Object>> writer(CommandContext context) {
 		Assert.notNull(redisCommands, "RedisCommands not set");
 		Assert.isTrue(!redisCommands.isEmpty(), "No Redis command specified");
-		Builder<String, String> writer = OperationItemWriter.client(context.getRedisClient());
+		Builder<String, String> writer = OperationItemWriter.builder(context.getRedisClient());
 		configure(writer);
-		return writer(redisCommands.stream().map(OperationCommand::operation).map(writer::operation)
+		return writer(redisCommands.stream().map(OperationCommand::operation).map(writer::build)
 				.collect(Collectors.toList()));
 	}
 

diff --git a/plugins/riot/src/main/java/com/redis/riot/cli/common/RedisReaderOptions.java b/plugins/riot/src/main/java/com/redis/riot/cli/common/RedisReaderOptions.java
@@ -51,7 +51,7 @@ public class RedisReaderOptions {
 	@Option(names = "--key-slots", arity = "1..*", description = "Key slot ranges to filter keyspace notifications.", paramLabel = "<range>")
 	private List<IntRange> keySlots = new ArrayList<>();
 
-	@Option(names = "--mem-limit", description = "Maximum memory usage in MB for a key to be read (default: ${DEFAULT-VALUE}). Use 0 to disable memory usage checks.", paramLabel = "<MB>")
+	@Option(names = "--mem-limit", description = "Maximum memory usage in MB for a key to be read. Use 0 to disable memory usage checks (default: 0).", paramLabel = "<MB>")
 	private long memLimit = MemoryUsageOptions.DEFAULT_LIMIT.toMegabytes();
 
 	@Option(names = "--mem-samples", description = "Number of memory usage samples for a key (default: ${DEFAULT-VALUE}).", paramLabel = "<int>")

diff --git a/plugins/riot/src/main/java/com/redis/riot/cli/operation/NoopCommand.java b/plugins/riot/src/main/java/com/redis/riot/cli/operation/NoopCommand.java
@@ -15,7 +15,7 @@ public class NoopCommand implements OperationCommand<Map<String, Object>> {
 	private HelpOptions helpOptions = new HelpOptions();
 
 	@Override
-	public Noop<String, String, Map<String, Object>, Object> operation() {
+	public Noop<String, String, Map<String, Object>> operation() {
 		return new Noop<>();
 	}
 

diff --git a/plugins/riot/src/main/java/com/redis/riot/cli/operation/OperationCommand.java b/plugins/riot/src/main/java/com/redis/riot/cli/operation/OperationCommand.java
@@ -1,9 +1,9 @@
 package com.redis.riot.cli.operation;
 
-import com.redis.spring.batch.common.Operation;
+import com.redis.spring.batch.writer.WriteOperation;
 
 public interface OperationCommand<T> {
 
-	Operation<String, String, T, Object> operation();
+	WriteOperation<String, String, T> operation();
 
 }