diff --git a/api/allclasses-index.html b/api/allclasses-index.html index eb714e61a..d1f8a77e9 100644 --- a/api/allclasses-index.html +++ b/api/allclasses-index.html @@ -95,33 +95,37 @@

All Classes and Interfaces<
 
CompareLoggingWriteListener<K>
 
-
CompareStatusItemWriter<K>
-
 
-
CompareStatusItemWriter.StatusCount
+
CompareMode
+
 
+
CompareStatusItemWriter<K>
 
-
CompareStepListener
+
CompareStatusItemWriter.StatusCount
 
-
ConsumerUnaryOperator<T>
+
CompareStepListener
 
-
ContentType
-
 
-
DatabaseExport
+
ConsumerUnaryOperator<T>
+
 
+
ContentType
+
 
+
DatabaseExport
+
 
+
DatabaseImport
 
-
DatabaseImport
+
DatabaseReaderArgs
 
-
DatabaseReaderArgs
+
DataSourceArgs
 
-
DataSourceArgs
+
DelCommand
 
-
DelCommand
+
EvaluationContextArgs
 
-
EvaluationContextArgs
+
ExpireCommand
 
-
ExpireCommand
+
ExpireTtlArgs
 
-
ExpireTtlArgs
+
Expression
 
-
Expression
+
ExpressionProcessor
 
FakerImport
 
@@ -254,114 +258,112 @@

All Classes and Interfaces<
 
RedisArgs
 
-
RedisContext
-
 
-
RedisReaderArgs
+
RedisClientArgs
+
 
+
RedisContext
 
-
RedisURIConverter
+
RedisReaderArgs
 
-
RedisWriterArgs
+
RedisURIConverter
 
-
RegexNamedGroupFunction
+
RedisWriterArgs
 
-
Replicate
+
RegexNamedGroupFunction
 
-
Replicate.CompareMode
-
 
+
Replicate
+
 
ReplicateReadLogger<K>
 
-
ReplicateReadWriteListener<K>
+
ReplicateWriteLogger<K>
 
-
ReplicateWriteLogger<K>
-
 
-
RetryPolicy
-
 
-
Riot
-
 
-
RiotUtils
+
RetryPolicy
+
 
+
Riot
 
-
RiotVersion
+
RiotUtils
 
-
RpushCommand
+
RiotVersion
 
-
SaddCommand
+
RpushCommand
 
-
ScoreArgs
+
SaddCommand
 
-
SetCommand
+
ScoreArgs
 
-
SetCommand.StringFormat
-
 
-
SkipPolicy
-
 
-
SourceRedisArgs
+
SetCommand
 
-
SslArgs
+
SetCommand.StringFormat
+
 
+
SkipPolicy
+
 
+
SourceRedisArgs
 
-
Step<I,O>
+
SslArgs
 
-
StepArgs
-
 
-
StepConfiguration
-
 
-
StreamItemProcessor
+
Step<I,O>
 
-
StreamMap
+
StepArgs
 
-
StringKeyValue<K>
+
StepConfiguration
+
 
+
StreamItemProcessor
+
 
+
StreamMap
 
-
StringToMapFunction
+
StringKeyValue<K>
 
-
SugaddCommand
+
StringToMapFunction
 
-
SystemOutResource
+
SugaddCommand
 
-
TargetRedisArgs
+
SystemOutResource
 
-
TemplateExpression
+
TargetRedisArgs
 
-
ThrottledItemWriter<T>
+
TemplateExpression
 
-
ToGeoValue<V,T>
+
ThrottledItemWriter<T>
 
-
ToMapFunction<T,K,V>
+
ToGeoValue<V,T>
 
-
ToSample<T>
+
ToMapFunction<T,K,V>
 
-
ToScoredValue<V,T>
+
ToSample<T>
 
-
ToStringKeyValue<K>
+
ToScoredValue<V,T>
 
-
ToSuggestion<V,T>
+
ToStringKeyValue<K>
 
-
TsAddCommand
+
ToSuggestion<V,T>
 
-
UncustomizedUrlResource
+
TsAddCommand
 
-
Versions
+
UncustomizedUrlResource
 
-
XaddCommand
+
Versions
 
-
XmlItemReader<T>
-
+
XaddCommand
+
 
+
XmlItemReader<T>
+
ItemStreamReader implementation that reads XML objects from a Resource having the following format:
-
XmlItemReaderBuilder<T>
-
 
-
XmlObjectReader<T>
+
XmlItemReaderBuilder<T>
 
-
XmlResourceItemWriter<T>
-
+
XmlObjectReader<T>
+
 
+
XmlResourceItemWriter<T>
+
Item writer that writes data in XML format to an output file.
-
XmlResourceItemWriterBuilder<T>
-
+
XmlResourceItemWriterBuilder<T>
+
Builder for XmlResourceItemWriter.
-
ZaddCommand
-
 
-
ZsetMap
+
ZaddCommand
 
+
ZsetMap
+
 
diff --git a/api/com/redis/riot/AbstractRedisExportCommand.html b/api/com/redis/riot/AbstractRedisExportCommand.html index 2e99cdd73..fbb03e640 100644 --- a/api/com/redis/riot/AbstractRedisExportCommand.html +++ b/api/com/redis/riot/AbstractRedisExportCommand.html @@ -140,14 +140,8 @@

Method Summary

Modifier and Type
Method
Description
-
protected void
-
configureSourceRedisReader(com.redis.spring.batch.item.redis.RedisItemReader<?,?> reader)
-
 
-
Pattern
-
getKeyRegex()
-
 
-
int
-
getPoolSize()
+
Pattern
+
getKeyRegex()
 
RedisArgs
getRedisArgs()
@@ -159,20 +153,17 @@

Method Summary

setKeyRegex(Pattern regex)
 
void
-
setPoolSize(int poolSize)
+
setRedisArgs(RedisArgs clientArgs)
 
-
void
-
setRedisArgs(RedisArgs clientArgs)
+
protected RedisContext
+
sourceRedisContext()
 
-
protected RedisContext
-
sourceRedisContext()
-
 

Methods inherited from class com.redis.riot.AbstractExportCommand

-configure, execute, getSourceRedisReaderArgs, setSourceRedisReaderArgs, step, step
+configure, configureSourceRedisReader, execute, getSourceRedisReaderArgs, setSourceRedisReaderArgs, step, step

Methods inherited from class com.redis.riot.core.AbstractJobCommand

configureAsyncReader, getJobArgs, getJobLauncher, getJobName, getJobRepository, getJobRepositoryName, getTransactionManager, job, job, job, setJobArgs, setJobLauncher, setJobName, setJobRepository, setJobRepositoryName, setTransactionManager, shouldShowProgress
@@ -218,16 +209,6 @@

