CommandLine.IVersionProvider implementation that returns
version information from the jar file's /META-INF/MANIFEST.MF file.ItemReader that generates HashMaps using Faker.WritableByteChannel that delays actually writing to or
closing the buffer if a transaction is active.ItemStreamReader implementation that reads XML objects from a Resource having the following format:ItemStreamReader implementation that reads XML objects from a Resource having the following format:XmlResourceItemWriter.protected LongSupplierinitialMaxSupplier(String stepName,
+
+
+
+
+
+
+
+
+
+protected LongSupplier
+initialMaxSupplier(String stepName,
org.springframework.batch.item.ItemReader<?> reader)
+
+protected AbstractRedisCallable
+runnable()
-protected AbstractRedisRunnable
-runnable()
+void
+setKeyFilterArgs(KeyFilterArgs keyFilterArgs)
void
void
-setProgressStyle(com.redis.riot.cli.AbstractRiotCommand.ProgressStyle style)
+setProcessorArgs(KeyValueProcessorArgs processorArgs)
+
+void
+setProgressStyle(com.redis.riot.cli.AbstractRiotCommand.ProgressStyle style)
+
+void
+setReaderArgs(RedisReaderArgs readerArgs)
protected String
@@ -204,7 +222,7 @@ Method Details
runnable
-
+
@@ -221,6 +239,42 @@ initialMaxSupplier
+
+getReaderArgs
+
+
+
+
+
+setReaderArgs
+
+
+
+
+
+getProcessorArgs
+
+
+
+
+
+setProcessorArgs
+
+
+
+
+
+getKeyFilterArgs
+
+
+
+
+
+setKeyFilterArgs
+
+
+
+
setName
diff --git a/api/com/redis/riot/cli/AbstractImportCommand.html b/api/com/redis/riot/cli/AbstractImportCommand.html
index b1360ebc1..3ca61f942 100644
--- a/api/com/redis/riot/cli/AbstractImportCommand.html
+++ b/api/com/redis/riot/cli/AbstractImportCommand.html
@@ -140,7 +140,7 @@ Method Summary
-protected abstract AbstractImport
+protected abstract AbstractMapImport
protected LongSupplier
@@ -150,7 +150,7 @@ Method Summary
-protected AbstractImport
+protected AbstractMapImport
runnable()
void
@@ -231,13 +231,13 @@ operations
runnable
-
+
importRunnable
-
+
diff --git a/api/com/redis/riot/cli/AbstractMainCommand.html b/api/com/redis/riot/cli/AbstractMainCommand.html
index 7f8f02c95..a618d5c77 100644
--- a/api/com/redis/riot/cli/AbstractMainCommand.html
+++ b/api/com/redis/riot/cli/AbstractMainCommand.html
@@ -115,20 +115,26 @@ Method Summary
Modifier and Type
Method
Description
-void
-run()
+
+
-static int
-run(AbstractMainCommand cmd,
+void
+run()
+
+static int
+run(AbstractMainCommand cmd,
PrintWriter out,
PrintWriter err,
String[] args,
picocli.CommandLine.IExecutionStrategy... executionStrategies)
-
-static int
-run(AbstractMainCommand cmd,
- String... args)
+static int
+run(AbstractMainCommand cmd,
+ String... args)
+
+void
+setRedisArgs(RedisArgs redisArgs)
+
protected abstract AbstractStructImportprotected abstract AbstractImportprotected LongSupplierinitialMaxSupplier(String stepName,
org.springframework.batch.item.ItemReader<?> reader) protected AbstractStructImportprotected AbstractImportrunnable()voidDbExportArgs, DbImportArgsgetUrl()voidvoidsetPassword(String password) voidvoidsetUsername(String username) dataSourceOptionsgetSql()booleanvoidsetAssertUpdates(boolean assertUpdates) voidvoidsetKeyRegex(Pattern keyRegex) voidvoidsetProgressStyle(com.redis.riot.cli.AbstractRiotCommand.ProgressStyle style) voidsetProgressStyle(com.redis.riot.cli.AbstractRiotCommand.ProgressStyle style) protected StringinitialMaxSupplier, runnablegetKeyFilterArgs, getProcessorArgs, getReaderArgs, initialMaxSupplier, runnable, setKeyFilterArgs, setProcessorArgs, setReaderArgs
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitdataSourceOptionsprotected AbstractImportintintintintgetSql()protected AbstractMapImportprotected LongSupplierinitialMaxSupplier(String stepName,
org.springframework.batch.item.ItemReader<?> reader) booleanbooleanvoidvoidsetFetchSize(int fetchSize) voidsetMaxItemCount(int maxItemCount) voidsetMaxResultSetRows(int maxResultSetRows) voidvoidsetProgressStyle(com.redis.riot.cli.AbstractRiotCommand.ProgressStyle style) voidsetQueryTimeout(int queryTimeout) voidvoidsetUseSharedExtendedConnection(boolean useSharedExtendedConnection) voidsetVerifyCursorPosition(boolean verifyCursorPosition) importRunnable in class AbstractImportCommandFileDumpExportArgs, FileDumpImportArgs, FileImportArgscom.redis.riot.cli.FileArgs.GcsArgsgetGcs()com.redis.riot.cli.FileArgs.S3ArgsgetS3()booleanvoidsetEncoding(String encoding) voidsetGcs(com.redis.riot.cli.FileArgs.GcsArgs gcs) voidsetGzipped(boolean gzipped) voidsetS3(com.redis.riot.cli.FileArgs.S3Args s3) fileOptionsgetFile()getType()booleanisAppend()voidsetAppend(boolean append) voidsetElementName(String elementName) voidvoidsetFileArgs(FileArgs fileArgs) voidsetLineSeparator(String lineSeparator) voidvoidsetProgressStyle(com.redis.riot.cli.AbstractRiotCommand.ProgressStyle style) voidsetRootName(String rootName) voidsetType(FileDumpType type) protected StringinitialMaxSupplier, runnablegetKeyFilterArgs, getProcessorArgs, getReaderArgs, initialMaxSupplier, runnable, setKeyFilterArgs, setProcessorArgs, setReaderArgs
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitfileOptionsgetFiles()getType()protected FileDumpImportvoidvoidsetProgressStyle(com.redis.riot.cli.AbstractRiotCommand.ProgressStyle style) voidsetProgressStyle(com.redis.riot.cli.AbstractRiotCommand.ProgressStyle style) voidsetType(FileDumpType type) protected StringfileOptionsprotected AbstractImportprotected LongSupplierinitialMaxSupplier(String stepName,
+
+
+
+
+
+
+
+
+
+
+
+
+
+getFiles()
+
+
+
+
+
+
+
+int[]
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+protected AbstractMapImport
+
+
+protected LongSupplier
+initialMaxSupplier(String stepName,
org.springframework.batch.item.ItemReader<?> reader)
+
+boolean
+isHeader()
+
+void
+setColumnRanges(List<String> columnRanges)
+
+void
+setContinuationString(String continuationString)
+
+void
+setDelimiter(String delimiter)
+
+void
+
+
+void
+setFileArgs(FileArgs fileArgs)
+
+void
+
+
+void
+setFileType(FileType fileType)
+
+void
+setHeader(boolean header)
+
+void
+setHeaderLine(Integer headerLine)
+
+void
+setIncludedFields(int[] includedFields)
+
+void
+setLinesToSkip(Integer linesToSkip)
+
+void
+setMaxItemCount(Integer maxItemCount)
void
@@ -148,6 +226,12 @@ Method Summary
void
setProgressStyle(com.redis.riot.cli.AbstractRiotCommand.ProgressStyle style)
+void
+setQuoteCharacter(Character quoteCharacter)
+
+void
+setRegexes(Map<String,Pattern> regexes)
+
importRunnable in class AbstractImportCommandorg.springframework.expression.Expressionorg.springframework.expression.ExpressionbooleanbooleanvoidsetDropStreamMessageIds(boolean dropStreamMessageIds) voidsetDropTtl(boolean dropTtl) voidsetKeyExpression(TemplateExpression keyExpression) voidsetTtlExpression(org.springframework.expression.Expression ttlExpression) voidsetTypeExpression(org.springframework.expression.Expression typeExpression) run, run, rungetRedisArgs, run, run, run, setRedisArgs
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitintgetHost()getKey()char[]char[]longchar[]intgetPort()io.lettuce.core.protocol.ProtocolVersionlongchar[]getUri()booleanbooleanbooleanbooleanisTls()voidsetClientName(String clientName) voidsetCluster(boolean cluster) voidsetDatabase(int database) voidvoidsetInsecure(boolean insecure) voidvoidsetKeyCert(File keyCert) voidsetKeyPassword(char[] keyPassword) voidsetKeystore(File keystore) voidsetKeystorePassword(char[] keystorePassword) voidsetMetricsStep(long metricsStep) voidsetNoAutoReconnect(boolean noAutoReconnect) voidsetPassword(char[] password) voidsetPort(int port) voidsetProtocolVersion(io.lettuce.core.protocol.ProtocolVersion protocolVersion) voidvoidsetTimeout(long timeout) voidsetTls(boolean tls) voidsetTrustedCerts(File trustedCerts) voidsetTruststore(File truststore) voidsetTruststorePassword(char[] truststorePassword) voidvoidsetUsername(String username) intintintintintlongintvoidsetIdleTimeout(long timeout) setChunkSize(int chunkSize) voidsetMemLimit(int memLimit) voidsetMemSamples(int memSamples) voidsetPoolSize(int poolSize) voidsetQueueCapacity(int queueCapacity) voidsetReadFrom(RedisReaderArgs.ReadFromEnum readFrom) voidsetScanCount(long scanCount) voidsetNotificationQueueCapacity(int capacity) setScanMatch(String scanMatch) voidsetScanType(String scanType) voidsetThreads(int threads) intintlongbooleanisMerge()booleanvoidsetMerge(boolean merge) voidsetMultiExec(boolean multiExec) voidsetPoolSize(int poolSize) voidsetWaitReplicas(int waitReplicas) voidsetWaitTimeout(long waitTimeout) longlonggetMode()intlongbooleanbooleanisType()voidsetCompareMode(CompareMode compareMode) voidsetFlushInterval(long flushInterval) voidsetIdleTimeout(long timeout) voidsetMode(ReplicationMode mode) voidvoidsetNotificationQueueCapacity(int capacity) voidsetProgressStyle(com.redis.riot.cli.AbstractRiotCommand.ProgressStyle style) voidsetShowDiffs(boolean showDiffs) voidsetTargetReadFrom(RedisReaderArgs.ReadFromEnum targetReadFrom) voidsetTargetRedisArgs(RedisArgs targetRedisArgs) voidsetTtlTolerance(long ttlTolerance) voidsetType(boolean type) voidsetWriterArgs(RedisWriterArgs writerArgs) protected StringinitialMaxSupplier, runnablegetKeyFilterArgs, getProcessorArgs, getReaderArgs, initialMaxSupplier, runnable, setKeyFilterArgs, setProcessorArgs, setReaderArgs
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitclass getDbArgs()class getDbArgs()class getFileArgs()class getFileArgs()class voidsetFileArgs(FileArgs fileArgs) voidsetFileArgs(FileArgs fileArgs) voidsetKeyFilterArgs(KeyFilterArgs keyFilterArgs)