sourceRedisContext

  • -
    -

    configureSourceRedisReader

    -
    protected void configureSourceRedisReader(com.redis.spring.batch.item.redis.RedisItemReader<?,?> reader)
    -
    -
    Overrides:
    -
    configureSourceRedisReader in class AbstractExportCommand
    -
    -
    -
    • -

  • mapProcessor

    protected org.springframework.batch.item.ItemProcessor<com.redis.spring.batch.item.redis.common.KeyValue<String>,Map<String,Object>> mapProcessor()
    @@ -246,18 +227,6 @@

    setRedisArgs

  • -
    -

    getPoolSize

    -
    public int getPoolSize()
    -
    -
    • -
  • -
    -

    setPoolSize

    -
    public void setPoolSize(int poolSize)
    -
    -
    • -

  • getKeyRegex

    public Pattern getKeyRegex()
    diff --git a/api/com/redis/riot/AbstractRedisImportCommand.html b/api/com/redis/riot/AbstractRedisImportCommand.html index 2b360322f..4b1e0a528 100644 --- a/api/com/redis/riot/AbstractRedisImportCommand.html +++ b/api/com/redis/riot/AbstractRedisImportCommand.html @@ -140,30 +140,21 @@

    Method Summary

    Modifier and Type
    Method
    Description
    -
    protected void
    -
    configureTargetRedisWriter(com.redis.spring.batch.item.redis.RedisItemWriter<?,?,?> writer)
    -
     
    -
    int
    -
    getPoolSize()
    -
     
    RedisArgs
    getRedisArgs()
     
    void
    -
    setPoolSize(int poolSize)
    +
    setRedisArgs(RedisArgs clientArgs)
     
    -
    void
    -
    setRedisArgs(RedisArgs clientArgs)
    +
    protected RedisContext
    +
    targetRedisContext()
     
    -
    protected RedisContext
    -
    targetRedisContext()
    -
     

    Methods inherited from class com.redis.riot.AbstractImportCommand

    -execute, getEvaluationContextArgs, getImportOperationCommands, getProcessorArgs, getTargetRedisWriterArgs, hasOperations, operations, operationWriter, processor, processor, setEvaluationContextArgs, setImportOperationCommands, setImportOperationCommands, setProcessorArgs, setTargetRedisWriterArgs, step
    +configureTargetRedisWriter, execute, getEvaluationContextArgs, getImportOperationCommands, getProcessorArgs, getTargetRedisWriterArgs, hasOperations, operations, operationWriter, processor, processor, setEvaluationContextArgs, setImportOperationCommands, setImportOperationCommands, setProcessorArgs, setTargetRedisWriterArgs, step

    Methods inherited from class com.redis.riot.core.AbstractJobCommand

    configureAsyncReader, getJobArgs, getJobLauncher, getJobName, getJobRepository, getJobRepositoryName, getTransactionManager, job, job, job, setJobArgs, setJobLauncher, setJobName, setJobRepository, setJobRepositoryName, setTransactionManager, shouldShowProgress
    @@ -199,16 +190,6 @@

    AbstractRedisImportCommand

    Method Details

    • diff --git a/api/com/redis/riot/AbstractRedisTargetExportCommand.html b/api/com/redis/riot/AbstractRedisTargetExportCommand.html index d38415c8b..69dc96284 100644 --- a/api/com/redis/riot/AbstractRedisTargetExportCommand.html +++ b/api/com/redis/riot/AbstractRedisTargetExportCommand.html @@ -153,56 +153,56 @@

    Method Summary

    configure(org.springframework.expression.spel.support.StandardEvaluationContext context)
     
    protected void
    -
    configureSourceRedisReader(com.redis.spring.batch.item.redis.RedisItemReader<?,?> reader)
    +
    configureTargetRedisReader(com.redis.spring.batch.item.redis.RedisItemReader<?,?> reader)
     
    protected void
    -
    configureTargetRedisReader(com.redis.spring.batch.item.redis.RedisItemReader<?,?> reader)
    +
    configureTargetRedisWriter(com.redis.spring.batch.item.redis.RedisItemWriter<?,?,?> writer)
     
    protected void
    -
    configureTargetRedisWriter(com.redis.spring.batch.item.redis.RedisItemWriter<?,?,?> writer)
    +
    execute()
     
    -
    protected void
    -
    execute()
    +
    SourceRedisArgs
    +
    getSourceRedisArgs()
     
    -
    SourceRedisArgs
    -
    getSourceRedisArgs()
    +
    io.lettuce.core.RedisURI
    +
    getSourceRedisUri()
     
    -
    io.lettuce.core.RedisURI
    -
    getSourceRedisUri()
    +
    SslArgs
    +
    getSslArgs()
     
    -
    SslArgs
    -
    getSslArgs()
    +
    TargetRedisArgs
    +
    getTargetRedisArgs()
     
    -
    TargetRedisArgs
    -
    getTargetRedisArgs()
    +
    io.lettuce.core.RedisURI
    +
    getTargetRedisUri()
     
    -
    io.lettuce.core.RedisURI
    -
    getTargetRedisUri()
    +
    void
    +
    setSourceRedisArgs(SourceRedisArgs sourceRedisArgs)
     
    void
    -
    setSourceRedisArgs(SourceRedisArgs sourceRedisArgs)
    +
    setSourceRedisUri(io.lettuce.core.RedisURI sourceRedisUri)
     
    void
    -
    setSourceRedisUri(io.lettuce.core.RedisURI sourceRedisUri)
    +
    setSslArgs(SslArgs sslArgs)
     
    void
    -
    setSslArgs(SslArgs sslArgs)
    +
    setTargetRedisArgs(TargetRedisArgs targetRedisArgs)
     
    void
    -
    setTargetRedisArgs(TargetRedisArgs targetRedisArgs)
    +
    setTargetRedisUri(io.lettuce.core.RedisURI targetRedisUri)
     
    -
    void
    -
    setTargetRedisUri(io.lettuce.core.RedisURI targetRedisUri)
    +
    protected RedisContext
    +
    sourceRedisContext()
     
    protected RedisContext
    -
    sourceRedisContext()
    +
    targetRedisContext()
     

    Methods inherited from class com.redis.riot.AbstractExportCommand

    -getSourceRedisReaderArgs, setSourceRedisReaderArgs, step, step
    +configureSourceRedisReader, getSourceRedisReaderArgs, setSourceRedisReaderArgs, step, step

    Methods inherited from class com.redis.riot.core.AbstractJobCommand

    configureAsyncReader, getJobArgs, getJobLauncher, getJobName, getJobRepository, getJobRepositoryName, getTransactionManager, job, job, job, setJobArgs, setJobLauncher, setJobName, setJobRepository, setJobRepositoryName, setTransactionManager, shouldShowProgress
    @@ -283,6 +283,12 @@

    sourceRedisContext

  • +
    +

    targetRedisContext

    +
    protected RedisContext targetRedisContext()
    +
    +
    • +

  • configure

    protected void configure(org.springframework.expression.spel.support.StandardEvaluationContext context)
    @@ -293,16 +299,6 @@

    configure

  • -
    -

    configureSourceRedisReader

    -
    protected void configureSourceRedisReader(com.redis.spring.batch.item.redis.RedisItemReader<?,?> reader)
    -
    -
    Overrides:
    -
    configureSourceRedisReader in class AbstractExportCommand
    -
    -
    -
    • -

  • configureTargetRedisReader

    protected void configureTargetRedisReader(com.redis.spring.batch.item.redis.RedisItemReader<?,?> reader)
    diff --git a/api/com/redis/riot/AbstractReplicateCommand.html b/api/com/redis/riot/AbstractReplicateCommand.html index 8585dbfb8..e7a4cb1d5 100644 --- a/api/com/redis/riot/AbstractReplicateCommand.html +++ b/api/com/redis/riot/AbstractReplicateCommand.html @@ -163,14 +163,8 @@

    Method Summary

    protected Step<com.redis.spring.batch.item.redis.reader.KeyComparison<byte[]>,com.redis.spring.batch.item.redis.reader.KeyComparison<byte[]>>
    compareStep()
     
    -
    protected void
    -
    configureTargetRedisReader(com.redis.spring.batch.item.redis.RedisItemReader<?,?> reader)
    -
     
    -
    KeyValueProcessorArgs
    -
    getProcessorArgs()
    -
     
    -
    ReadFrom
    -
    getTargetReadFrom()
    +
    KeyValueProcessorArgs
    +
    getProcessorArgs()
     
    long
    getTtlToleranceMillis()
    @@ -197,20 +191,17 @@

    Method Summary

    setShowDiffs(boolean showDiffs)
     
    void
    -
    setTargetReadFrom(ReadFrom readFrom)
    +
    setTtlToleranceMillis(long tolerance)
     
    -
    void
    -
    setTtlToleranceMillis(long tolerance)
    -
     

    Methods inherited from class com.redis.riot.AbstractRedisTargetExportCommand

    -configure, configureSourceRedisReader, configureTargetRedisWriter, execute, getSourceRedisArgs, getSourceRedisUri, getSslArgs, getTargetRedisArgs, getTargetRedisUri, setSourceRedisArgs, setSourceRedisUri, setSslArgs, setTargetRedisArgs, setTargetRedisUri, sourceRedisContext
    +configure, configureTargetRedisReader, configureTargetRedisWriter, execute, getSourceRedisArgs, getSourceRedisUri, getSslArgs, getTargetRedisArgs, getTargetRedisUri, setSourceRedisArgs, setSourceRedisUri, setSslArgs, setTargetRedisArgs, setTargetRedisUri, sourceRedisContext, targetRedisContext

    Methods inherited from class com.redis.riot.AbstractExportCommand

    -getSourceRedisReaderArgs, setSourceRedisReaderArgs, step, step
    +configureSourceRedisReader, getSourceRedisReaderArgs, setSourceRedisReaderArgs, step, step

    Methods inherited from class com.redis.riot.core.AbstractJobCommand

    configureAsyncReader, getJobArgs, getJobLauncher, getJobName, getJobRepository, getJobRepositoryName, getTransactionManager, job, job, job, setJobArgs, setJobLauncher, setJobName, setJobRepository, setJobRepositoryName, setTransactionManager, shouldShowProgress
    @@ -310,28 +301,6 @@

    isIgnoreStreamMessageId

  • -
    -

    configureTargetRedisReader

    -
    protected void configureTargetRedisReader(com.redis.spring.batch.item.redis.RedisItemReader<?,?> reader)
    -
    -
    Overrides:
    -
    configureTargetRedisReader in class AbstractRedisTargetExportCommand
    -
    -
    -
    • -
  • -
    -

    getTargetReadFrom

    -
    public ReadFrom getTargetReadFrom()
    -
    -
    • -
  • -
    -

    setTargetReadFrom

    -
    public void setTargetReadFrom(ReadFrom readFrom)
    -
    -
    • -

  • isShowDiffs

    public boolean isShowDiffs()
    diff --git a/api/com/redis/riot/AwsArgs.html b/api/com/redis/riot/AwsArgs.html index 3435a2ad9..8a1008109 100644 --- a/api/com/redis/riot/AwsArgs.html +++ b/api/com/redis/riot/AwsArgs.html @@ -127,15 +127,12 @@

    Method Summary

    void
    setRegion(software.amazon.awssdk.regions.Region region)
     
    -
    String
    -
    toString()
    -
     

    Methods inherited from class java.lang.Object

    -clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
    +clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • @@ -203,16 +200,6 @@

    setEndpoint

    public void setEndpoint(URI endpoint)
    -
  • -
    -

    toString

    -
    public String toString()
    -
    -
    Overrides:
    -
    toString in class Object
    -
    -
    -
    • diff --git a/api/com/redis/riot/AwsCredentialsArgs.html b/api/com/redis/riot/AwsCredentialsArgs.html index dc589e34f..7b1893d5e 100644 --- a/api/com/redis/riot/AwsCredentialsArgs.html +++ b/api/com/redis/riot/AwsCredentialsArgs.html @@ -118,15 +118,12 @@

    Method Summary

    void
    setSecretKey(String secretKey)
     
    -
    String
    -
    toString()
    -
     

    Methods inherited from class java.lang.Object

    -clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
    +clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait @@ -176,16 +173,6 @@

    setSecretKey

    public void setSecretKey(String secretKey)
    -
  • -
    -

    toString

    -
    public String toString()
    -
    -
    Overrides:
    -
    toString in class Object
    -
    -
    -
    • diff --git a/api/com/redis/riot/Compare.html b/api/com/redis/riot/Compare.html index c5a08d29b..4e5c8e643 100644 --- a/api/com/redis/riot/Compare.html +++ b/api/com/redis/riot/Compare.html @@ -169,13 +169,13 @@

    Method Summary

    Methods inherited from class com.redis.riot.AbstractReplicateCommand

    -compareReader, compareStep, configureTargetRedisReader, getProcessorArgs, getTargetReadFrom, getTtlToleranceMillis, isShowDiffs, processor, setProcessorArgs, setShowDiffs, setTargetReadFrom, setTtlToleranceMillis
    +compareReader, compareStep, getProcessorArgs, getTtlToleranceMillis, isShowDiffs, processor, setProcessorArgs, setShowDiffs, setTtlToleranceMillis

    Methods inherited from class com.redis.riot.AbstractRedisTargetExportCommand

    -configure, configureSourceRedisReader, configureTargetRedisWriter, execute, getSourceRedisArgs, getSourceRedisUri, getSslArgs, getTargetRedisArgs, getTargetRedisUri, setSourceRedisArgs, setSourceRedisUri, setSslArgs, setTargetRedisArgs, setTargetRedisUri, sourceRedisContext
    +configure, configureTargetRedisReader, configureTargetRedisWriter, execute, getSourceRedisArgs, getSourceRedisUri, getSslArgs, getTargetRedisArgs, getTargetRedisUri, setSourceRedisArgs, setSourceRedisUri, setSslArgs, setTargetRedisArgs, setTargetRedisUri, sourceRedisContext, targetRedisContext

    Methods inherited from class com.redis.riot.AbstractExportCommand

    -getSourceRedisReaderArgs, setSourceRedisReaderArgs, step, step
    +configureSourceRedisReader, getSourceRedisReaderArgs, setSourceRedisReaderArgs, step, step

    Methods inherited from class com.redis.riot.core.AbstractJobCommand

    configureAsyncReader, getJobArgs, getJobLauncher, getJobName, getJobRepository, getJobRepositoryName, getTransactionManager, job, job, setJobArgs, setJobLauncher, setJobName, setJobRepository, setJobRepositoryName, setTransactionManager, shouldShowProgress
    diff --git a/api/com/redis/riot/Replicate.CompareMode.html b/api/com/redis/riot/CompareMode.html similarity index 85% rename from api/com/redis/riot/Replicate.CompareMode.html rename to api/com/redis/riot/CompareMode.html index b6a093306..58f927a40 100644 --- a/api/com/redis/riot/Replicate.CompareMode.html +++ b/api/com/redis/riot/CompareMode.html @@ -2,10 +2,10 @@ -Replicate.CompareMode (riot unspecified) +CompareMode (riot unspecified) - + @@ -35,7 +35,7 @@
  • Overview
  • Package
  • Class
    • -
  • Use
    • +
  • Use
  • Tree
  • Index
  • Help
    • @@ -70,25 +70,21 @@
    Package com.redis.riot
    -

    Enum Class Replicate.CompareMode

    +

    Enum Class CompareMode

    java.lang.Object -
    java.lang.Enum<Replicate.CompareMode> -
    com.redis.riot.Replicate.CompareMode
    +
    java.lang.Enum<CompareMode> +
    com.redis.riot.CompareMode
    All Implemented Interfaces:
    -
    Serializable, Comparable<Replicate.CompareMode>, Constable
    -
    -
    -
    Enclosing class:
    -
    Replicate
    +
    Serializable, Comparable<CompareMode>, Constable
    -
    public static enum Replicate.CompareMode -extends Enum<Replicate.CompareMode>
    +
    public enum CompareMode +extends Enum<CompareMode>
    @@ -189,7 +185,7 @@

    Method Details

  • values

    -
    public static Replicate.CompareMode[] values()
    +
    public static CompareMode[] values()
    Returns an array containing the constants of this enum class, in the order they are declared.
    @@ -201,7 +197,7 @@

    values

  • valueOf

    -
    public static Replicate.CompareMode valueOf(String name)
    +
    public static CompareMode valueOf(String name)
    Returns the enum constant of this class with the specified name. The string must match exactly an identifier used to declare an enum constant in this class. (Extraneous whitespace characters are diff --git a/api/com/redis/riot/DataSourceArgs.html b/api/com/redis/riot/DataSourceArgs.html index 4a2a0e918..5cc74cb4a 100644 --- a/api/com/redis/riot/DataSourceArgs.html +++ b/api/com/redis/riot/DataSourceArgs.html @@ -133,15 +133,12 @@

    Method Summary

    void
    setUsername(String username)
     
    -
    String
    -
    toString()
    -
     

    • Methods inherited from class java.lang.Object

    -clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
    +clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait @@ -168,6 +165,12 @@

    DataSourceArgs

    Method Details

    diff --git a/api/com/redis/riot/DatabaseExport.html b/api/com/redis/riot/DatabaseExport.html index 9ca928fe7..77c00b4ea 100644 --- a/api/com/redis/riot/DatabaseExport.html +++ b/api/com/redis/riot/DatabaseExport.html @@ -173,10 +173,10 @@

    Method Summary

    Methods inherited from class com.redis.riot.AbstractRedisExportCommand

    -configureSourceRedisReader, getKeyRegex, getPoolSize, getRedisArgs, mapProcessor, setKeyRegex, setPoolSize, setRedisArgs, sourceRedisContext
    +getKeyRegex, getRedisArgs, mapProcessor, setKeyRegex, setRedisArgs, sourceRedisContext

    Methods inherited from class com.redis.riot.AbstractExportCommand

    -configure, execute, getSourceRedisReaderArgs, setSourceRedisReaderArgs, step, step
    +configure, configureSourceRedisReader, execute, getSourceRedisReaderArgs, setSourceRedisReaderArgs, step, step

    Methods inherited from class com.redis.riot.core.AbstractJobCommand

    configureAsyncReader, getJobArgs, getJobLauncher, getJobName, getJobRepository, getJobRepositoryName, getTransactionManager, job, job, setJobArgs, setJobLauncher, setJobName, setJobRepository, setJobRepositoryName, setTransactionManager, shouldShowProgress
    diff --git a/api/com/redis/riot/DatabaseImport.html b/api/com/redis/riot/DatabaseImport.html index 18cf64a32..7c4103f91 100644 --- a/api/com/redis/riot/DatabaseImport.html +++ b/api/com/redis/riot/DatabaseImport.html @@ -164,10 +164,10 @@

    Method Summary

    Methods inherited from class com.redis.riot.AbstractRedisImportCommand

    -configureTargetRedisWriter, getPoolSize, getRedisArgs, setPoolSize, setRedisArgs, targetRedisContext
    +getRedisArgs, setRedisArgs, targetRedisContext

    Methods inherited from class com.redis.riot.AbstractImportCommand

    -execute, getEvaluationContextArgs, getImportOperationCommands, getProcessorArgs, getTargetRedisWriterArgs, hasOperations, operations, operationWriter, processor, processor, setEvaluationContextArgs, setImportOperationCommands, setImportOperationCommands, setProcessorArgs, setTargetRedisWriterArgs, step
    +configureTargetRedisWriter, execute, getEvaluationContextArgs, getImportOperationCommands, getProcessorArgs, getTargetRedisWriterArgs, hasOperations, operations, operationWriter, processor, processor, setEvaluationContextArgs, setImportOperationCommands, setImportOperationCommands, setProcessorArgs, setTargetRedisWriterArgs, step

    Methods inherited from class com.redis.riot.core.AbstractJobCommand

    configureAsyncReader, getJobArgs, getJobLauncher, getJobName, getJobRepository, getJobRepositoryName, getTransactionManager, job, job, setJobArgs, setJobLauncher, setJobName, setJobRepository, setJobRepositoryName, setTransactionManager, shouldShowProgress
    diff --git a/api/com/redis/riot/DatabaseReaderArgs.html b/api/com/redis/riot/DatabaseReaderArgs.html index 165f1f4e7..f19a33e51 100644 --- a/api/com/redis/riot/DatabaseReaderArgs.html +++ b/api/com/redis/riot/DatabaseReaderArgs.html @@ -165,15 +165,12 @@

    Method Summary

    void
    setVerifyCursorPosition(boolean verifyCursorPosition)
     
    -
    String
    -
    toString()
    -
     

    Methods inherited from class java.lang.Object

    -clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
    +clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait @@ -325,16 +322,6 @@

    setVerifyCursorPosition

    public void setVerifyCursorPosition(boolean verifyCursorPosition)
    -
  • -
    -

    toString

    -
    public String toString()
    -
    -
    Overrides:
    -
    toString in class Object
    -
    -
    -
    • diff --git a/api/com/redis/riot/EvaluationContextArgs.html b/api/com/redis/riot/EvaluationContextArgs.html index 132a09b4e..4adc22c7a 100644 --- a/api/com/redis/riot/EvaluationContextArgs.html +++ b/api/com/redis/riot/EvaluationContextArgs.html @@ -157,15 +157,12 @@

    Method Summary

    void
    setVars(Map<String,Object> variables)
     
    -
    String
    -
    toString()
    -
     

    Methods inherited from class java.lang.Object

    -clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
    +clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait @@ -309,16 +306,6 @@

    setNumberFormat

    public void setNumberFormat(String numberFormat)
    -
  • -
    -

    toString

    -
    public String toString()
    -
    -
    Overrides:
    -
    toString in class Object
    -
    -
    -
    • diff --git a/api/com/redis/riot/ReplicateReadWriteListener.html b/api/com/redis/riot/ExpressionProcessor.html similarity index 50% rename from api/com/redis/riot/ReplicateReadWriteListener.html rename to api/com/redis/riot/ExpressionProcessor.html index a682a38a9..f5ae65310 100644 --- a/api/com/redis/riot/ReplicateReadWriteListener.html +++ b/api/com/redis/riot/ExpressionProcessor.html @@ -2,10 +2,10 @@ -ReplicateReadWriteListener (riot unspecified) +ExpressionProcessor (riot unspecified) - + @@ -35,7 +35,7 @@
  • Overview
  • Package
  • Class
    • -
  • Use
    • +
  • Use
  • Tree
  • Index
  • Help
    • @@ -46,13 +46,13 @@ @@ -70,38 +70,23 @@
    Package com.redis.riot
    -

    Class ReplicateReadWriteListener<K>

    +

    Class ExpressionProcessor

    java.lang.Object -
    com.redis.riot.ReplicateReadWriteListener<K>
    +
    com.redis.riot.ExpressionProcessor
    All Implemented Interfaces:
    -
    org.springframework.batch.core.ItemReadListener<com.redis.spring.batch.item.redis.common.KeyValue<K>>, org.springframework.batch.core.ItemWriteListener<com.redis.spring.batch.item.redis.common.KeyValue<K>>, org.springframework.batch.core.StepListener
    +
    org.springframework.batch.item.ItemProcessor<Map<String,Object>,Map<String,Object>>
    -
    public class ReplicateReadWriteListener<K> +
    public class ExpressionProcessor extends Object -implements org.springframework.batch.core.ItemWriteListener<com.redis.spring.batch.item.redis.common.KeyValue<K>>, org.springframework.batch.core.ItemReadListener<com.redis.spring.batch.item.redis.common.KeyValue<K>>
    +implements org.springframework.batch.item.ItemProcessor<Map<String,Object>,Map<String,Object>>
    @@ -326,16 +323,6 @@

    setHeader

    public void setHeader(boolean header)
    -
  • -
    -

    toString

    -
    public String toString()
    -
    -
    Overrides:
    -
    toString in class Object
    -
    -
    -
    • diff --git a/api/com/redis/riot/FileExport.html b/api/com/redis/riot/FileExport.html index 2c2d7f2be..a5059063e 100644 --- a/api/com/redis/riot/FileExport.html +++ b/api/com/redis/riot/FileExport.html @@ -187,10 +187,10 @@

    Method Summary

    Methods inherited from class com.redis.riot.AbstractRedisExportCommand

    -configureSourceRedisReader, getKeyRegex, getPoolSize, getRedisArgs, mapProcessor, setKeyRegex, setPoolSize, setRedisArgs, sourceRedisContext
    +getKeyRegex, getRedisArgs, mapProcessor, setKeyRegex, setRedisArgs, sourceRedisContext

    Methods inherited from class com.redis.riot.AbstractExportCommand

    -configure, execute, getSourceRedisReaderArgs, setSourceRedisReaderArgs, step, step
    +configure, configureSourceRedisReader, execute, getSourceRedisReaderArgs, setSourceRedisReaderArgs, step, step

    Methods inherited from class com.redis.riot.core.AbstractJobCommand

    configureAsyncReader, getJobArgs, getJobLauncher, getJobName, getJobRepository, getJobRepositoryName, getTransactionManager, job, job, setJobArgs, setJobLauncher, setJobName, setJobRepository, setJobRepositoryName, setTransactionManager
    diff --git a/api/com/redis/riot/FileImport.html b/api/com/redis/riot/FileImport.html index bb6acfcf7..bc8c14516 100644 --- a/api/com/redis/riot/FileImport.html +++ b/api/com/redis/riot/FileImport.html @@ -190,10 +190,10 @@

    Method Summary

    Methods inherited from class com.redis.riot.AbstractRedisImportCommand

    -configureTargetRedisWriter, getPoolSize, getRedisArgs, setPoolSize, setRedisArgs, targetRedisContext
    +getRedisArgs, setRedisArgs, targetRedisContext

    Methods inherited from class com.redis.riot.AbstractImportCommand

    -execute, getEvaluationContextArgs, getImportOperationCommands, getProcessorArgs, getTargetRedisWriterArgs, hasOperations, operations, operationWriter, processor, setEvaluationContextArgs, setImportOperationCommands, setImportOperationCommands, setProcessorArgs, setTargetRedisWriterArgs, step
    +configureTargetRedisWriter, execute, getEvaluationContextArgs, getImportOperationCommands, getProcessorArgs, getTargetRedisWriterArgs, hasOperations, operations, operationWriter, processor, setEvaluationContextArgs, setImportOperationCommands, setImportOperationCommands, setProcessorArgs, setTargetRedisWriterArgs, step

    Methods inherited from class com.redis.riot.core.AbstractJobCommand

    configureAsyncReader, getJobArgs, getJobLauncher, getJobName, getJobRepository, getJobRepositoryName, getTransactionManager, job, job, setJobArgs, setJobLauncher, setJobName, setJobRepository, setJobRepositoryName, setTransactionManager, shouldShowProgress
    diff --git a/api/com/redis/riot/FileReaderArgs.html b/api/com/redis/riot/FileReaderArgs.html index a1e368143..e23c92b2e 100644 --- a/api/com/redis/riot/FileReaderArgs.html +++ b/api/com/redis/riot/FileReaderArgs.html @@ -175,15 +175,12 @@

    Method Summary

    void
    setMaxItemCount(int maxItemCount)
     
    -
    String
    -
    toString()
    -
     

    Methods inherited from class java.lang.Object

    -clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
    +clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait @@ -352,16 +349,6 @@

    setFileArgs

    public void setFileArgs(FileArgs fileArgs)
    -
  • -
    -

    toString

    -
    public String toString()
    -
    -
    Overrides:
    -
    toString in class Object
    -
    -
    -
    • diff --git a/api/com/redis/riot/FileWriterArgs.html b/api/com/redis/riot/FileWriterArgs.html index 580f14158..0496ff290 100644 --- a/api/com/redis/riot/FileWriterArgs.html +++ b/api/com/redis/riot/FileWriterArgs.html @@ -199,15 +199,12 @@

    Method Summary

    void
    setTransactional(boolean transactional)
     
    -
    String
    -
    toString()
    -
     

    Methods inherited from class java.lang.Object

    -clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
    +clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait @@ -440,16 +437,6 @@

    setFileArgs

    public void setFileArgs(FileArgs fileArgs)
    -
  • -
    -

    toString

    -
    public String toString()
    -
    -
    Overrides:
    -
    toString in class Object
    -
    -
    -
    • diff --git a/api/com/redis/riot/Generate.html b/api/com/redis/riot/Generate.html index bbae5a6b1..1c4477fca 100644 --- a/api/com/redis/riot/Generate.html +++ b/api/com/redis/riot/Generate.html @@ -136,20 +136,14 @@

    Method Summary

    GenerateArgs
    getGenerateArgs()
     
    -
    int
    -
    getPoolSize()
    +
    RedisWriterArgs
    +
    getRedisWriterArgs()
     
    -
    RedisWriterArgs
    -
    getRedisWriterArgs()
    -
     
    -
    protected org.springframework.batch.core.Job
    -
    job()
    -
     
    -
    void
    -
    setGenerateArgs(GenerateArgs args)
    +
    protected org.springframework.batch.core.Job
    +
    job()
     
    void
    -
    setPoolSize(int poolSize)
    +
    setGenerateArgs(GenerateArgs args)
     
    void
    setRedisWriterArgs(RedisWriterArgs args)
    @@ -228,18 +222,6 @@

    setGenerateArgs

    public void setGenerateArgs(GenerateArgs args)
    -
  • -
    -

    getPoolSize

    -
    public int getPoolSize()
    -
    -
    • -
  • -
    -

    setPoolSize

    -
    public void setPoolSize(int poolSize)
    -
    -
    • diff --git a/api/com/redis/riot/GenerateArgs.html b/api/com/redis/riot/GenerateArgs.html index 071e040d1..4cbc987c7 100644 --- a/api/com/redis/riot/GenerateArgs.html +++ b/api/com/redis/riot/GenerateArgs.html @@ -184,7 +184,7 @@

    Method Summary

    Instant
    getTimeseriesStartTime()
     
    -
    List<com.redis.spring.batch.item.redis.common.DataType>
    +
    List<com.redis.spring.batch.item.redis.gen.ItemType>
    getTypes()
     
    com.redis.spring.batch.item.redis.common.Range
    @@ -257,7 +257,7 @@

    Method Summary

    setTimeseriesStartTime(Instant timeseriesStartTime)
     
    void
    -
    setTypes(List<com.redis.spring.batch.item.redis.common.DataType> types)
    +
    setTypes(List<com.redis.spring.batch.item.redis.gen.ItemType> types)
     
    void
    setZsetMemberCount(com.redis.spring.batch.item.redis.common.Range zsetMemberCount)
    @@ -268,15 +268,12 @@

    Method Summary

    void
    setZsetScore(com.redis.spring.batch.item.redis.common.Range zsetScore)
     
    -
    String
    -
    toString()
    -
     

    Methods inherited from class java.lang.Object

    -clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
    +clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait @@ -369,13 +366,13 @@

    setKeyRange

  • getTypes

    -
    public List<com.redis.spring.batch.item.redis.common.DataType> getTypes()
    +
    public List<com.redis.spring.batch.item.redis.gen.ItemType> getTypes()

  • setTypes

    -
    public void setTypes(List<com.redis.spring.batch.item.redis.common.DataType> types)
    +
    public void setTypes(List<com.redis.spring.batch.item.redis.gen.ItemType> types)
  • @@ -618,16 +615,6 @@

    setKeySepataror

    public void setKeySepataror(String keySepataror)
    • -
  • -
    -

    toString

    -
    public String toString()
    -
    -
    Overrides:
    -
    toString in class Object
    -
    -
    -
    • diff --git a/api/com/redis/riot/GoogleStorageArgs.html b/api/com/redis/riot/GoogleStorageArgs.html index 96ee328b9..18b6aa8a1 100644 --- a/api/com/redis/riot/GoogleStorageArgs.html +++ b/api/com/redis/riot/GoogleStorageArgs.html @@ -148,15 +148,12 @@

    Method Summary

    void
    setScope(com.google.cloud.spring.core.GcpScope scope)
     
    -
    String
    -
    toString()
    -
     

    Methods inherited from class java.lang.Object

    -clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
    +clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait @@ -255,16 +252,6 @@

    resource

    -
  • -
    -

    toString

    -
    public String toString()
    -
    -
    Overrides:
    -
    toString in class Object
    -
    -
    -
    • diff --git a/api/com/redis/riot/ImportProcessorArgs.html b/api/com/redis/riot/ImportProcessorArgs.html index 6425fa244..9f4e0664b 100644 --- a/api/com/redis/riot/ImportProcessorArgs.html +++ b/api/com/redis/riot/ImportProcessorArgs.html @@ -118,15 +118,12 @@

    Method Summary

    void
    setFilter(Expression filter)
     
    -
    String
    -
    toString()
    -
     

    Methods inherited from class java.lang.Object

    -clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
    +clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait @@ -176,16 +173,6 @@

    setFilter

    public void setFilter(Expression filter)
    -
  • -
    -

    toString

    -
    public String toString()
    -
    -
    Overrides:
    -
    toString in class Object
    -
    -
    -
    • diff --git a/api/com/redis/riot/KeyFilterArgs.html b/api/com/redis/riot/KeyFilterArgs.html index f4d88b3e2..578cb4bc9 100644 --- a/api/com/redis/riot/KeyFilterArgs.html +++ b/api/com/redis/riot/KeyFilterArgs.html @@ -135,15 +135,12 @@

    Method Summary

    slotRangePredicate(io.lettuce.core.codec.RedisCodec<K,?> codec, com.redis.spring.batch.item.redis.common.Range range)
     
    -
    String
    -
    toString()
    -
     

    Methods inherited from class java.lang.Object

    -clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
    +clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait @@ -225,16 +222,6 @@

    setSlots

    public void setSlots(List<com.redis.spring.batch.item.redis.common.Range> slots)
    -
  • -
    -

    toString

    -
    public String toString()
    -
    -
    Overrides:
    -
    toString in class Object
    -
    -
    -
    • diff --git a/api/com/redis/riot/KeyValueProcessorArgs.html b/api/com/redis/riot/KeyValueProcessorArgs.html index 3c48c96eb..6fc95b355 100644 --- a/api/com/redis/riot/KeyValueProcessorArgs.html +++ b/api/com/redis/riot/KeyValueProcessorArgs.html @@ -145,15 +145,12 @@

    Method Summary

    void
    setTypeExpression(Expression expression)
     
    -
    String
    -
    toString()
    -
     

    Methods inherited from class java.lang.Object

    -clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
    +clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait @@ -257,16 +254,6 @@

    setPrune

    public void setPrune(boolean prune)
    -
  • -
    -

    toString

    -
    public String toString()
    -
    -
    Overrides:
    -
    toString in class Object
    -
    -
    -
    • diff --git a/api/com/redis/riot/RedisArgs.html b/api/com/redis/riot/RedisArgs.html index 931ec359d..cf75f60ed 100644 --- a/api/com/redis/riot/RedisArgs.html +++ b/api/com/redis/riot/RedisArgs.html @@ -46,7 +46,7 @@ @@ -76,12 +76,26 @@

    Class RedisArgs

    com.redis.riot.RedisArgs
    +
    +
    All Implemented Interfaces:
    +
    RedisClientArgs
    +
    public class RedisArgs -extends Object
    +extends Object +implements RedisClientArgs
    @@ -237,15 +248,13 @@

    RedisArgs

    Method Details

  • -
    -

    isMetrics

    -
    public boolean isMetrics()
    +
    +

    getPoolSize

    +
    public int getPoolSize()
    +
    +
    Specified by:
    +
    getPoolSize in interface RedisClientArgs
    +
  • -
    -

    setMetrics

    -
    public void setMetrics(boolean metrics)
    +
    +

    setPoolSize

    +
    public void setPoolSize(int poolSize)
  • -
    -

    toString

    -
    public String toString()
    +
    +

    getReadFrom

    +
    public ReadFrom getReadFrom()
    -
    Overrides:
    -
    toString in class Object
    +
    Specified by:
    +
    getReadFrom in interface RedisClientArgs
  • -
    -

    redisContext

    -
    public RedisContext redisContext()
    +
    +

    setReadFrom

    +
    public void setReadFrom(ReadFrom readFrom)
    • diff --git a/api/com/redis/riot/RedisClientArgs.html b/api/com/redis/riot/RedisClientArgs.html new file mode 100644 index 000000000..1c65d3790 --- /dev/null +++ b/api/com/redis/riot/RedisClientArgs.html @@ -0,0 +1,370 @@ + + + + +RedisClientArgs (riot unspecified) + + + + + + + + + + + + + + +
    + +
    +
    + +
    +
    Package com.redis.riot
    +

    Interface RedisClientArgs

    +
    +
    +
    +
    All Known Implementing Classes:
    +
    RedisArgs, SourceRedisArgs, TargetRedisArgs
    +
    +
    +
    public interface RedisClientArgs
    +
    +
    + +
    +
    +
      + +
    • +
      +

      Field Details

      +
        +
      • +
        +

        DEFAULT_HOST

        +
        static final String DEFAULT_HOST
        +
        +
        See Also:
        +
        + +
        +
        +
        +
        • +
      • +
        +

        DEFAULT_PORT

        +
        static final int DEFAULT_PORT
        +
        +
        See Also:
        +
        + +
        +
        +
        +
        • +
      • +
        +

        DEFAULT_TIMEOUT

        +
        static final Duration DEFAULT_TIMEOUT
        +
        +
        • +
      • +
        +

        DEFAULT_TIMEOUT_SECONDS

        +
        static final long DEFAULT_TIMEOUT_SECONDS
        +
        +
        • +
      • +
        +

        DEFAULT_DATABASE

        +
        static final int DEFAULT_DATABASE
        +
        +
        See Also:
        +
        + +
        +
        +
        +
        • +
      • +
        +

        DEFAULT_PROTOCOL_VERSION

        +
        static final io.lettuce.core.protocol.ProtocolVersion DEFAULT_PROTOCOL_VERSION
        +
        +
        • +
      • +
        +

        DEFAULT_POOL_SIZE

        +
        static final int DEFAULT_POOL_SIZE
        +
        +
        See Also:
        +
        + +
        +
        +
        +
        • +
      • +
        +

        DEFAULT_READ_FROM

        +
        static final ReadFrom DEFAULT_READ_FROM
        +
        +
        • +
      +
      +
      • + +
    • +
      +

      Method Details

      +
        +
      • +
        +

        getHost

        +
        default String getHost()
        +
        +
        • +
      • +
        +

        getPort

        +
        default int getPort()
        +
        +
        • +
      • +
        +

        getSocket

        +
        default String getSocket()
        +
        +
        • +
      • +
        +

        getUsername

        +
        default String getUsername()
        +
        +
        • +
      • +
        +

        getPassword

        +
        default char[] getPassword()
        +
        +
        • +
      • +
        +

        getTimeout

        +
        default Duration getTimeout()
        +
        +
        • +
      • +
        +

        getDatabase

        +
        default int getDatabase()
        +
        +
        • +
      • +
        +

        isTls

        +
        default boolean isTls()
        +
        +
        • +
      • +
        +

        isInsecure

        +
        default boolean isInsecure()
        +
        +
        • +
      • +
        +

        getClientName

        +
        default String getClientName()
        +
        +
        • +
      • +
        +

        isCluster

        +
        default boolean isCluster()
        +
        +
        • +
      • +
        +

        getProtocolVersion

        +
        default io.lettuce.core.protocol.ProtocolVersion getProtocolVersion()
        +
        +
        • +
      • +
        +

        getPoolSize

        +
        default int getPoolSize()
        +
        +
        • +
      • +
        +

        getReadFrom

        +
        default ReadFrom getReadFrom()
        +
        +
        • +
      +
      +
      • +
    +
    + +
    +
    +
    + + diff --git a/api/com/redis/riot/RedisContext.html b/api/com/redis/riot/RedisContext.html index 6a08c239f..c2e8e3e49 100644 --- a/api/com/redis/riot/RedisContext.html +++ b/api/com/redis/riot/RedisContext.html @@ -78,12 +78,12 @@

    Class RedisContext

    All Implemented Interfaces:
    -
    AutoCloseable
    +
    AutoCloseable, org.springframework.beans.factory.InitializingBean
    public class RedisContext extends Object -implements AutoCloseable
    +implements org.springframework.beans.factory.InitializingBean, AutoCloseable
    @@ -113,30 +112,72 @@

    Method Summary

    Method
    Description
    void
    +
    afterPropertiesSet()
    +
     
    +
    RedisContext
    +
    clientResources(io.lettuce.core.resource.ClientResources clientResources)
    +
     
    +
    void
    close()
     
    -
    void
    -
    configure(com.redis.spring.batch.item.redis.RedisItemReader<?,?> reader)
    +
    RedisContext
    +
    cluster(boolean cluster)
     
    void
    -
    configure(com.redis.spring.batch.item.redis.RedisItemWriter<?,?,?> writer)
    +
    configure(com.redis.spring.batch.item.redis.RedisItemReader<?,?> reader)
     
    -
    static RedisContext
    -
    create(io.lettuce.core.RedisURI uri, - boolean cluster, - io.lettuce.core.protocol.ProtocolVersion protocolVersion, - SslArgs sslArgs, - boolean metrics)
    -
     
    +
    void
    +
    configure(com.redis.spring.batch.item.redis.RedisItemWriter<?,?,?> writer)
    +
     
    io.lettuce.core.AbstractRedisClient
    getClient()
     
    -
    com.redis.lettucemod.api.StatefulRedisModulesConnection<String,String>
    -
    getConnection()
    +
    io.lettuce.core.resource.ClientResources
    +
    getClientResources()
    +
     
    +
    com.redis.lettucemod.api.StatefulRedisModulesConnection<String,String>
    +
    getConnection()
    +
     
    +
    int
    +
    getPoolSize()
    +
     
    +
    io.lettuce.core.protocol.ProtocolVersion
    +
    getProtocolVersion()
    +
     
    +
    io.lettuce.core.ReadFrom
    +
    getReadFrom()
     
    -
    io.lettuce.core.RedisURI
    -
    getUri()
    +
    io.lettuce.core.SslOptions
    +
    getSslOptions()
     
    +
    io.lettuce.core.RedisURI
    +
    getUri()
    +
     
    +
    boolean
    +
    isCluster()
    +
     
    +
    static RedisContext
    +
    of(RedisArgs args)
    +
     
    +
    static RedisContext
    +
    of(io.lettuce.core.RedisURI uri, + RedisClientArgs args)
    +
     
    +
    RedisContext
    +
    poolSize(int size)
    +
     
    +
    RedisContext
    +
    protocolVersion(io.lettuce.core.protocol.ProtocolVersion protocolVersion)
    +
     
    +
    RedisContext
    +
    readFrom(io.lettuce.core.ReadFrom readFrom)
    +
     
    +
    RedisContext
    +
    sslOptions(io.lettuce.core.SslOptions sslOptions)
    +
     
    +
    RedisContext
    +
    uri(io.lettuce.core.RedisURI uri)
    +
     
    @@ -155,10 +196,9 @@

    Methods inherited from cl

    Constructor Details

    @@ -170,6 +210,16 @@

    RedisContext

    Method Details

    diff --git a/api/com/redis/riot/RedisReaderArgs.html b/api/com/redis/riot/RedisReaderArgs.html index 4c3eb56ed..ed0928e68 100644 --- a/api/com/redis/riot/RedisReaderArgs.html +++ b/api/com/redis/riot/RedisReaderArgs.html @@ -181,59 +181,53 @@

    Method Summary

    int
    getQueueCapacity()
     
    -
    ReadFrom
    -
    getReadFrom()
    -
     
    -
    int
    -
    getRetryLimit()
    -
     
    -
    long
    -
    getScanCount()
    +
    int
    +
    getRetryLimit()
     
    -
    int
    -
    getSkipLimit()
    +
    long
    +
    getScanCount()
     
    int
    -
    getThreads()
    +
    getSkipLimit()
     
    -
    void
    -
    setChunkSize(int chunkSize)
    +
    int
    +
    getThreads()
     
    void
    -
    setFlushInterval(long intervalMillis)
    +
    setChunkSize(int chunkSize)
     
    void
    -
    setIdleTimeout(long idleTimeout)
    +
    setFlushInterval(long intervalMillis)
     
    void
    -
    setKeyFilterArgs(KeyFilterArgs keyFilterArgs)
    +
    setIdleTimeout(long idleTimeout)
     
    void
    -
    setKeyPattern(String scanMatch)
    +
    setKeyFilterArgs(KeyFilterArgs keyFilterArgs)
     
    void
    -
    setKeyType(String scanType)
    +
    setKeyPattern(String scanMatch)
     
    void
    -
    setMemUsageLimit(org.springframework.util.unit.DataSize memLimit)
    +
    setKeyType(String scanType)
     
    void
    -
    setMemUsageSamples(int memSamples)
    +
    setMemUsageLimit(org.springframework.util.unit.DataSize memLimit)
     
    void
    -
    setMode(com.redis.spring.batch.item.redis.RedisItemReader.ReaderMode mode)
    +
    setMemUsageSamples(int memSamples)
     
    void
    -
    setNotificationQueueCapacity(int capacity)
    +
    setMode(com.redis.spring.batch.item.redis.RedisItemReader.ReaderMode mode)
     
    void
    -
    setPollTimeout(long pollTimeout)
    +
    setNotificationQueueCapacity(int capacity)
     
    void
    -
    setQueueCapacity(int queueCapacity)
    +
    setPollTimeout(long pollTimeout)
     
    void
    -
    setReadFrom(ReadFrom readFrom)
    +
    setQueueCapacity(int queueCapacity)
     
    void
    setRetryLimit(int retryLimit)
    @@ -247,15 +241,12 @@

    Method Summary

    void
    setThreads(int threads)
     
    -
    String
    -
    toString()
    -
     

    Methods inherited from class java.lang.Object

    -clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
    +clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait @@ -464,18 +455,6 @@

    setChunkSize

  • -
    -

    getReadFrom

    -
    public ReadFrom getReadFrom()
    -
    -
    • -
  • -
    -

    setReadFrom

    -
    public void setReadFrom(ReadFrom readFrom)
    -
    -
    • -

  • getMemUsageLimit

    public org.springframework.util.unit.DataSize getMemUsageLimit()
    @@ -595,16 +574,6 @@

    setSkipLimit

    public void setSkipLimit(int skipLimit)
    • -
  • -
    -

    toString

    -
    public String toString()
    -
    -
    Overrides:
    -
    toString in class Object
    -
    -
    -
    • diff --git a/api/com/redis/riot/RedisWriterArgs.html b/api/com/redis/riot/RedisWriterArgs.html index 820c102f8..324a0841c 100644 --- a/api/com/redis/riot/RedisWriterArgs.html +++ b/api/com/redis/riot/RedisWriterArgs.html @@ -153,15 +153,12 @@

    Method Summary

    void
    setWaitTimeout(Duration waitTimeout)
     
    -
    String
    -
    toString()
    -
     

    Methods inherited from class java.lang.Object

    -clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
    +clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait @@ -271,16 +268,6 @@

    setMerge

    public void setMerge(boolean merge)
    -
  • -
    -

    toString

    -
    public String toString()
    -
    -
    Overrides:
    -
    toString in class Object
    -
    -
    -
    • diff --git a/api/com/redis/riot/Replicate.html b/api/com/redis/riot/Replicate.html index 9be6fe9d8..5848aeba2 100644 --- a/api/com/redis/riot/Replicate.html +++ b/api/com/redis/riot/Replicate.html @@ -45,7 +45,7 @@
    @@ -176,7 +161,7 @@

    Method Summary

    protected void
    configureTargetRedisWriter(com.redis.spring.batch.item.redis.RedisItemWriter<?,?,?> writer)
     
    -
    Replicate.CompareMode
    +
    CompareMode
    getCompareMode()
     
    RedisWriterArgs
    @@ -195,7 +180,7 @@

    Method Summary

    job()
     
    void
    -
    setCompareMode(Replicate.CompareMode compareMode)
    +
    setCompareMode(CompareMode compareMode)
     
    void
    setLogKeys(boolean enable)
    @@ -206,18 +191,21 @@

    Method Summary

    void
    setTargetRedisWriterArgs(RedisWriterArgs redisWriterArgs)
     
    +
    protected Step<com.redis.spring.batch.item.redis.common.KeyValue<byte[]>,com.redis.spring.batch.item.redis.common.KeyValue<byte[]>>
    +
    step()
    +
     

    Methods inherited from class com.redis.riot.AbstractReplicateCommand

    -compareStep, configureTargetRedisReader, getProcessorArgs, getTargetReadFrom, getTtlToleranceMillis, isIgnoreStreamMessageId, isShowDiffs, processor, setProcessorArgs, setShowDiffs, setTargetReadFrom, setTtlToleranceMillis
    +compareStep, getProcessorArgs, getTtlToleranceMillis, isIgnoreStreamMessageId, isShowDiffs, processor, setProcessorArgs, setShowDiffs, setTtlToleranceMillis

    Methods inherited from class com.redis.riot.AbstractRedisTargetExportCommand

    -configure, configureSourceRedisReader, execute, getSourceRedisArgs, getSourceRedisUri, getSslArgs, getTargetRedisArgs, getTargetRedisUri, setSourceRedisArgs, setSourceRedisUri, setSslArgs, setTargetRedisArgs, setTargetRedisUri, sourceRedisContext
    +configure, configureTargetRedisReader, execute, getSourceRedisArgs, getSourceRedisUri, getSslArgs, getTargetRedisArgs, getTargetRedisUri, setSourceRedisArgs, setSourceRedisUri, setSslArgs, setTargetRedisArgs, setTargetRedisUri, sourceRedisContext, targetRedisContext

    Methods inherited from class com.redis.riot.AbstractExportCommand

    -getSourceRedisReaderArgs, setSourceRedisReaderArgs, step, step
    +configureSourceRedisReader, getSourceRedisReaderArgs, setSourceRedisReaderArgs, step, step

    Methods inherited from class com.redis.riot.core.AbstractJobCommand

    configureAsyncReader, getJobArgs, getJobLauncher, getJobName, getJobRepository, getJobRepositoryName, getTransactionManager, job, job, setJobArgs, setJobLauncher, setJobName, setJobRepository, setJobRepositoryName, setTransactionManager, shouldShowProgress
    @@ -241,7 +229,7 @@

    Field Details

  • DEFAULT_COMPARE_MODE

    -
    public static final Replicate.CompareMode DEFAULT_COMPARE_MODE
    +
    public static final CompareMode DEFAULT_COMPARE_MODE
    • @@ -297,6 +285,12 @@

    configureTargetRedisWriter

  • +
    +

    step

    +
    protected Step<com.redis.spring.batch.item.redis.common.KeyValue<byte[]>,com.redis.spring.batch.item.redis.common.KeyValue<byte[]>> step()
    +
    +
    • +

  • compareReader

    protected com.redis.spring.batch.item.redis.reader.KeyComparisonItemReader<byte[],byte[]> compareReader()
    @@ -349,13 +343,13 @@

    setLogKeys

  • getCompareMode

    -
    public Replicate.CompareMode getCompareMode()
    +
    public CompareMode getCompareMode()
  • -
    +

    setCompareMode

    -
    public void setCompareMode(Replicate.CompareMode compareMode)
    +
    public void setCompareMode(CompareMode compareMode)
    • diff --git a/api/com/redis/riot/Riot.html b/api/com/redis/riot/Riot.html index 1ed252cc9..80bdb2cb0 100644 --- a/api/com/redis/riot/Riot.html +++ b/api/com/redis/riot/Riot.html @@ -126,16 +126,46 @@

    Method Summary

    protected picocli.CommandLine
    commandLine()
     
    -
    static void
    -
    configureCommandLine(picocli.CommandLine commandLine)
    -
     
    +
    protected Compare
    +
    compare()
    +
     
    +
    protected DatabaseExport
    +
    databaseExport()
    +
     
    +
    protected DatabaseImport
    +
    databaseImport()
    +
     
    protected int
    execute(picocli.CommandLine.ParseResult parseResult, picocli.CommandLine.IExecutionStrategy defaultStrategy)
     
    -
    static void
    -
    main(String[] args)
    -
     
    +
    protected FakerImport
    +
    fakerImport()
    +
     
    +
    protected FileExport
    +
    fileExport()
    +
     
    +
    protected FileImport
    +
    fileImport()
    +
     
    +
    protected Generate
    +
    generate()
    +
     
    +
    protected picocli.AutoComplete.GenerateCompletion
    +
    generateCompletion()
    +
     
    +
    static void
    +
    main(String[] args)
    +
     
    +
    protected Ping
    +
    ping()
    +
     
    +
    protected Replicate
    +
    replicate()
    +
     
    +
    protected List<Object>
    +
    subcommands()
    +
     
    @@ -187,9 +217,69 @@

    commandLine

  • -
    -

    configureCommandLine

    -
    public static void configureCommandLine(picocli.CommandLine commandLine)
    +
    +

    subcommands

    +
    protected List<Object> subcommands()
    +
    +
    • +
  • +
    +

    generateCompletion

    +
    protected picocli.AutoComplete.GenerateCompletion generateCompletion()
    +
    +
    • +
  • +
    +

    compare

    +
    protected Compare compare()
    +
    +
    • +
  • +
    +

    replicate

    +
    protected Replicate replicate()
    +
    +
    • +
  • +
    +

    ping

    +
    protected Ping ping()
    +
    +
    • +
  • +
    +

    generate

    +
    protected Generate generate()
    +
    +
    • +
  • +
    +

    fileImport

    +
    protected FileImport fileImport()
    +
    +
    • +
  • +
    +

    fileExport

    +
    protected FileExport fileExport()
    +
    +
    • +
  • +
    +

    fakerImport

    +
    protected FakerImport fakerImport()
    +
    +
    • +
  • +
    +

    databaseImport

    +
    protected DatabaseImport databaseImport()
    +
    +
    • +
  • +
    +

    databaseExport

    +
    protected DatabaseExport databaseExport()
  • diff --git a/api/com/redis/riot/SourceRedisArgs.html b/api/com/redis/riot/SourceRedisArgs.html index 005423cb2..5eb5cf1a6 100644 --- a/api/com/redis/riot/SourceRedisArgs.html +++ b/api/com/redis/riot/SourceRedisArgs.html @@ -46,7 +46,7 @@ @@ -76,12 +76,26 @@

    Class SourceRedisArgs

    com.redis.riot.SourceRedisArgs
    +
    +
    All Implemented Interfaces:
    +
    RedisClientArgs
    +
    public class SourceRedisArgs -extends Object
    +extends Object +implements RedisClientArgs
    @@ -208,15 +215,13 @@

    SourceRedisArgs

    Method Details

  • -
    -

    isMetrics

    -
    public boolean isMetrics()
    -
    -
    • -
  • -
    -

    setMetrics

    -
    public void setMetrics(boolean metrics)
    -
    -
    • -
  • -
    -

    toString

    -
    public String toString()
    +
    +

    getReadFrom

    +
    public ReadFrom getReadFrom()
    -
    Overrides:
    -
    toString in class Object
    +
    Specified by:
    +
    getReadFrom in interface RedisClientArgs
  • -
    -

    redisContext

    -
    public RedisContext redisContext(io.lettuce.core.RedisURI uri, - SslArgs sslArgs)
    +
    +

    setReadFrom

    +
    public void setReadFrom(ReadFrom readFrom)
    • diff --git a/api/com/redis/riot/SslArgs.html b/api/com/redis/riot/SslArgs.html index 773054f0e..52e9bc327 100644 --- a/api/com/redis/riot/SslArgs.html +++ b/api/com/redis/riot/SslArgs.html @@ -157,15 +157,12 @@

    Method Summary

    io.lettuce.core.SslOptions
    sslOptions()
     
    -
    String
    -
    toString()
    -
     

    Methods inherited from class java.lang.Object

    -clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
    +clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait @@ -293,16 +290,6 @@

    setTrustedCerts

    public void setTrustedCerts(File trustedCerts)
    -
  • -
    -

    toString

    -
    public String toString()
    -
    -
    Overrides:
    -
    toString in class Object
    -
    -
    -
    • diff --git a/api/com/redis/riot/TargetRedisArgs.html b/api/com/redis/riot/TargetRedisArgs.html index 1f097c672..77d0a63da 100644 --- a/api/com/redis/riot/TargetRedisArgs.html +++ b/api/com/redis/riot/TargetRedisArgs.html @@ -46,7 +46,7 @@ @@ -76,12 +76,26 @@

    Class TargetRedisArgs

    com.redis.riot.TargetRedisArgs
    +
    +
    All Implemented Interfaces:
    +
    RedisClientArgs
    +
    public class TargetRedisArgs -extends Object
    +extends Object +implements RedisClientArgs
    @@ -208,22 +215,13 @@

    TargetRedisArgs

    Method Details

  • -
    -

    isCluster

    -
    public boolean isCluster()
    -
    -
    • -
  • -
    -

    setCluster

    -
    public void setCluster(boolean cluster)
    -
    -
    • -
  • -
    -

    getProtocolVersion

    -
    public io.lettuce.core.protocol.ProtocolVersion getProtocolVersion()
    -
    -
    • -
  • -
    -

    setProtocolVersion

    -
    public void setProtocolVersion(io.lettuce.core.protocol.ProtocolVersion protocolVersion)
    -
    -
    • -
  • -
    -

    getPoolSize

    -
    public int getPoolSize()
    -
    -
    • -
  • -
    -

    setPoolSize

    -
    public void setPoolSize(int poolSize)
    -
    -
    • -

  • getTimeout

    -
    public long getTimeout()
    +
    public Duration getTimeout()
    +
    +
    Specified by:
    +
    getTimeout in interface RedisClientArgs
    +
  • @@ -308,6 +282,10 @@

    setTimeout

    isTls

    public boolean isTls()
    +
    +
    Specified by:
    +
    isTls in interface RedisClientArgs
    +
  • @@ -320,6 +298,10 @@

    setTls

    getClientName

    public String getClientName()
    +
    +
    Specified by:
    +
    getClientName in interface RedisClientArgs
    +
  • @@ -329,27 +311,69 @@

    setClientName

  • -
    -

    isMetrics

    -
    public boolean isMetrics()
    +
    +

    isCluster

    +
    public boolean isCluster()
    +
    +
    Specified by:
    +
    isCluster in interface RedisClientArgs
    +
  • -
    -

    setMetrics

    -
    public void setMetrics(boolean metrics)
    +
    +

    setCluster

    +
    public void setCluster(boolean cluster)
  • -
    -

    toString

    -
    public String toString()
    +
    +

    getProtocolVersion

    +
    public io.lettuce.core.protocol.ProtocolVersion getProtocolVersion()
    -
    Overrides:
    -
    toString in class Object
    +
    Specified by:
    +
    getProtocolVersion in interface RedisClientArgs
    • +
  • +
    +

    setProtocolVersion

    +
    public void setProtocolVersion(io.lettuce.core.protocol.ProtocolVersion protocolVersion)
    +
    +
    • +
  • +
    +

    getPoolSize

    +
    public int getPoolSize()
    +
    +
    Specified by:
    +
    getPoolSize in interface RedisClientArgs
    +
    +
    +
    • +
  • +
    +

    setPoolSize

    +
    public void setPoolSize(int poolSize)
    +
    +
    • +
  • +
    +

    getReadFrom

    +
    public ReadFrom getReadFrom()
    +
    +
    Specified by:
    +
    getReadFrom in interface RedisClientArgs
    +
    +
    +
    • +
  • +
    +

    setReadFrom

    +
    public void setReadFrom(ReadFrom readFrom)
    +
    +
    • diff --git a/api/com/redis/riot/class-use/Compare.html b/api/com/redis/riot/class-use/Compare.html index b03a58e2a..61f8c80b1 100644 --- a/api/com/redis/riot/class-use/Compare.html +++ b/api/com/redis/riot/class-use/Compare.html @@ -51,7 +51,32 @@

    Uses of Class
    com.redis.riot.Compare

    -No usage of com.redis.riot.Compare +
    Packages that use Compare
    +
    +
    Package
    +
    Description
    +
    com.redis.riot
    +
     
    +
    +
    + +
    + diff --git a/api/com/redis/riot/class-use/Replicate.CompareMode.html b/api/com/redis/riot/class-use/CompareMode.html similarity index 66% rename from api/com/redis/riot/class-use/Replicate.CompareMode.html rename to api/com/redis/riot/class-use/CompareMode.html index 4ec15b8b8..df11d49d8 100644 --- a/api/com/redis/riot/class-use/Replicate.CompareMode.html +++ b/api/com/redis/riot/class-use/CompareMode.html @@ -2,10 +2,10 @@ -Uses of Enum Class com.redis.riot.Replicate.CompareMode (riot unspecified) +Uses of Enum Class com.redis.riot.CompareMode (riot unspecified) - + @@ -30,7 +30,7 @@ diff --git a/api/com/redis/riot/core/RiotVersion.html b/api/com/redis/riot/core/RiotVersion.html index eec440f51..f10283721 100644 --- a/api/com/redis/riot/core/RiotVersion.html +++ b/api/com/redis/riot/core/RiotVersion.html @@ -115,11 +115,8 @@

    Method Summary

    String version)
     
    static String
    -
    getPlainVersion()
    +
    getVersion()
     
    -
    static String
    -
    riotVersion()
    -
     
    @@ -138,15 +135,9 @@

    Methods inherited from cl

    Method Details

    @@ -494,16 +491,6 @@

    getSkip

    public Collection<Class<? extends Throwable>> getSkip()
    -
  • -
    -

    toString

    -
    public String toString()
    -
    -
    Overrides:
    -
    toString in class Object
    -
    -
    -
    • diff --git a/api/com/redis/riot/core/StepArgs.html b/api/com/redis/riot/core/StepArgs.html index 3cf658bcb..4d8970deb 100644 --- a/api/com/redis/riot/core/StepArgs.html +++ b/api/com/redis/riot/core/StepArgs.html @@ -187,15 +187,12 @@

    Method Summary

    void
    setThreads(int threads)
     
    -
    String
    -
    toString()
    -
     

    Methods inherited from class java.lang.Object

    -clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
    +clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait @@ -391,16 +388,6 @@

    setRetryPolicy

    public void setRetryPolicy(RetryPolicy retryPolicy)
    -
  • -
    -

    toString

    -
    public String toString()
    -
    -
    Overrides:
    -
    toString in class Object
    -
    -
    -
    • diff --git a/api/com/redis/riot/core/class-use/Expression.html b/api/com/redis/riot/core/class-use/Expression.html index 549412b15..5e885b6bb 100644 --- a/api/com/redis/riot/core/class-use/Expression.html +++ b/api/com/redis/riot/core/class-use/Expression.html @@ -119,6 +119,16 @@

    Uses of Ex
    EvaluationContextArgs.setVarExpressions(Map<String,Expression> expressions)
     
    +
    Constructor parameters in com.redis.riot with type arguments of type Expression
    +
    +
    Modifier
    +
    Constructor
    +
    Description
    +
     
    +
    ExpressionProcessor(org.springframework.expression.EvaluationContext context, + Map<String,Expression> expressions)
    +
     
    +
  • diff --git a/api/com/redis/riot/core/class-use/Step.html b/api/com/redis/riot/core/class-use/Step.html index 4352cb088..cbf7edd0d 100644 --- a/api/com/redis/riot/core/class-use/Step.html +++ b/api/com/redis/riot/core/class-use/Step.html @@ -86,6 +86,9 @@

    Uses of Step
    protected Step<Map<String,Object>,Map<String,Object>>
    AbstractImportCommand.step(org.springframework.batch.item.ItemReader<Map<String,Object>> reader)
     
    +
    protected Step<com.redis.spring.batch.item.redis.common.KeyValue<byte[]>,com.redis.spring.batch.item.redis.common.KeyValue<byte[]>>
    +
    Replicate.step()
    +
     

    • diff --git a/api/com/redis/riot/operation/ExpireTtlArgs.html b/api/com/redis/riot/operation/ExpireTtlArgs.html index 9eb435c8c..7ddd5b446 100644 --- a/api/com/redis/riot/operation/ExpireTtlArgs.html +++ b/api/com/redis/riot/operation/ExpireTtlArgs.html @@ -118,15 +118,12 @@

    Method Summary

    void
    setTtlValue(long ttlValue)
     
    -
    String
    -
    toString()
    -
     

    Methods inherited from class java.lang.Object

    -clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
    +clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait @@ -176,16 +173,6 @@

    setTtlValue

    public void setTtlValue(long ttlValue)
    -
  • -
    -

    toString

    -
    public String toString()
    -
    -
    Overrides:
    -
    toString in class Object
    -
    -
    -
    • diff --git a/api/com/redis/riot/operation/FieldFilterArgs.html b/api/com/redis/riot/operation/FieldFilterArgs.html index 9c977eae0..69009e731 100644 --- a/api/com/redis/riot/operation/FieldFilterArgs.html +++ b/api/com/redis/riot/operation/FieldFilterArgs.html @@ -121,15 +121,12 @@

    Method Summary

    void
    setIncludeFields(List<String> includes)
     
    -
    String
    -
    toString()
    -
     

    Methods inherited from class java.lang.Object

    -clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
    +clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait @@ -185,16 +182,6 @@

    setIncludeFields

    public void setIncludeFields(List<String> includes)
    -
  • -
    -

    toString

    -
    public String toString()
    -
    -
    Overrides:
    -
    toString in class Object
    -
    -
    -
    • diff --git a/api/com/redis/riot/operation/MemberOperationArgs.html b/api/com/redis/riot/operation/MemberOperationArgs.html index 6b56a0791..f7f616169 100644 --- a/api/com/redis/riot/operation/MemberOperationArgs.html +++ b/api/com/redis/riot/operation/MemberOperationArgs.html @@ -118,15 +118,12 @@

    Method Summary

    void
    setMemberSpace(String space)
     
    -
    String
    -
    toString()
    -
     

    Methods inherited from class java.lang.Object

    -clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
    +clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait @@ -176,16 +173,6 @@

    setMemberFields

    public void setMemberFields(List<String> fields)
    -
  • -
    -

    toString

    -
    public String toString()
    -
    -
    Overrides:
    -
    toString in class Object
    -
    -
    -
    • diff --git a/api/com/redis/riot/operation/ScoreArgs.html b/api/com/redis/riot/operation/ScoreArgs.html index 50da068da..b5a5b3cb5 100644 --- a/api/com/redis/riot/operation/ScoreArgs.html +++ b/api/com/redis/riot/operation/ScoreArgs.html @@ -133,15 +133,12 @@

    Method Summary

    void
    setField(String field)
     
    -
    String
    -
    toString()
    -
     

    Methods inherited from class java.lang.Object

    -clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
    +clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait @@ -213,16 +210,6 @@

    setDefaultValue

    public void setDefaultValue(double defaultValue)
    -
  • -
    -

    toString

    -
    public String toString()
    -
    -
    Overrides:
    -
    toString in class Object
    -
    -
    -
    • diff --git a/api/com/redis/riot/package-summary.html b/api/com/redis/riot/package-summary.html index b820d1cdf..2bd2941f3 100644 --- a/api/com/redis/riot/package-summary.html +++ b/api/com/redis/riot/package-summary.html @@ -90,7 +90,7 @@

    Package com.redis.riot

  • -
    +
    diff --git a/api/com/redis/riot/package-tree.html b/api/com/redis/riot/package-tree.html index 70d4982fe..761fef0b6 100644 --- a/api/com/redis/riot/package-tree.html +++ b/api/com/redis/riot/package-tree.html @@ -122,6 +122,7 @@

    Class Hierarchy

  • com.redis.riot.DatabaseReaderArgs
  • com.redis.riot.DataSourceArgs
  • com.redis.riot.EvaluationContextArgs
    • +
  • com.redis.riot.ExpressionProcessor (implements org.springframework.batch.item.ItemProcessor<I,O>)
  • com.redis.riot.FileArgs
  • com.redis.riot.FileReaderArgs
  • com.redis.riot.FileWriterArgs
    • @@ -160,32 +161,37 @@

    Class Hierarchy

  • com.redis.riot.KeyValueProcessorArgs
  • com.redis.riot.PingExecution
  • com.redis.riot.RangeConverter (implements picocli.CommandLine.ITypeConverter<K>)
    • -
  • com.redis.riot.RedisArgs
    • -
  • com.redis.riot.RedisContext (implements java.lang.AutoCloseable)
    • +
  • com.redis.riot.RedisArgs (implements com.redis.riot.RedisClientArgs)
    • +
  • com.redis.riot.RedisContext (implements java.lang.AutoCloseable, org.springframework.beans.factory.InitializingBean)
  • com.redis.riot.RedisReaderArgs
  • com.redis.riot.RedisURIConverter (implements picocli.CommandLine.ITypeConverter<K>)
  • com.redis.riot.RedisWriterArgs
  • com.redis.riot.ReplicateReadLogger<K> (implements org.springframework.batch.core.ItemReadListener<T>, org.springframework.batch.core.ItemWriteListener<S>)
    • -
  • com.redis.riot.ReplicateReadWriteListener<K> (implements org.springframework.batch.core.ItemReadListener<T>, org.springframework.batch.core.ItemWriteListener<S>)
  • com.redis.riot.ReplicateWriteLogger<K> (implements org.springframework.batch.core.ItemWriteListener<S>)
    • -
  • com.redis.riot.SourceRedisArgs
    • +
  • com.redis.riot.SourceRedisArgs (implements com.redis.riot.RedisClientArgs)
  • com.redis.riot.SslArgs
    • -
  • com.redis.riot.TargetRedisArgs
    • +
  • com.redis.riot.TargetRedisArgs (implements com.redis.riot.RedisClientArgs)
  • com.redis.riot.Versions (implements picocli.CommandLine.IVersionProvider)
    • +

    Interface Hierarchy

    + +
    +

    Enum Class Hierarchy

    +
  • com.redis.riot.ExpressionProcessor (implements org.springframework.batch.item.ItemProcessor<I,O>)
  • com.redis.riot.core.processor.FieldExtractorFactory
  • com.redis.riot.core.processor.FieldExtractorFactory.FieldExtractorFactoryBuilder
  • com.redis.riot.operation.FieldFilterArgs
    • @@ -263,19 +264,18 @@

    Class Hierarchy

  • com.redis.riot.core.ProgressArgs
  • com.redis.riot.core.ProgressStepExecutionListener<I,O> (implements org.springframework.batch.core.ItemWriteListener<S>, org.springframework.batch.core.StepExecutionListener)
  • com.redis.riot.RangeConverter (implements picocli.CommandLine.ITypeConverter<K>)
    • -
  • com.redis.riot.RedisArgs
    • -
  • com.redis.riot.RedisContext (implements java.lang.AutoCloseable)
    • +
  • com.redis.riot.RedisArgs (implements com.redis.riot.RedisClientArgs)
    • +
  • com.redis.riot.RedisContext (implements java.lang.AutoCloseable, org.springframework.beans.factory.InitializingBean)
  • com.redis.riot.RedisReaderArgs
  • com.redis.riot.RedisURIConverter (implements picocli.CommandLine.ITypeConverter<K>)
  • com.redis.riot.RedisWriterArgs
  • com.redis.riot.core.processor.RegexNamedGroupFunction (implements java.util.function.Function<T,R>)
  • com.redis.riot.ReplicateReadLogger<K> (implements org.springframework.batch.core.ItemReadListener<T>, org.springframework.batch.core.ItemWriteListener<S>)
    • -
  • com.redis.riot.ReplicateReadWriteListener<K> (implements org.springframework.batch.core.ItemReadListener<T>, org.springframework.batch.core.ItemWriteListener<S>)
  • com.redis.riot.ReplicateWriteLogger<K> (implements org.springframework.batch.core.ItemWriteListener<S>)
  • com.redis.riot.core.RiotUtils
  • com.redis.riot.core.RiotVersion
  • com.redis.riot.operation.ScoreArgs
    • -
  • com.redis.riot.SourceRedisArgs
    • +
  • com.redis.riot.SourceRedisArgs (implements com.redis.riot.RedisClientArgs)
  • com.redis.riot.SslArgs
  • com.redis.riot.core.Step<I,O>
  • com.redis.riot.core.StepArgs
    • @@ -283,7 +283,7 @@

    Class Hierarchy

  • com.redis.riot.function.StreamMap (implements java.util.function.Function<T,R>)
  • com.redis.riot.function.StringKeyValue<K> (implements java.util.function.Function<T,R>)
  • com.redis.riot.core.processor.StringToMapFunction (implements java.util.function.Function<T,R>)
    • -
  • com.redis.riot.TargetRedisArgs
    • +
  • com.redis.riot.TargetRedisArgs (implements com.redis.riot.RedisClientArgs)
  • com.redis.riot.core.ThrottledItemWriter<T> (implements org.springframework.batch.item.ItemStreamWriter<T>)
  • java.lang.Throwable (implements java.io.Serializable)
    • @@ -328,11 +329,11 @@

    Enum Class Hierarchy

    • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.lang.constant.Constable, java.io.Serializable)
        +
      • com.redis.riot.CompareMode
      • com.redis.riot.ContentType
      • com.redis.riot.file.FileType
      • com.redis.riot.core.ProgressStyle
      • com.redis.riot.ReadFrom
        • -
      • com.redis.riot.Replicate.CompareMode
      • com.redis.riot.core.RetryPolicy
      • com.redis.riot.operation.SetCommand.StringFormat
      • com.redis.riot.core.SkipPolicy
        • diff --git a/api/type-search-index.js b/api/type-search-index.js index 108ac7a3c..cf295e551 100644 --- a/api/type-search-index.js +++ b/api/type-search-index.js @@ -1 +1 @@ -typeSearchIndex = [{"p":"com.redis.riot.core","l":"AbstractCallableCommand"},{"p":"com.redis.riot","l":"AbstractExportCommand"},{"p":"com.redis.riot","l":"AbstractImportCommand"},{"p":"com.redis.riot.core","l":"AbstractJobCommand"},{"p":"com.redis.riot.operation","l":"AbstractOperationCommand"},{"p":"com.redis.riot","l":"AbstractRedisCommand"},{"p":"com.redis.riot","l":"AbstractRedisExportCommand"},{"p":"com.redis.riot","l":"AbstractRedisImportCommand"},{"p":"com.redis.riot","l":"AbstractRedisTargetExportCommand"},{"p":"com.redis.riot","l":"AbstractReplicateCommand"},{"p":"com.redis.riot.test","l":"AbstractRiotTestBase"},{"l":"All Classes and Interfaces","u":"allclasses-index.html"},{"p":"com.redis.riot","l":"AwsArgs"},{"p":"com.redis.riot","l":"AwsCredentialsArgs"},{"p":"com.redis.riot.core","l":"BaseCommand"},{"p":"com.redis.riot.core.processor","l":"CollectionToMapFunction"},{"p":"com.redis.riot","l":"Compare"},{"p":"com.redis.riot","l":"CompareLoggingWriteListener"},{"p":"com.redis.riot","l":"Replicate.CompareMode"},{"p":"com.redis.riot","l":"CompareStatusItemWriter"},{"p":"com.redis.riot","l":"CompareStepListener"},{"p":"com.redis.riot.core.processor","l":"IdFunctionBuilder.ConcatenatingFunction"},{"p":"com.redis.riot.core.processor","l":"ConsumerUnaryOperator"},{"p":"com.redis.riot","l":"ContentType"},{"p":"com.redis.riot","l":"DatabaseExport"},{"p":"com.redis.riot","l":"DatabaseImport"},{"p":"com.redis.riot","l":"DatabaseReaderArgs"},{"p":"com.redis.riot","l":"DataSourceArgs"},{"p":"com.redis.riot.operation","l":"DelCommand"},{"p":"com.redis.riot","l":"EvaluationContextArgs"},{"p":"com.redis.riot.operation","l":"ExpireCommand"},{"p":"com.redis.riot.operation","l":"ExpireTtlArgs"},{"p":"com.redis.riot.core","l":"Expression"},{"p":"com.redis.riot","l":"FakerImport"},{"p":"com.redis.riot.faker","l":"FakerItemReader"},{"p":"com.redis.riot.core.processor","l":"FieldExtractorFactory"},{"p":"com.redis.riot.core.processor","l":"FieldExtractorFactory.FieldExtractorFactoryBuilder"},{"p":"com.redis.riot.operation","l":"FieldFilterArgs"},{"p":"com.redis.riot","l":"FileArgs"},{"p":"com.redis.riot","l":"FileExport"},{"p":"com.redis.riot","l":"FileImport"},{"p":"com.redis.riot.file","l":"FilenameInputStreamResource"},{"p":"com.redis.riot","l":"FileReaderArgs"},{"p":"com.redis.riot.file","l":"FileType"},{"p":"com.redis.riot.file","l":"FileUtils"},{"p":"com.redis.riot","l":"FileWriterArgs"},{"p":"com.redis.riot.core.processor","l":"FunctionPredicate"},{"p":"com.redis.riot","l":"Generate"},{"p":"com.redis.riot","l":"GenerateArgs"},{"p":"com.redis.riot.operation","l":"GeoaddCommand"},{"p":"com.redis.riot","l":"GoogleStorageArgs"},{"p":"com.redis.riot.file","l":"HeaderCallbackHandler"},{"p":"com.redis.riot.operation","l":"HsetCommand"},{"p":"com.redis.riot.core.processor","l":"IdFunctionBuilder"},{"p":"com.redis.riot","l":"ImportProcessorArgs"},{"p":"com.redis.riot.core","l":"IO"},{"p":"com.redis.riot.file","l":"JsonLineAggregator"},{"p":"com.redis.riot.operation","l":"JsonSetCommand"},{"p":"com.redis.riot","l":"KeyFilterArgs"},{"p":"com.redis.riot","l":"KeyValueDeserializer"},{"p":"com.redis.riot","l":"KeyValueFilter"},{"p":"com.redis.riot.function","l":"KeyValueMap"},{"p":"com.redis.riot","l":"KeyValueProcessorArgs"},{"p":"com.redis.riot.core","l":"LoggingMixin"},{"p":"com.redis.riot.operation","l":"LpushCommand"},{"p":"com.redis.riot.core","l":"MainCommand"},{"p":"com.redis.riot.file","l":"MapFieldSetMapper"},{"p":"com.redis.riot.core.processor","l":"MapFilteringFunction"},{"p":"com.redis.riot.core.processor","l":"MapFlatteningFunction"},{"p":"com.redis.riot.file","l":"MapToFieldFunction"},{"p":"com.redis.riot.operation","l":"MemberOperationArgs"},{"p":"com.redis.riot.core.processor","l":"FieldExtractorFactory.MissingFieldException"},{"p":"com.redis.riot.core","l":"NoopItemWriter"},{"p":"com.redis.riot.function","l":"ObjectMapperFunction"},{"p":"com.redis.riot.file","l":"ObjectMapperLineMapper"},{"p":"com.redis.riot.core.processor","l":"ObjectToDoubleFunction"},{"p":"com.redis.riot.core.processor","l":"ObjectToLongFunction"},{"p":"com.redis.riot.core.processor","l":"ObjectToStringFunction"},{"p":"com.redis.riot.operation","l":"OperationCommand"},{"p":"com.redis.riot.file","l":"OutputStreamResource"},{"p":"com.redis.riot","l":"Ping"},{"p":"com.redis.riot","l":"PingExecution"},{"p":"com.redis.riot","l":"PingExecutionItemReader"},{"p":"com.redis.riot.core.processor","l":"PredicateOperator"},{"p":"com.redis.riot.core","l":"PrintExceptionMessageHandler"},{"p":"com.redis.riot.core","l":"ProgressArgs"},{"p":"com.redis.riot.core","l":"ProgressStepExecutionListener"},{"p":"com.redis.riot.core","l":"ProgressStyle"},{"p":"com.redis.riot.core","l":"QuietMapAccessor"},{"p":"com.redis.riot","l":"RangeConverter"},{"p":"com.redis.riot","l":"ReadFrom"},{"p":"com.redis.riot","l":"RedisArgs"},{"p":"com.redis.riot","l":"RedisContext"},{"p":"com.redis.riot","l":"RedisReaderArgs"},{"p":"com.redis.riot","l":"RedisURIConverter"},{"p":"com.redis.riot","l":"RedisWriterArgs"},{"p":"com.redis.riot.core.processor","l":"RegexNamedGroupFunction"},{"p":"com.redis.riot","l":"Replicate"},{"p":"com.redis.riot","l":"ReplicateReadLogger"},{"p":"com.redis.riot","l":"ReplicateReadWriteListener"},{"p":"com.redis.riot","l":"ReplicateWriteLogger"},{"p":"com.redis.riot.core","l":"RetryPolicy"},{"p":"com.redis.riot","l":"Riot"},{"p":"com.redis.riot.core","l":"RiotUtils"},{"p":"com.redis.riot.core","l":"RiotVersion"},{"p":"com.redis.riot.operation","l":"RpushCommand"},{"p":"com.redis.riot.operation","l":"SaddCommand"},{"p":"com.redis.riot.operation","l":"ScoreArgs"},{"p":"com.redis.riot.operation","l":"SetCommand"},{"p":"com.redis.riot.core","l":"SkipPolicy"},{"p":"com.redis.riot","l":"SourceRedisArgs"},{"p":"com.redis.riot","l":"SslArgs"},{"p":"com.redis.riot","l":"CompareStatusItemWriter.StatusCount"},{"p":"com.redis.riot.core","l":"Step"},{"p":"com.redis.riot.core","l":"StepArgs"},{"p":"com.redis.riot.core","l":"StepConfiguration"},{"p":"com.redis.riot.function","l":"StreamItemProcessor"},{"p":"com.redis.riot.function","l":"StreamMap"},{"p":"com.redis.riot.operation","l":"SetCommand.StringFormat"},{"p":"com.redis.riot.function","l":"StringKeyValue"},{"p":"com.redis.riot.core.processor","l":"StringToMapFunction"},{"p":"com.redis.riot.operation","l":"SugaddCommand"},{"p":"com.redis.riot.file","l":"SystemOutResource"},{"p":"com.redis.riot","l":"TargetRedisArgs"},{"p":"com.redis.riot.core","l":"TemplateExpression"},{"p":"com.redis.riot.core","l":"ThrottledItemWriter"},{"p":"com.redis.riot.function","l":"ToGeoValue"},{"p":"com.redis.riot.file","l":"ToMapFunction"},{"p":"com.redis.riot.function","l":"ToSample"},{"p":"com.redis.riot.function","l":"ToScoredValue"},{"p":"com.redis.riot.function","l":"ToStringKeyValue"},{"p":"com.redis.riot.function","l":"ToSuggestion"},{"p":"com.redis.riot.operation","l":"TsAddCommand"},{"p":"com.redis.riot.file","l":"UncustomizedUrlResource"},{"p":"com.redis.riot","l":"Versions"},{"p":"com.redis.riot.operation","l":"XaddCommand"},{"p":"com.redis.riot.file.xml","l":"XmlItemReader"},{"p":"com.redis.riot.file.xml","l":"XmlItemReaderBuilder"},{"p":"com.redis.riot.file.xml","l":"XmlObjectReader"},{"p":"com.redis.riot.file.xml","l":"XmlResourceItemWriter"},{"p":"com.redis.riot.file.xml","l":"XmlResourceItemWriterBuilder"},{"p":"com.redis.riot.operation","l":"ZaddCommand"},{"p":"com.redis.riot.function","l":"ZsetMap"}];updateSearchResults(); \ No newline at end of file +typeSearchIndex = [{"p":"com.redis.riot.core","l":"AbstractCallableCommand"},{"p":"com.redis.riot","l":"AbstractExportCommand"},{"p":"com.redis.riot","l":"AbstractImportCommand"},{"p":"com.redis.riot.core","l":"AbstractJobCommand"},{"p":"com.redis.riot.operation","l":"AbstractOperationCommand"},{"p":"com.redis.riot","l":"AbstractRedisCommand"},{"p":"com.redis.riot","l":"AbstractRedisExportCommand"},{"p":"com.redis.riot","l":"AbstractRedisImportCommand"},{"p":"com.redis.riot","l":"AbstractRedisTargetExportCommand"},{"p":"com.redis.riot","l":"AbstractReplicateCommand"},{"p":"com.redis.riot.test","l":"AbstractRiotTestBase"},{"l":"All Classes and Interfaces","u":"allclasses-index.html"},{"p":"com.redis.riot","l":"AwsArgs"},{"p":"com.redis.riot","l":"AwsCredentialsArgs"},{"p":"com.redis.riot.core","l":"BaseCommand"},{"p":"com.redis.riot.core.processor","l":"CollectionToMapFunction"},{"p":"com.redis.riot","l":"Compare"},{"p":"com.redis.riot","l":"CompareLoggingWriteListener"},{"p":"com.redis.riot","l":"CompareMode"},{"p":"com.redis.riot","l":"CompareStatusItemWriter"},{"p":"com.redis.riot","l":"CompareStepListener"},{"p":"com.redis.riot.core.processor","l":"IdFunctionBuilder.ConcatenatingFunction"},{"p":"com.redis.riot.core.processor","l":"ConsumerUnaryOperator"},{"p":"com.redis.riot","l":"ContentType"},{"p":"com.redis.riot","l":"DatabaseExport"},{"p":"com.redis.riot","l":"DatabaseImport"},{"p":"com.redis.riot","l":"DatabaseReaderArgs"},{"p":"com.redis.riot","l":"DataSourceArgs"},{"p":"com.redis.riot.operation","l":"DelCommand"},{"p":"com.redis.riot","l":"EvaluationContextArgs"},{"p":"com.redis.riot.operation","l":"ExpireCommand"},{"p":"com.redis.riot.operation","l":"ExpireTtlArgs"},{"p":"com.redis.riot.core","l":"Expression"},{"p":"com.redis.riot","l":"ExpressionProcessor"},{"p":"com.redis.riot","l":"FakerImport"},{"p":"com.redis.riot.faker","l":"FakerItemReader"},{"p":"com.redis.riot.core.processor","l":"FieldExtractorFactory"},{"p":"com.redis.riot.core.processor","l":"FieldExtractorFactory.FieldExtractorFactoryBuilder"},{"p":"com.redis.riot.operation","l":"FieldFilterArgs"},{"p":"com.redis.riot","l":"FileArgs"},{"p":"com.redis.riot","l":"FileExport"},{"p":"com.redis.riot","l":"FileImport"},{"p":"com.redis.riot.file","l":"FilenameInputStreamResource"},{"p":"com.redis.riot","l":"FileReaderArgs"},{"p":"com.redis.riot.file","l":"FileType"},{"p":"com.redis.riot.file","l":"FileUtils"},{"p":"com.redis.riot","l":"FileWriterArgs"},{"p":"com.redis.riot.core.processor","l":"FunctionPredicate"},{"p":"com.redis.riot","l":"Generate"},{"p":"com.redis.riot","l":"GenerateArgs"},{"p":"com.redis.riot.operation","l":"GeoaddCommand"},{"p":"com.redis.riot","l":"GoogleStorageArgs"},{"p":"com.redis.riot.file","l":"HeaderCallbackHandler"},{"p":"com.redis.riot.operation","l":"HsetCommand"},{"p":"com.redis.riot.core.processor","l":"IdFunctionBuilder"},{"p":"com.redis.riot","l":"ImportProcessorArgs"},{"p":"com.redis.riot.core","l":"IO"},{"p":"com.redis.riot.file","l":"JsonLineAggregator"},{"p":"com.redis.riot.operation","l":"JsonSetCommand"},{"p":"com.redis.riot","l":"KeyFilterArgs"},{"p":"com.redis.riot","l":"KeyValueDeserializer"},{"p":"com.redis.riot","l":"KeyValueFilter"},{"p":"com.redis.riot.function","l":"KeyValueMap"},{"p":"com.redis.riot","l":"KeyValueProcessorArgs"},{"p":"com.redis.riot.core","l":"LoggingMixin"},{"p":"com.redis.riot.operation","l":"LpushCommand"},{"p":"com.redis.riot.core","l":"MainCommand"},{"p":"com.redis.riot.file","l":"MapFieldSetMapper"},{"p":"com.redis.riot.core.processor","l":"MapFilteringFunction"},{"p":"com.redis.riot.core.processor","l":"MapFlatteningFunction"},{"p":"com.redis.riot.file","l":"MapToFieldFunction"},{"p":"com.redis.riot.operation","l":"MemberOperationArgs"},{"p":"com.redis.riot.core.processor","l":"FieldExtractorFactory.MissingFieldException"},{"p":"com.redis.riot.core","l":"NoopItemWriter"},{"p":"com.redis.riot.function","l":"ObjectMapperFunction"},{"p":"com.redis.riot.file","l":"ObjectMapperLineMapper"},{"p":"com.redis.riot.core.processor","l":"ObjectToDoubleFunction"},{"p":"com.redis.riot.core.processor","l":"ObjectToLongFunction"},{"p":"com.redis.riot.core.processor","l":"ObjectToStringFunction"},{"p":"com.redis.riot.operation","l":"OperationCommand"},{"p":"com.redis.riot.file","l":"OutputStreamResource"},{"p":"com.redis.riot","l":"Ping"},{"p":"com.redis.riot","l":"PingExecution"},{"p":"com.redis.riot","l":"PingExecutionItemReader"},{"p":"com.redis.riot.core.processor","l":"PredicateOperator"},{"p":"com.redis.riot.core","l":"PrintExceptionMessageHandler"},{"p":"com.redis.riot.core","l":"ProgressArgs"},{"p":"com.redis.riot.core","l":"ProgressStepExecutionListener"},{"p":"com.redis.riot.core","l":"ProgressStyle"},{"p":"com.redis.riot.core","l":"QuietMapAccessor"},{"p":"com.redis.riot","l":"RangeConverter"},{"p":"com.redis.riot","l":"ReadFrom"},{"p":"com.redis.riot","l":"RedisArgs"},{"p":"com.redis.riot","l":"RedisClientArgs"},{"p":"com.redis.riot","l":"RedisContext"},{"p":"com.redis.riot","l":"RedisReaderArgs"},{"p":"com.redis.riot","l":"RedisURIConverter"},{"p":"com.redis.riot","l":"RedisWriterArgs"},{"p":"com.redis.riot.core.processor","l":"RegexNamedGroupFunction"},{"p":"com.redis.riot","l":"Replicate"},{"p":"com.redis.riot","l":"ReplicateReadLogger"},{"p":"com.redis.riot","l":"ReplicateWriteLogger"},{"p":"com.redis.riot.core","l":"RetryPolicy"},{"p":"com.redis.riot","l":"Riot"},{"p":"com.redis.riot.core","l":"RiotUtils"},{"p":"com.redis.riot.core","l":"RiotVersion"},{"p":"com.redis.riot.operation","l":"RpushCommand"},{"p":"com.redis.riot.operation","l":"SaddCommand"},{"p":"com.redis.riot.operation","l":"ScoreArgs"},{"p":"com.redis.riot.operation","l":"SetCommand"},{"p":"com.redis.riot.core","l":"SkipPolicy"},{"p":"com.redis.riot","l":"SourceRedisArgs"},{"p":"com.redis.riot","l":"SslArgs"},{"p":"com.redis.riot","l":"CompareStatusItemWriter.StatusCount"},{"p":"com.redis.riot.core","l":"Step"},{"p":"com.redis.riot.core","l":"StepArgs"},{"p":"com.redis.riot.core","l":"StepConfiguration"},{"p":"com.redis.riot.function","l":"StreamItemProcessor"},{"p":"com.redis.riot.function","l":"StreamMap"},{"p":"com.redis.riot.operation","l":"SetCommand.StringFormat"},{"p":"com.redis.riot.function","l":"StringKeyValue"},{"p":"com.redis.riot.core.processor","l":"StringToMapFunction"},{"p":"com.redis.riot.operation","l":"SugaddCommand"},{"p":"com.redis.riot.file","l":"SystemOutResource"},{"p":"com.redis.riot","l":"TargetRedisArgs"},{"p":"com.redis.riot.core","l":"TemplateExpression"},{"p":"com.redis.riot.core","l":"ThrottledItemWriter"},{"p":"com.redis.riot.function","l":"ToGeoValue"},{"p":"com.redis.riot.file","l":"ToMapFunction"},{"p":"com.redis.riot.function","l":"ToSample"},{"p":"com.redis.riot.function","l":"ToScoredValue"},{"p":"com.redis.riot.function","l":"ToStringKeyValue"},{"p":"com.redis.riot.function","l":"ToSuggestion"},{"p":"com.redis.riot.operation","l":"TsAddCommand"},{"p":"com.redis.riot.file","l":"UncustomizedUrlResource"},{"p":"com.redis.riot","l":"Versions"},{"p":"com.redis.riot.operation","l":"XaddCommand"},{"p":"com.redis.riot.file.xml","l":"XmlItemReader"},{"p":"com.redis.riot.file.xml","l":"XmlItemReaderBuilder"},{"p":"com.redis.riot.file.xml","l":"XmlObjectReader"},{"p":"com.redis.riot.file.xml","l":"XmlResourceItemWriter"},{"p":"com.redis.riot.file.xml","l":"XmlResourceItemWriterBuilder"},{"p":"com.redis.riot.operation","l":"ZaddCommand"},{"p":"com.redis.riot.function","l":"ZsetMap"}];updateSearchResults(); \ No newline at end of file diff --git a/images/riotx-dashboard-jvm.png b/images/riotx-dashboard-jvm.png new file mode 100644 index 000000000..3035c2df9 Binary files /dev/null and b/images/riotx-dashboard-jvm.png differ diff --git a/images/riotx-dashboard-replication-drop.png b/images/riotx-dashboard-replication-drop.png new file mode 100644 index 000000000..20b663a88 Binary files /dev/null and b/images/riotx-dashboard-replication-drop.png differ diff --git a/images/riotx-dashboard-replication.png b/images/riotx-dashboard-replication.png new file mode 100644 index 000000000..39fdef6a2 Binary files /dev/null and b/images/riotx-dashboard-replication.png differ diff --git a/index.html b/index.html index c7f7705b0..f3596604b 100644 --- a/index.html +++ b/index.html @@ -92,7 +92,7 @@

        Redis Input/Output Tools (RIOT)

        Julien Ruaux
        -version 4.1.4 +version 4.1.5
        Table of Contents
        @@ -101,6 +101,7 @@

        Redis Input/Output Tools (RIOT)

      • Install
      • Concepts
        • @@ -220,10 +251,10 @@

        Manual Installation (All Platforms)
        -

        riot-4.1.4.zip requires Java 11 or greater to be installed.

        +

        riot-4.1.5.zip requires Java 11 or greater to be installed.

        -

        riot-standalone-4.1.4-*.zip includes its own Java runtime and does not require a Java installation.

        +

        riot-standalone-4.1.5-*.zip includes its own Java runtime and does not require a Java installation.

        @@ -252,6 +283,127 @@

        Concepts

        +

        Redis URI

        +
        +

        RIOT follows the Redis URI specification, which supports standalone, sentinel and cluster Redis deployments with plain, SSL, TLS and unix domain socket connections.

        +
        +
        + + + + + +
        + + +You can use the host:port short hand for redis://host:port. +
        +
        +
        + + + + + +
        + + +You can provide the database, password and timeouts within the Redis URI. +
        +
        +
        +
        +
        Redis Standalone
        +
        +

        redis :// [[username :] password@] host [:port][/database] + [?[timeout=timeout[d|h|m|s|ms|us|ns]] [&clientName=clientName] + [&libraryName=libraryName] [&libraryVersion=libraryVersion] ]

        +
        +
        Redis Standalone (SSL)
        +
        +

        rediss :// [[username :] password@] host [: port][/database] + [?[timeout=timeout[d|h|m|s|ms|us|ns]] [&clientName=clientName] + [&libraryName=libraryName] [&libraryVersion=libraryVersion] ]

        +
        +
        Redis Standalone (Unix Domain Sockets)
        +
        +

        redis-socket :// [[username :] password@]path + [?[timeout=timeout[d|h|m|s|ms|us|ns]] [&database=database] + [&clientName=clientName] [&libraryName=libraryName] + [&libraryVersion=libraryVersion] ]

        +
        +
        Redis Sentinel
        +
        +

        redis-sentinel :// [[username :] password@] host1[:port1] [, host2[:port2]] [, hostN[:portN]] [/database] + [?[timeout=timeout[d|h|m|s|ms|us|ns]] [&sentinelMasterId=sentinelMasterId] + [&clientName=clientName] [&libraryName=libraryName] + [&libraryVersion=libraryVersion] ]

        +
        +
        +
        +
        +
        Timeout Units
        + + + + + + + + + + + + + + + + + + + + + + + + + + + + + +
        +d + +

        Days

        +
        +h + +

        Hours

        +
        +m + +

        Minutes

        +
        +s + +

        Seconds

        +
        +ms + +

        Milliseconds

        +
        +us + +

        Microseconds

        +
        +ns + +

        Nanoseconds

        +
        +
        +
        +

        Batching

        Processing in RIOT is done in batches: a fixed number of records is read from the source, processed, and written to the target. @@ -277,7 +429,7 @@

        Multi
        Multi-threading example
        -
        riot db-import "SELECT * FROM orders" --url "jdbc:postgresql://host:port/database" --username appuser --password passwd --threads 3 hset --keyspace order --key order_id
        +
        riot db-import "SELECT * FROM orders" --jdbc-url "jdbc:postgresql://host:port/database" --jdbc-username appuser --jdbc-password passwd --threads 3 hset --keyspace order --key order_id

        @@ -702,7 +854,7 @@

        Database Import

        -
        riot db-import -h <redis host> -p <redis port> --url <jdbc url> SQL [REDIS COMMAND...]
        +
        riot db-import --jdbc-url <jdbc url> SQL [REDIS COMMAND...]
        @@ -749,13 +901,13 @@

        Database Import

        PostgreSQL Import Example
        -
        riot db-import "SELECT * FROM orders" --url "jdbc:postgresql://host:port/database" --username appuser --password passwd hset --keyspace order --key order_id
        +
        riot db-import "SELECT * FROM orders" --jdbc-url "jdbc:postgresql://host:port/database" --jdbc-username appuser --jdbc-password passwd hset --keyspace order --key order_id
        Import from PostgreSQL to JSON strings
        -
        riot db-import "SELECT * FROM orders" --url "jdbc:postgresql://host:port/database" --username appuser --password passwd set --keyspace order --key order_id
        +
        riot db-import "SELECT * FROM orders" --jdbc-url "jdbc:postgresql://host:port/database" --jdbc-username appuser --jdbc-password passwd set --keyspace order --key order_id
        @@ -804,7 +956,7 @@

        Database Export

        -
        riot db-export -h <redis host> -p <redis port> --url <jdbc url> SQL
        +
        riot db-export --jdbc-url <jdbc url> SQL
        @@ -818,7 +970,7 @@

        Database Export

        Example: export to PostgreSQL
        -
        riot db-export "INSERT INTO mytable (id, field1, field2) VALUES (CAST(:id AS SMALLINT), :field1, :field2)" --url "jdbc:postgresql://host:port/database" --username appuser --password passwd --key-pattern "gen:*" --key-regex "gen:(?<id>.*)"
        +
        riot db-export "INSERT INTO mytable (id, field1, field2) VALUES (CAST(:id AS SMALLINT), :field1, :field2)" --jdbc-url "jdbc:postgresql://host:port/database" --jdbc-username appuser --jdbc-password passwd --key-pattern "gen:*" --key-regex "gen:(?<id>.*)"
        @@ -1304,10 +1456,16 @@

        Replication

        The replicate command reads data from a source Redis database and writes to a target Redis database.

        +
        +

        The basic usage is:

        +
        -
        riot replicate SOURCE TARGET [--mode <scan|live|liveonly>] [--struct] [OPTIONS]
        +
        riot replicate [OPTIONS] SOURCE TARGET
        +
        +
        +

        where SOURCE and TARGET are Redis URIs.

        For the full usage, run:

        @@ -1317,24 +1475,53 @@

        Replication

        riot replicate --help
        +
        + + + + + +
        + + +To replicate a Redis logical database other than the default (0), specify the database in the source Redis URI. +For example riot replicate redis://source:6379/1 redis://target:6379 replicates database 1. +
        +

        A status bar shows progress with a percentage of keys that have been replicated. The total number of keys is estimated when the process starts and it can change by the time it is finished, for example if keys are deleted or added during replication.

        Replication Modes

        +
        +

        The --mode option allows you to specify how RIOT identifies keys to be replicated. +Possible values: SCAN (default), LIVE, LIVEONLY.

        +
        -
        Scan
        +
        SCAN

        This mode uses the SCAN command to identify keys to propagate to the target Redis database.

        +
        +
        Scan replication example
        +
        +
        riot replicate redis://source redis://target
        +
        +
        -
        Live
        +
        LIVE

        This mode builds upon scan replication by also listening for changes on the source Redis database. Whenever a key is modified its corresponding value is read and propagated to the target Redis database.

        +
        +
        Live replication example
        +
        +
        riot replicate --mode live redis://source redis://target
        +
        +

        Live replication relies on keyspace notifications for capturing these changes.

        @@ -1381,7 +1568,7 @@
        -
        Live Only
        +
        LIVEONLY

        In this mode only keyspace notifications are used.

        @@ -1389,6 +1576,19 @@

        Replication Types

        +
        +

        RIOT offers two different mechanisms for reading and writing keys:

        +
        +
        +
          +
        • +

          Dump & restore (default)

          +
          • +
        • +

          Data structure replication (--struct)

          +
          • +
        +
        Dump & Restore
        @@ -1425,7 +1625,7 @@
        -

        In those cases you can use another replication strategy that is data structure-specific: each key is introspected to determine its type and then use the corresponding read/write commands:

        +

        In those cases you can use another replication strategy that is data structure-specific: each key is introspected to determine its type and then use the corresponding read/write commands.

        @@ -1497,18 +1697,6 @@
        -
        Snapshot replication example
        -
        -
        riot replicate --batch 10 redis://source redis://target
        -
        - -
        -
        Live replication example
        -
        -
        riot replicate --mode live redis://source redis://target
        -
        -
        -
        Type-based replication example
        riot replicate --struct redis://source redis://target
        @@ -1877,85 +2065,57 @@

        Connectivity Test

        FAQ

        -
        -
        -
        Logs are cut off or missing
        -
        +
        +
          +
        1. +

          Logs are cut off or missing

          This could be due to concurrency issues in the terminal when refreshing the progress bar and displaying logs. Try running with job option --progress log.

          -
        -
        -
        -
        -
        -
        Unknown options: '--keyspace', '--key'
        -
        + +
      • +

        Unknown options: '--keyspace', '--key'

        You must specify one or more Redis commands with import commands (file-import, faker, db-import).

        -
        • -
        -
        -
        -
        -
        ERR DUMP payload version or checksum are wrong
        -
        + +
      • +

        ERR DUMP payload version or checksum are wrong

        Redis 7 DUMP format is not backwards compatible with previous versions. To replicate between different Redis versions, use Type-Based Replication.

        -
        • -
        -
        -
        -
        -
        Process gets stuck during replication and eventually times out
        -
        + +
      • +

        Process gets stuck during replication and eventually times out

        This could be due to big keys clogging the replication pipes. In these cases it might be hard to catch the offending key(s). Try running the same command with --info and --progress log so that all errors are reported. Check the database with redis-cli Big keys and/or use reader options to filter these keys out.

        -
        • -
        -
        -
        -
        -
        NOAUTH Authentication required
        -
        + +
      • +

        NOAUTH Authentication required

        This issue occurs when you fail to supply the --pass <password> parameter.

        -
        • -
        -
        -
        -
        -
        ERR The ID argument cannot be a complete ID because xadd-id-uniqueness-mode is strict
        -
        + +
      • +

        ERR The ID argument cannot be a complete ID because xadd-id-uniqueness-mode is strict

        This usually happens in Active/Active (CRDB) setups where stream message IDs cannot be copied over to the target database. Use the --no-stream-id option to disable ID propagation.

        -
        • -
        -
        -
        -
        -
        ERR Error running script…​ This Redis command is not allowed from scripts
        -
        + +
      • +

        ERR Error running script…​ This Redis command is not allowed from scripts

        This can happen with Active/Active (CRDB) databases because the MEMORY USAGE command is not allowed to be run from a LUA script. Use the --mem-limit -1 option to disable memory usage.

        -
        • -
        -
        -
        -
        -
        java.lang.OutOfMemoryError: Java heap space
        -
        -

        The JVM running RIOT ran out of memory. + +

      • +

        java.lang.OutOfMemoryError: Java heap space

        +

        The RIOT JVM ran out of memory. Either increase max JVM heap size (export JAVA_OPTS="-Xmx8g") or reduce RIOT memory usage by lowering threads, batch, read-batch and read-queue.

        -
        • -
        + +