From c008af2d720083c712e8fbe4dc37f71991c03ebc Mon Sep 17 00:00:00 2001 From: runner Date: Wed, 24 Apr 2024 17:37:39 +0000 Subject: [PATCH] Publish guide for unspecified --- api/allclasses-index.html | 224 +++++----- .../redis/riot/cli/AbstractExportCommand.html | 66 ++- .../redis/riot/cli/AbstractImportCommand.html | 8 +- .../redis/riot/cli/AbstractMainCommand.html | 34 +- .../riot/cli/AbstractStructImportCommand.html | 8 +- api/com/redis/riot/cli/DbArgs.html | 76 +++- api/com/redis/riot/cli/DbExportArgs.html | 133 ------ api/com/redis/riot/cli/DbExportCommand.html | 78 +++- api/com/redis/riot/cli/DbImportArgs.html | 133 ------ api/com/redis/riot/cli/DbImportCommand.html | 148 ++++++- api/com/redis/riot/cli/FileArgs.html | 76 +++- .../redis/riot/cli/FileDumpExportArgs.html | 133 ------ .../redis/riot/cli/FileDumpExportCommand.html | 128 +++++- .../redis/riot/cli/FileDumpImportArgs.html | 133 ------ .../redis/riot/cli/FileDumpImportCommand.html | 40 +- api/com/redis/riot/cli/FileImportArgs.html | 133 ------ api/com/redis/riot/cli/FileImportCommand.html | 262 ++++++++++- .../redis/riot/cli/KeyValueProcessorArgs.html | 94 +++- api/com/redis/riot/cli/Main.html | 2 +- api/com/redis/riot/cli/RedisArgs.html | 418 +++++++++++++++++- api/com/redis/riot/cli/RedisReaderArgs.html | 184 +++++++- api/com/redis/riot/cli/RedisWriterArgs.html | 90 ++++ api/com/redis/riot/cli/ReplicateCommand.html | 202 ++++++++- api/com/redis/riot/cli/class-use/DbArgs.html | 24 +- .../riot/cli/class-use/DbImportArgs.html | 58 --- .../redis/riot/cli/class-use/FileArgs.html | 25 +- .../cli/class-use/FileDumpExportArgs.html | 58 --- .../cli/class-use/FileDumpImportArgs.html | 58 --- .../riot/cli/class-use/FileImportArgs.html | 58 --- .../riot/cli/class-use/KeyFilterArgs.html | 36 +- .../cli/class-use/KeyValueProcessorArgs.html | 36 +- .../redis/riot/cli/class-use/RedisArgs.html | 42 +- .../RedisReaderArgs.ReadFromEnum.html | 18 + .../riot/cli/class-use/RedisReaderArgs.html | 36 +- .../riot/cli/class-use/RedisWriterArgs.html | 36 +- api/com/redis/riot/cli/package-summary.html | 64 ++- api/com/redis/riot/cli/package-tree.html | 15 +- api/com/redis/riot/cli/package-use.html | 12 +- api/com/redis/riot/core/AbstractExport.html | 120 ++--- api/com/redis/riot/core/AbstractImport.html | 130 ++---- .../redis/riot/core/AbstractMapExport.html | 27 +- .../redis/riot/core/AbstractMapImport.html | 283 ++++++++++++ .../riot/core/AbstractRedisCallable.html | 320 ++++++++++++++ .../riot/core/AbstractRedisRunnable.html | 220 --------- ...cutable.html => AbstractRiotCallable.html} | 151 ++++--- .../redis/riot/core/AbstractStructImport.html | 191 -------- api/com/redis/riot/core/KeyFilterOptions.html | 17 +- .../redis/riot/core/RedisReaderOptions.html | 180 ++------ .../redis/riot/core/RedisWriterOptions.html | 37 +- api/com/redis/riot/core/RiotUtils.html | 57 +-- .../riot/core/class-use/AbstractImport.html | 51 ++- ...ructImport.html => AbstractMapImport.html} | 64 ++- ...nnable.html => AbstractRedisCallable.html} | 38 +- ...cutable.html => AbstractRiotCallable.html} | 34 +- .../class-use/EvaluationContextOptions.html | 6 +- .../class-use/ImportProcessorOptions.html | 4 +- .../riot/core/class-use/KeyFilterOptions.html | 22 +- .../core/class-use/LoggingWriteListener.html | 58 --- .../core/class-use/RedisClientOptions.html | 4 +- .../core/class-use/RedisReaderOptions.html | 2 +- .../core/class-use/RedisWriterOptions.html | 7 - .../core/class-use/StepConfiguration.html | 2 +- .../core/class-use/TemplateExpression.html | 42 +- ...IdFunction.html => CompositeOperator.html} | 44 +- .../core/function/DropStreamMessageId.html | 171 +++++++ .../core/function/ExpressionFunction.html | 24 +- .../riot/core/function/KeyValueOperator.html | 207 --------- .../core/function/LongExpressionFunction.html | 2 +- .../core/function/StringKeyValueFunction.html | 18 +- .../function/ToStringKeyValueFunction.html | 18 +- ...ueOperator.html => CompositeOperator.html} | 10 +- ...Function.html => DropStreamMessageId.html} | 10 +- .../class-use/ExpressionFunction.html | 32 +- .../class-use/LongExpressionFunction.html | 27 +- .../riot/core/function/package-summary.html | 24 +- .../riot/core/function/package-tree.html | 8 +- .../redis/riot/core/function/package-use.html | 17 +- api/com/redis/riot/core/package-summary.html | 42 +- api/com/redis/riot/core/package-tree.html | 12 +- api/com/redis/riot/core/package-use.html | 93 ++-- api/com/redis/riot/db/DatabaseExport.html | 25 +- api/com/redis/riot/db/DatabaseImport.html | 34 +- api/com/redis/riot/db/package-tree.html | 8 +- api/com/redis/riot/faker/FakerImport.html | 34 +- api/com/redis/riot/faker/package-tree.html | 8 +- api/com/redis/riot/file/FileDumpExport.html | 27 +- api/com/redis/riot/file/FileDumpImport.html | 33 +- api/com/redis/riot/file/FileImport.html | 38 +- .../riot/file/class-use/FileDumpType.html | 33 +- .../redis/riot/file/class-use/FileType.html | 27 +- api/com/redis/riot/file/package-tree.html | 8 +- api/com/redis/riot/file/package-use.html | 6 +- api/com/redis/riot/redis/GeneratorImport.html | 33 +- api/com/redis/riot/redis/Ping.html | 27 +- .../Replication.LoggingWriteListener.html} | 34 +- api/com/redis/riot/redis/Replication.html | 283 ++++++++++-- .../riot/redis/class-use/CompareMode.html | 27 +- .../Replication.LoggingWriteListener.html} | 10 +- .../riot/redis/class-use/ReplicationMode.html | 27 +- api/com/redis/riot/redis/package-summary.html | 8 +- api/com/redis/riot/redis/package-tree.html | 7 +- api/com/redis/riot/redis/package-use.html | 8 +- api/constant-values.html | 63 +-- api/index-files/index-1.html | 40 +- api/index-files/index-10.html | 6 +- api/index-files/index-11.html | 10 +- api/index-files/index-12.html | 4 +- api/index-files/index-14.html | 2 +- api/index-files/index-15.html | 4 - api/index-files/index-16.html | 4 +- api/index-files/index-18.html | 6 + api/index-files/index-19.html | 252 +++++++++-- api/index-files/index-20.html | 2 +- api/index-files/index-23.html | 6 +- api/index-files/index-3.html | 30 +- api/index-files/index-4.html | 30 +- api/index-files/index-5.html | 12 +- api/index-files/index-6.html | 22 +- api/index-files/index-7.html | 206 ++++++++- api/index-files/index-9.html | 36 +- api/member-search-index.js | 2 +- api/overview-tree.html | 91 ++-- api/type-search-index.js | 2 +- index.html | 10 +- riot-3.2.2.pdf => riot-3.2.3.pdf | Bin 572549 -> 572549 bytes 125 files changed, 4829 insertions(+), 2961 deletions(-) delete mode 100644 api/com/redis/riot/cli/DbExportArgs.html delete mode 100644 api/com/redis/riot/cli/DbImportArgs.html delete mode 100644 api/com/redis/riot/cli/FileDumpExportArgs.html delete mode 100644 api/com/redis/riot/cli/FileDumpImportArgs.html delete mode 100644 api/com/redis/riot/cli/FileImportArgs.html delete mode 100644 api/com/redis/riot/cli/class-use/DbImportArgs.html delete mode 100644 api/com/redis/riot/cli/class-use/FileDumpExportArgs.html delete mode 100644 api/com/redis/riot/cli/class-use/FileDumpImportArgs.html delete mode 100644 api/com/redis/riot/cli/class-use/FileImportArgs.html create mode 100644 api/com/redis/riot/core/AbstractMapImport.html create mode 100644 api/com/redis/riot/core/AbstractRedisCallable.html delete mode 100644 api/com/redis/riot/core/AbstractRedisRunnable.html rename api/com/redis/riot/core/{AbstractExecutable.html => AbstractRiotCallable.html} (77%) delete mode 100644 api/com/redis/riot/core/AbstractStructImport.html rename api/com/redis/riot/core/class-use/{AbstractStructImport.html => AbstractMapImport.html} (50%) rename api/com/redis/riot/core/class-use/{AbstractRedisRunnable.html => AbstractRedisCallable.html} (83%) rename api/com/redis/riot/core/class-use/{AbstractExecutable.html => AbstractRiotCallable.html} (76%) delete mode 100644 api/com/redis/riot/core/class-use/LoggingWriteListener.html rename api/com/redis/riot/core/function/{DropStreamMessageIdFunction.html => CompositeOperator.html} (72%) create mode 100644 api/com/redis/riot/core/function/DropStreamMessageId.html delete mode 100644 api/com/redis/riot/core/function/KeyValueOperator.html rename api/com/redis/riot/core/function/class-use/{KeyValueOperator.html => CompositeOperator.html} (83%) rename api/com/redis/riot/core/function/class-use/{DropStreamMessageIdFunction.html => DropStreamMessageId.html} (86%) rename api/com/redis/riot/{core/LoggingWriteListener.html => redis/Replication.LoggingWriteListener.html} (79%) rename api/com/redis/riot/{cli/class-use/DbExportArgs.html => redis/class-use/Replication.LoggingWriteListener.html} (79%) rename riot-3.2.2.pdf => riot-3.2.3.pdf (99%) diff --git a/api/allclasses-index.html b/api/allclasses-index.html index d7c5a6673..ddad6599a 100644 --- a/api/allclasses-index.html +++ b/api/allclasses-index.html @@ -63,36 +63,36 @@

All Classes and Interfaces<
Description
 
- +
 
- +
 
- +
 
- +
 
- +
 
- +
 
- -
 
- -
+ +
CommandLine.IVersionProvider implementation that returns version information from the jar file's /META-INF/MANIFEST.MF file.
- + +
 
+
 
 
- +
 
Base class for item writers that write data to a file or stream.
- +
 
 
@@ -108,85 +108,77 @@

All Classes and Interfaces<
 
 
- -
+ +
 
+ +
An OutputStream that counts the number of bytes written.
- -
 
- +
 
- +
 
- +
 
- +
 
 
- +
 
- +
 
- +
 
- +
 
- +
 
- +
 
- -
 
- -
 
- -
 
- + +
 
+
 
- +
 
- +
 
- +
 
- +
 
- +
 
- -
+ +
 
+ +
ItemReader that generates HashMaps using Faker.
- -
 
- -
 
- -
 
- +
 
- +
 
- + +
 
+ +
 
+
 
- +
 
 
 
- +
 
- -
 
- -
 
- +
 
- -
 
- + +
 
+
 
 
@@ -258,13 +250,9 @@

All Classes and Interfaces<
 
 
- +
 
- -
 
- -
 
- +
 
 
@@ -345,89 +333,91 @@

All Classes and Interfaces<
 
 
- -
 
- -
 
- +
 
- + +
 
+ +
 
+
 
- +
 
- +
 
- +
 
- -
 
- -
 
- +
 
- +
 
- -
 
- + +
 
+
 
- + +
 
+ +
 
+
 
- +
 
- +
 
- +
 
- +
 
- +
 
- +
 
- +
 
- +
 
- -
+ +
 
+ +
Wrapper for a WritableByteChannel that delays actually writing to or closing the buffer if a transaction is active.
- -
 
- +
 
- -
 
- -
 
- +
 
- +
 
- -
-
ItemStreamReader implementation that reads XML objects from a Resource having the following format:
-
- + +
 
+
 
- +
 
- +
-
Item writer that writes data in XML format to an output file.
+
ItemStreamReader implementation that reads XML objects from a Resource having the following format:
- + +
 
+ +
 
+
+
Item writer that writes data in XML format to an output file.
+
+ +
- -
 
- +
 
- +
 
+ +
 

diff --git a/api/com/redis/riot/cli/AbstractExportCommand.html b/api/com/redis/riot/cli/AbstractExportCommand.html index 05fd98269..88a8f2c93 100644 --- a/api/com/redis/riot/cli/AbstractExportCommand.html +++ b/api/com/redis/riot/cli/AbstractExportCommand.html @@ -140,18 +140,36 @@

Method Summary

org.springframework.batch.item.ItemReader<?> reader, org.springframework.batch.item.ItemWriter<?> writer)
 
-
protected LongSupplier
-
initialMaxSupplier(String stepName, + + +
 
+ + +
 
+ + +
 
+
protected LongSupplier
+
initialMaxSupplier(String stepName, org.springframework.batch.item.ItemReader<?> reader)
+
 
+ +
 
- - +
void
+
 
void
 
void
-
setProgressStyle(com.redis.riot.cli.AbstractRiotCommand.ProgressStyle style)
+ +
 
+
void
+
setProgressStyle(com.redis.riot.cli.AbstractRiotCommand.ProgressStyle style)
+
 
+
void
+
 
protected String
taskName(String stepName)
@@ -204,7 +222,7 @@

Method Details

  • runnable

    -
    protected AbstractRedisRunnable runnable()
    +
    protected AbstractRedisCallable runnable()
  • @@ -221,6 +239,42 @@

    initialMaxSupplier

  • +
    +

    getReaderArgs

    +
    public RedisReaderArgs getReaderArgs()
    +
    +
  • +
  • +
    +

    setReaderArgs

    +
    public void setReaderArgs(RedisReaderArgs readerArgs)
    +
    +
  • +
  • +
    +

    getProcessorArgs

    +
    public KeyValueProcessorArgs getProcessorArgs()
    +
    +
  • +
  • +
    +

    setProcessorArgs

    +
    public void setProcessorArgs(KeyValueProcessorArgs processorArgs)
    +
    +
  • +
  • +
    +

    getKeyFilterArgs

    +
    public KeyFilterArgs getKeyFilterArgs()
    +
    +
  • +
  • +
    +

    setKeyFilterArgs

    +
    public void setKeyFilterArgs(KeyFilterArgs keyFilterArgs)
    +
    +
  • +
  • setName

    public void setName(String name)
    diff --git a/api/com/redis/riot/cli/AbstractImportCommand.html b/api/com/redis/riot/cli/AbstractImportCommand.html index b1360ebc1..3ca61f942 100644 --- a/api/com/redis/riot/cli/AbstractImportCommand.html +++ b/api/com/redis/riot/cli/AbstractImportCommand.html @@ -140,7 +140,7 @@

    Method Summary

     
    -
    protected abstract AbstractImport
    +
    protected abstract AbstractMapImport
     
    protected LongSupplier
    @@ -150,7 +150,7 @@

    Method Summary

    protected List<com.redis.spring.batch.operation.Operation<String,String,Map<String,Object>,Object>>
     
    -
    protected AbstractImport
    +
     
    void
    @@ -231,13 +231,13 @@

    operations

  • runnable

    -
    protected AbstractImport runnable()
    +
    protected AbstractMapImport runnable()
  • importRunnable

    -
    protected abstract AbstractImport importRunnable()
    +
    protected abstract AbstractMapImport importRunnable()
  • diff --git a/api/com/redis/riot/cli/AbstractMainCommand.html b/api/com/redis/riot/cli/AbstractMainCommand.html index 7f8f02c95..a618d5c77 100644 --- a/api/com/redis/riot/cli/AbstractMainCommand.html +++ b/api/com/redis/riot/cli/AbstractMainCommand.html @@ -115,20 +115,26 @@

    Method Summary

    Modifier and Type
    Method
    Description
    -
    void
    -
    run()
    + +
     
    -
    static int
    -
    run(AbstractMainCommand cmd, +
    void
    +
    run()
    +
     
    +
    static int
    +
    run(AbstractMainCommand cmd, PrintWriter out, PrintWriter err, String[] args, picocli.CommandLine.IExecutionStrategy... executionStrategies)
    -
     
    -
    static int
    -
    run(AbstractMainCommand cmd, - String... args)
     
    +
    static int
    +
    run(AbstractMainCommand cmd, + String... args)
    +
     
    +
    void
    + +
     
  • @@ -187,6 +193,18 @@

    run

    picocli.CommandLine.IExecutionStrategy... executionStrategies) +
  • +
    +

    getRedisArgs

    +
    public RedisArgs getRedisArgs()
    +
    +
  • +
  • +
    +

    setRedisArgs

    +
    public void setRedisArgs(RedisArgs redisArgs)
    +
    +
  • diff --git a/api/com/redis/riot/cli/AbstractStructImportCommand.html b/api/com/redis/riot/cli/AbstractStructImportCommand.html index c85defdab..6ee5be366 100644 --- a/api/com/redis/riot/cli/AbstractStructImportCommand.html +++ b/api/com/redis/riot/cli/AbstractStructImportCommand.html @@ -137,14 +137,14 @@

    Method Summary

    org.springframework.batch.item.ItemReader<?> reader, org.springframework.batch.item.ItemWriter<?> writer)
     
    -
    protected abstract AbstractStructImport
    +
    protected abstract AbstractImport
     
    protected LongSupplier
    initialMaxSupplier(String stepName, org.springframework.batch.item.ItemReader<?> reader)
     
    - +
    protected AbstractImport
     
    void
    @@ -204,13 +204,13 @@

    Method Details

  • runnable

    -
    protected AbstractStructImport runnable()
    +
    protected AbstractImport runnable()
  • importRunnable

    -
    protected abstract AbstractStructImport importRunnable()
    +
    protected abstract AbstractImport importRunnable()
  • diff --git a/api/com/redis/riot/cli/DbArgs.html b/api/com/redis/riot/cli/DbArgs.html index eba7300c6..a2dc4d779 100644 --- a/api/com/redis/riot/cli/DbArgs.html +++ b/api/com/redis/riot/cli/DbArgs.html @@ -76,10 +76,6 @@

    Class DbArgs

    com.redis.riot.cli.DbArgs
    -
    -
    Direct Known Subclasses:
    -
    DbExportArgs, DbImportArgs
    -

    public class DbArgs extends Object
    @@ -113,6 +109,30 @@

    Method Summary

     
    + + +
     
    + + +
     
    + + +
     
    + + +
     
    +
    void
    +
    setDriver(String driver)
    +
     
    +
    void
    +
    setPassword(String password)
    +
     
    +
    void
    + +
     
    +
    void
    +
    setUsername(String username)
    +
     
    @@ -150,6 +170,54 @@

    dataSourceOptions

    public DataSourceOptions dataSourceOptions()
  • +
  • +
    +

    getDriver

    +
    public String getDriver()
    +
    +
  • +
  • +
    +

    setDriver

    +
    public void setDriver(String driver)
    +
    +
  • +
  • +
    +

    getUrl

    +
    public String getUrl()
    +
    +
  • +
  • +
    +

    setUrl

    +
    public void setUrl(String url)
    +
    +
  • +
  • +
    +

    getUsername

    +
    public String getUsername()
    +
    +
  • +
  • +
    +

    setUsername

    +
    public void setUsername(String username)
    +
    +
  • +
  • +
    +

    getPassword

    +
    public String getPassword()
    +
    +
  • +
  • +
    +

    setPassword

    +
    public void setPassword(String password)
    +
    +
  • diff --git a/api/com/redis/riot/cli/DbExportArgs.html b/api/com/redis/riot/cli/DbExportArgs.html deleted file mode 100644 index 9be72c235..000000000 --- a/api/com/redis/riot/cli/DbExportArgs.html +++ /dev/null @@ -1,133 +0,0 @@ - - - - -DbExportArgs (riot unspecified) - - - - - - - - - - - - - - -
    - -
    -
    - -
    - -

    Class DbExportArgs

    -
    -
    java.lang.Object -
    com.redis.riot.cli.DbArgs -
    com.redis.riot.cli.DbExportArgs
    -
    -
    -
    -
    -
    public class DbExportArgs -extends DbArgs
    -
    -
    - -
    -
    -
      - -
    • -
      -

      Constructor Details

      -
        -
      • -
        -

        DbExportArgs

        -
        public DbExportArgs()
        -
        -
      • -
      -
      -
    • -
    -
    - -
    -
    -
    - - diff --git a/api/com/redis/riot/cli/DbExportCommand.html b/api/com/redis/riot/cli/DbExportCommand.html index d6cbbea26..f3379b55e 100644 --- a/api/com/redis/riot/cli/DbExportCommand.html +++ b/api/com/redis/riot/cli/DbExportCommand.html @@ -138,11 +138,35 @@

    Method Summary

    org.springframework.batch.item.ItemReader<?> reader, org.springframework.batch.item.ItemWriter<?> writer)
     
    + + +
     
    + + +
     
    + + +
     
    +
    boolean
    + +
     
    +
    void
    +
    setAssertUpdates(boolean assertUpdates)
    +
     
    +
    void
    +
    setDbArgs(DbArgs dbArgs)
    +
     
    +
    void
    +
    setKeyRegex(Pattern keyRegex)
    +
     
    +
    void
    + +
     
    void
    - +
    setProgressStyle(com.redis.riot.cli.AbstractRiotCommand.ProgressStyle style)
     
    void
    -
    setProgressStyle(com.redis.riot.cli.AbstractRiotCommand.ProgressStyle style)
    +
     
    protected String
    taskName(String stepName)
    @@ -152,7 +176,7 @@

    Method Summary

    Methods inherited from class com.redis.riot.cli.AbstractExportCommand

    -initialMaxSupplier, runnable
    +getKeyFilterArgs, getProcessorArgs, getReaderArgs, initialMaxSupplier, runnable, setKeyFilterArgs, setProcessorArgs, setReaderArgs

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    @@ -206,6 +230,54 @@

    exportRunnable

  • +
    +

    getSql

    +
    public String getSql()
    +
    +
  • +
  • +
    +

    setSql

    +
    public void setSql(String sql)
    +
    +
  • +
  • +
    +

    getDbArgs

    +
    public DbArgs getDbArgs()
    +
    +
  • +
  • +
    +

    setDbArgs

    +
    public void setDbArgs(DbArgs dbArgs)
    +
    +
  • +
  • +
    +

    getKeyRegex

    +
    public Pattern getKeyRegex()
    +
    +
  • +
  • +
    +

    setKeyRegex

    +
    public void setKeyRegex(Pattern keyRegex)
    +
    +
  • +
  • +
    +

    isAssertUpdates

    +
    public boolean isAssertUpdates()
    +
    +
  • +
  • +
    +

    setAssertUpdates

    +
    public void setAssertUpdates(boolean assertUpdates)
    +
    +
  • +
  • setName

    public void setName(String name)
    diff --git a/api/com/redis/riot/cli/DbImportArgs.html b/api/com/redis/riot/cli/DbImportArgs.html deleted file mode 100644 index 64d339087..000000000 --- a/api/com/redis/riot/cli/DbImportArgs.html +++ /dev/null @@ -1,133 +0,0 @@ - - - - -DbImportArgs (riot unspecified) - - - - - - - - - - - - - - -
    - -
    -
    - -
    - -

    Class DbImportArgs

    -
    -
    java.lang.Object -
    com.redis.riot.cli.DbArgs -
    com.redis.riot.cli.DbImportArgs
    -
    -
    -
    -
    -
    public class DbImportArgs -extends DbArgs
    -
    -
    - -
    -
    -
      - -
    • -
      -

      Constructor Details

      -
        -
      • -
        -

        DbImportArgs

        -
        public DbImportArgs()
        -
        -
      • -
      -
      -
    • -
    -
    - -
    -
    -
    - - diff --git a/api/com/redis/riot/cli/DbImportCommand.html b/api/com/redis/riot/cli/DbImportCommand.html index 89396b18d..94251c3cf 100644 --- a/api/com/redis/riot/cli/DbImportCommand.html +++ b/api/com/redis/riot/cli/DbImportCommand.html @@ -135,19 +135,67 @@

    Method Summary

    org.springframework.batch.item.ItemReader<?> reader, org.springframework.batch.item.ItemWriter<?> writer)
     
    -
    protected AbstractImport
    + + +
     
    +
    int
    + +
     
    +
    int
    + +
     
    +
    int
    + +
     
    +
    int
    + +
     
    + + +
     
    +
     
    protected LongSupplier
    initialMaxSupplier(String stepName, org.springframework.batch.item.ItemReader<?> reader)
     
    +
    boolean
    + +
     
    +
    boolean
    + +
     
    +
    void
    +
    setDbArgs(DbArgs dbArgs)
    +
     
    +
    void
    +
    setFetchSize(int fetchSize)
    +
     
    +
    void
    +
    setMaxItemCount(int maxItemCount)
    +
     
    +
    void
    +
    setMaxResultSetRows(int maxResultSetRows)
    +
     
    void
     
    void
    setProgressStyle(com.redis.riot.cli.AbstractRiotCommand.ProgressStyle style)
     
    +
    void
    +
    setQueryTimeout(int queryTimeout)
    +
     
    +
    void
    + +
     
    +
    void
    +
    setUseSharedExtendedConnection(boolean useSharedExtendedConnection)
    +
     
    +
    void
    +
    setVerifyCursorPosition(boolean verifyCursorPosition)
    +
     
    @@ -199,7 +247,7 @@

    Method Details

  • importRunnable

    -
    protected AbstractImport importRunnable()
    +
    protected AbstractMapImport importRunnable()
    Specified by:
    importRunnable in class AbstractImportCommand
    @@ -207,6 +255,102 @@

    importRunnable

  • +
    +

    getSql

    +
    public String getSql()
    +
    +
  • +
  • +
    +

    setSql

    +
    public void setSql(String sql)
    +
    +
  • +
  • +
    +

    getDbArgs

    +
    public DbArgs getDbArgs()
    +
    +
  • +
  • +
    +

    setDbArgs

    +
    public void setDbArgs(DbArgs dbArgs)
    +
    +
  • +
  • +
    +

    getMaxItemCount

    +
    public int getMaxItemCount()
    +
    +
  • +
  • +
    +

    setMaxItemCount

    +
    public void setMaxItemCount(int maxItemCount)
    +
    +
  • +
  • +
    +

    getFetchSize

    +
    public int getFetchSize()
    +
    +
  • +
  • +
    +

    setFetchSize

    +
    public void setFetchSize(int fetchSize)
    +
    +
  • +
  • +
    +

    getMaxResultSetRows

    +
    public int getMaxResultSetRows()
    +
    +
  • +
  • +
    +

    setMaxResultSetRows

    +
    public void setMaxResultSetRows(int maxResultSetRows)
    +
    +
  • +
  • +
    +

    getQueryTimeout

    +
    public int getQueryTimeout()
    +
    +
  • +
  • +
    +

    setQueryTimeout

    +
    public void setQueryTimeout(int queryTimeout)
    +
    +
  • +
  • +
    +

    isUseSharedExtendedConnection

    +
    public boolean isUseSharedExtendedConnection()
    +
    +
  • +
  • +
    +

    setUseSharedExtendedConnection

    +
    public void setUseSharedExtendedConnection(boolean useSharedExtendedConnection)
    +
    +
  • +
  • +
    +

    isVerifyCursorPosition

    +
    public boolean isVerifyCursorPosition()
    +
    +
  • +
  • +
    +

    setVerifyCursorPosition

    +
    public void setVerifyCursorPosition(boolean verifyCursorPosition)
    +
    +
  • +
  • setName

    public void setName(String name)
    diff --git a/api/com/redis/riot/cli/FileArgs.html b/api/com/redis/riot/cli/FileArgs.html index caa8b19a1..d5fed0ec9 100644 --- a/api/com/redis/riot/cli/FileArgs.html +++ b/api/com/redis/riot/cli/FileArgs.html @@ -76,10 +76,6 @@

    Class FileArgs

    com.redis.riot.cli.FileArgs
    -
    -
    Direct Known Subclasses:
    -
    FileDumpExportArgs, FileDumpImportArgs, FileImportArgs
    -

    public class FileArgs extends Object
    @@ -113,6 +109,30 @@

    Method Summary

     
    + + +
     
    +
    com.redis.riot.cli.FileArgs.GcsArgs
    + +
     
    +
    com.redis.riot.cli.FileArgs.S3Args
    + +
     
    +
    boolean
    + +
     
    +
    void
    +
    setEncoding(String encoding)
    +
     
    +
    void
    +
    setGcs(com.redis.riot.cli.FileArgs.GcsArgs gcs)
    +
     
    +
    void
    +
    setGzipped(boolean gzipped)
    +
     
    +
    void
    +
    setS3(com.redis.riot.cli.FileArgs.S3Args s3)
    +
     
    @@ -150,6 +170,54 @@

    fileOptions

    public FileOptions fileOptions()
  • +
  • +
    +

    getEncoding

    +
    public String getEncoding()
    +
    +
  • +
  • +
    +

    setEncoding

    +
    public void setEncoding(String encoding)
    +
    +
  • +
  • +
    +

    isGzipped

    +
    public boolean isGzipped()
    +
    +
  • +
  • +
    +

    setGzipped

    +
    public void setGzipped(boolean gzipped)
    +
    +
  • +
  • +
    +

    getS3

    +
    public com.redis.riot.cli.FileArgs.S3Args getS3()
    +
    +
  • +
  • +
    +

    setS3

    +
    public void setS3(com.redis.riot.cli.FileArgs.S3Args s3)
    +
    +
  • +
  • +
    +

    getGcs

    +
    public com.redis.riot.cli.FileArgs.GcsArgs getGcs()
    +
    +
  • +
  • +
    +

    setGcs

    +
    public void setGcs(com.redis.riot.cli.FileArgs.GcsArgs gcs)
    +
    +
  • diff --git a/api/com/redis/riot/cli/FileDumpExportArgs.html b/api/com/redis/riot/cli/FileDumpExportArgs.html deleted file mode 100644 index b61cb34cd..000000000 --- a/api/com/redis/riot/cli/FileDumpExportArgs.html +++ /dev/null @@ -1,133 +0,0 @@ - - - - -FileDumpExportArgs (riot unspecified) - - - - - - - - - - - - - - -
    - -
    -
    - -
    - -

    Class FileDumpExportArgs

    -
    -
    java.lang.Object -
    com.redis.riot.cli.FileArgs -
    com.redis.riot.cli.FileDumpExportArgs
    -
    -
    -
    -
    -
    public class FileDumpExportArgs -extends FileArgs
    -
    -
    - -
    -
    -
      - -
    • -
      -

      Constructor Details

      -
        -
      • -
        -

        FileDumpExportArgs

        -
        public FileDumpExportArgs()
        -
        -
      • -
      -
      -
    • -
    -
    - -
    -
    -
    - - diff --git a/api/com/redis/riot/cli/FileDumpExportCommand.html b/api/com/redis/riot/cli/FileDumpExportCommand.html index ec57ea8ed..ffbdb9ffb 100644 --- a/api/com/redis/riot/cli/FileDumpExportCommand.html +++ b/api/com/redis/riot/cli/FileDumpExportCommand.html @@ -138,12 +138,54 @@

    Method Summary

    org.springframework.batch.item.ItemReader<?> reader, org.springframework.batch.item.ItemWriter<?> writer)
     
    +
    String
    +
    getElementName()
    +
     
    +
    String
    +
    getFile()
    +
     
    +
    FileArgs
    +
    getFileArgs()
    +
     
    +
    String
    +
    getLineSeparator()
    +
     
    +
    String
    +
    getRootName()
    +
     
    +
    FileDumpType
    +
    getType()
    +
     
    +
    boolean
    +
    isAppend()
    +
     
    +
    void
    +
    setAppend(boolean append)
    +
     
    +
    void
    +
    setElementName(String elementName)
    +
     
    +
    void
    +
    setFile(String file)
    +
     
    +
    void
    +
    setFileArgs(FileArgs fileArgs)
    +
     
    +
    void
    +
    setLineSeparator(String lineSeparator)
    +
     
    void
    setName(String name)
     
    void
    setProgressStyle(com.redis.riot.cli.AbstractRiotCommand.ProgressStyle style)
     
    +
    void
    +
    setRootName(String rootName)
    +
     
    +
    void
    +
    setType(FileDumpType type)
    +
     
    protected String
    taskName(String stepName)
     
    @@ -152,7 +194,7 @@

    Method Summary

    Methods inherited from class com.redis.riot.cli.AbstractExportCommand

    -initialMaxSupplier, runnable
    +getKeyFilterArgs, getProcessorArgs, getReaderArgs, initialMaxSupplier, runnable, setKeyFilterArgs, setProcessorArgs, setReaderArgs

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    @@ -206,6 +248,90 @@

    exportRunnable

  • +
    +

    getFileArgs

    +
    public FileArgs getFileArgs()
    +
    +
  • +
  • +
    +

    setFileArgs

    +
    public void setFileArgs(FileArgs fileArgs)
    +
    +
  • +
  • +
    +

    getFile

    +
    public String getFile()
    +
    +
  • +
  • +
    +

    setFile

    +
    public void setFile(String file)
    +
    +
  • +
  • +
    +

    getType

    +
    public FileDumpType getType()
    +
    +
  • +
  • +
    +

    setType

    +
    public void setType(FileDumpType type)
    +
    +
  • +
  • +
    +

    isAppend

    +
    public boolean isAppend()
    +
    +
  • +
  • +
    +

    setAppend

    +
    public void setAppend(boolean append)
    +
    +
  • +
  • +
    +

    getRootName

    +
    public String getRootName()
    +
    +
  • +
  • +
    +

    setRootName

    +
    public void setRootName(String rootName)
    +
    +
  • +
  • +
    +

    getElementName

    +
    public String getElementName()
    +
    +
  • +
  • +
    +

    setElementName

    +
    public void setElementName(String elementName)
    +
    +
  • +
  • +
    +

    getLineSeparator

    +
    public String getLineSeparator()
    +
    +
  • +
  • +
    +

    setLineSeparator

    +
    public void setLineSeparator(String lineSeparator)
    +
    +
  • +
  • setName

    public void setName(String name)
    diff --git a/api/com/redis/riot/cli/FileDumpImportArgs.html b/api/com/redis/riot/cli/FileDumpImportArgs.html deleted file mode 100644 index 35654401f..000000000 --- a/api/com/redis/riot/cli/FileDumpImportArgs.html +++ /dev/null @@ -1,133 +0,0 @@ - - - - -FileDumpImportArgs (riot unspecified) - - - - - - - - - - - - - - -
    - -
    -
    - -
    - -

    Class FileDumpImportArgs

    -
    -
    java.lang.Object -
    com.redis.riot.cli.FileArgs -
    com.redis.riot.cli.FileDumpImportArgs
    -
    -
    -
    -
    -
    public class FileDumpImportArgs -extends FileArgs
    -
    -
    - -
    -
    -
      - -
    • -
      -

      Constructor Details

      -
        -
      • -
        -

        FileDumpImportArgs

        -
        public FileDumpImportArgs()
        -
        -
      • -
      -
      -
    • -
    -
    - -
    -
    -
    - - diff --git a/api/com/redis/riot/cli/FileDumpImportCommand.html b/api/com/redis/riot/cli/FileDumpImportCommand.html index bf6f41f42..5ba6e3aa2 100644 --- a/api/com/redis/riot/cli/FileDumpImportCommand.html +++ b/api/com/redis/riot/cli/FileDumpImportCommand.html @@ -135,6 +135,12 @@

    Method Summary

    org.springframework.batch.item.ItemReader<?> reader, org.springframework.batch.item.ItemWriter<?> writer)
     
    + + +
     
    + + +
     
    protected FileDumpImport
     
    @@ -143,10 +149,16 @@

    Method Summary

    org.springframework.batch.item.ItemReader<?> reader)
     
    void
    - +
     
    void
    -
    setProgressStyle(com.redis.riot.cli.AbstractRiotCommand.ProgressStyle style)
    + +
     
    +
    void
    +
    setProgressStyle(com.redis.riot.cli.AbstractRiotCommand.ProgressStyle style)
    +
     
    +
    void
    +
     
    protected String
    taskName(String stepName)
    @@ -216,6 +228,30 @@

    taskName

  • +
    +

    getFiles

    +
    public List<String> getFiles()
    +
    +
  • +
  • +
    +

    setFiles

    +
    public void setFiles(List<String> files)
    +
    +
  • +
  • +
    +

    getType

    +
    public FileDumpType getType()
    +
    +
  • +
  • +
    +

    setType

    +
    public void setType(FileDumpType type)
    +
    +
  • +
  • setName

    public void setName(String name)
    diff --git a/api/com/redis/riot/cli/FileImportArgs.html b/api/com/redis/riot/cli/FileImportArgs.html deleted file mode 100644 index b0802cf6b..000000000 --- a/api/com/redis/riot/cli/FileImportArgs.html +++ /dev/null @@ -1,133 +0,0 @@ - - - - -FileImportArgs (riot unspecified) - - - - - - - - - - - - - - -
    - -
    -
    - -
    - -

    Class FileImportArgs

    -
    -
    java.lang.Object -
    com.redis.riot.cli.FileArgs -
    com.redis.riot.cli.FileImportArgs
    -
    -
    -
    -
    -
    public class FileImportArgs -extends FileArgs
    -
    -
    - -
    -
    -
      - -
    • -
      -

      Constructor Details

      -
        -
      • -
        -

        FileImportArgs

        -
        public FileImportArgs()
        -
        -
      • -
      -
      -
    • -
    -
    - -
    -
    -
    - - diff --git a/api/com/redis/riot/cli/FileImportCommand.html b/api/com/redis/riot/cli/FileImportCommand.html index 50fd1e6c0..0d1690c8b 100644 --- a/api/com/redis/riot/cli/FileImportCommand.html +++ b/api/com/redis/riot/cli/FileImportCommand.html @@ -135,12 +135,90 @@

    Method Summary

    org.springframework.batch.item.ItemReader<?> reader, org.springframework.batch.item.ItemWriter<?> writer)
     
    -
    protected AbstractImport
    - + +
     
    -
    protected LongSupplier
    -
    initialMaxSupplier(String stepName, + + +
     
    + + +
     
    + + +
     
    + + +
     
    + + +
     
    + + +
     
    + + +
     
    +
    int[]
    + +
     
    + + +
     
    + + +
     
    + + +
     
    + + +
     
    + + +
     
    +
    protected LongSupplier
    +
    initialMaxSupplier(String stepName, org.springframework.batch.item.ItemReader<?> reader)
    +
     
    +
    boolean
    + +
     
    +
    void
    +
    setColumnRanges(List<String> columnRanges)
    +
     
    +
    void
    +
    setContinuationString(String continuationString)
    +
     
    +
    void
    +
    setDelimiter(String delimiter)
    +
     
    +
    void
    + +
     
    +
    void
    + +
     
    +
    void
    + +
     
    +
    void
    + +
     
    +
    void
    +
    setHeader(boolean header)
    +
     
    +
    void
    +
    setHeaderLine(Integer headerLine)
    +
     
    +
    void
    +
    setIncludedFields(int[] includedFields)
    +
     
    +
    void
    +
    setLinesToSkip(Integer linesToSkip)
    +
     
    +
    void
    +
    setMaxItemCount(Integer maxItemCount)
     
    void
    @@ -148,6 +226,12 @@

    Method Summary

    void
    setProgressStyle(com.redis.riot.cli.AbstractRiotCommand.ProgressStyle style)
     
    +
    void
    +
    setQuoteCharacter(Character quoteCharacter)
    +
     
    +
    void
    + +
     
    @@ -199,7 +283,7 @@

    Method Details

  • importRunnable

    -
    protected AbstractImport importRunnable()
    +
    protected AbstractMapImport importRunnable()
    Specified by:
    importRunnable in class AbstractImportCommand
    @@ -207,6 +291,174 @@

    importRunnable

  • +
    +

    getFileArgs

    +
    public FileArgs getFileArgs()
    +
    +
  • +
  • +
    +

    setFileArgs

    +
    public void setFileArgs(FileArgs fileArgs)
    +
    +
  • +
  • +
    +

    getFiles

    +
    public List<String> getFiles()
    +
    +
  • +
  • +
    +

    setFiles

    +
    public void setFiles(List<String> files)
    +
    +
  • +
  • +
    +

    getFileType

    +
    public FileType getFileType()
    +
    +
  • +
  • +
    +

    setFileType

    +
    public void setFileType(FileType fileType)
    +
    +
  • +
  • +
    +

    getMaxItemCount

    +
    public Integer getMaxItemCount()
    +
    +
  • +
  • +
    +

    setMaxItemCount

    +
    public void setMaxItemCount(Integer maxItemCount)
    +
    +
  • +
  • +
    +

    getFields

    +
    public List<String> getFields()
    +
    +
  • +
  • +
    +

    setFields

    +
    public void setFields(List<String> fields)
    +
    +
  • +
  • +
    +

    isHeader

    +
    public boolean isHeader()
    +
    +
  • +
  • +
    +

    setHeader

    +
    public void setHeader(boolean header)
    +
    +
  • +
  • +
    +

    getHeaderLine

    +
    public Integer getHeaderLine()
    +
    +
  • +
  • +
    +

    setHeaderLine

    +
    public void setHeaderLine(Integer headerLine)
    +
    +
  • +
  • +
    +

    getDelimiter

    +
    public String getDelimiter()
    +
    +
  • +
  • +
    +

    setDelimiter

    +
    public void setDelimiter(String delimiter)
    +
    +
  • +
  • +
    +

    getLinesToSkip

    +
    public Integer getLinesToSkip()
    +
    +
  • +
  • +
    +

    setLinesToSkip

    +
    public void setLinesToSkip(Integer linesToSkip)
    +
    +
  • +
  • +
    +

    getIncludedFields

    +
    public int[] getIncludedFields()
    +
    +
  • +
  • +
    +

    setIncludedFields

    +
    public void setIncludedFields(int[] includedFields)
    +
    +
  • +
  • +
    +

    getColumnRanges

    +
    public List<String> getColumnRanges()
    +
    +
  • +
  • +
    +

    setColumnRanges

    +
    public void setColumnRanges(List<String> columnRanges)
    +
    +
  • +
  • +
    +

    getQuoteCharacter

    +
    public Character getQuoteCharacter()
    +
    +
  • +
  • +
    +

    setQuoteCharacter

    +
    public void setQuoteCharacter(Character quoteCharacter)
    +
    +
  • +
  • +
    +

    getContinuationString

    +
    public String getContinuationString()
    +
    +
  • +
  • +
    +

    setContinuationString

    +
    public void setContinuationString(String continuationString)
    +
    +
  • +
  • +
    +

    getRegexes

    +
    public Map<String,Pattern> getRegexes()
    +
    +
  • +
  • +
    +

    setRegexes

    +
    public void setRegexes(Map<String,Pattern> regexes)
    +
    +
  • +
  • setName

    public void setName(String name)
    diff --git a/api/com/redis/riot/cli/KeyValueProcessorArgs.html b/api/com/redis/riot/cli/KeyValueProcessorArgs.html index 16a3efe4a..094a349c3 100644 --- a/api/com/redis/riot/cli/KeyValueProcessorArgs.html +++ b/api/com/redis/riot/cli/KeyValueProcessorArgs.html @@ -106,8 +106,38 @@

    Method Summary

    Modifier and Type
    Method
    Description
    - - + + +
     
    +
    org.springframework.expression.Expression
    + +
     
    +
    org.springframework.expression.Expression
    + +
     
    +
    boolean
    + +
     
    +
    boolean
    + +
     
    + + +
     
    +
    void
    +
    setDropStreamMessageIds(boolean dropStreamMessageIds)
    +
     
    +
    void
    +
    setDropTtl(boolean dropTtl)
    +
     
    +
    void
    + +
     
    +
    void
    +
    setTtlExpression(org.springframework.expression.Expression ttlExpression)
    +
     
    +
    void
    +
    setTypeExpression(org.springframework.expression.Expression typeExpression)
     
    @@ -146,6 +176,66 @@

    processorOptions

    public ExportProcessorOptions processorOptions()
  • +
  • +
    +

    getKeyExpression

    +
    public TemplateExpression getKeyExpression()
    +
    +
  • +
  • +
    +

    setKeyExpression

    +
    public void setKeyExpression(TemplateExpression keyExpression)
    +
    +
  • +
  • +
    +

    getTypeExpression

    +
    public org.springframework.expression.Expression getTypeExpression()
    +
    +
  • +
  • +
    +

    setTypeExpression

    +
    public void setTypeExpression(org.springframework.expression.Expression typeExpression)
    +
    +
  • +
  • +
    +

    getTtlExpression

    +
    public org.springframework.expression.Expression getTtlExpression()
    +
    +
  • +
  • +
    +

    setTtlExpression

    +
    public void setTtlExpression(org.springframework.expression.Expression ttlExpression)
    +
    +
  • +
  • +
    +

    isDropTtl

    +
    public boolean isDropTtl()
    +
    +
  • +
  • +
    +

    setDropTtl

    +
    public void setDropTtl(boolean dropTtl)
    +
    +
  • +
  • +
    +

    isDropStreamMessageIds

    +
    public boolean isDropStreamMessageIds()
    +
    +
  • +
  • +
    +

    setDropStreamMessageIds

    +
    public void setDropStreamMessageIds(boolean dropStreamMessageIds)
    +
    +
  • diff --git a/api/com/redis/riot/cli/Main.html b/api/com/redis/riot/cli/Main.html index 2d45a2183..010ede773 100644 --- a/api/com/redis/riot/cli/Main.html +++ b/api/com/redis/riot/cli/Main.html @@ -120,7 +120,7 @@

    Method Summary

    Methods inherited from class com.redis.riot.cli.AbstractMainCommand

    -run, run, run
    +getRedisArgs, run, run, run, setRedisArgs

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    diff --git a/api/com/redis/riot/cli/RedisArgs.html b/api/com/redis/riot/cli/RedisArgs.html index 57be12dd0..2d6c2cb5d 100644 --- a/api/com/redis/riot/cli/RedisArgs.html +++ b/api/com/redis/riot/cli/RedisArgs.html @@ -106,8 +106,146 @@

    Method Summary

    Modifier and Type
    Method
    Description
    - - + + +
     
    +
    int
    + +
     
    + + +
     
    + + +
     
    + + +
     
    +
    char[]
    + +
     
    + + +
     
    +
    char[]
    + +
     
    +
    long
    + +
     
    +
    char[]
    + +
     
    +
    int
    + +
     
    +
    io.lettuce.core.protocol.ProtocolVersion
    + +
     
    + + +
     
    +
    long
    + +
     
    + + +
     
    + + +
     
    +
    char[]
    + +
     
    + + +
     
    + + +
     
    +
    boolean
    + +
     
    +
    boolean
    + +
     
    +
    boolean
    + +
     
    +
    boolean
    + +
     
    + + +
     
    +
    void
    +
    setClientName(String clientName)
    +
     
    +
    void
    +
    setCluster(boolean cluster)
    +
     
    +
    void
    +
    setDatabase(int database)
    +
     
    +
    void
    + +
     
    +
    void
    +
    setInsecure(boolean insecure)
    +
     
    +
    void
    +
    setKey(File key)
    +
     
    +
    void
    +
    setKeyCert(File keyCert)
    +
     
    +
    void
    +
    setKeyPassword(char[] keyPassword)
    +
     
    +
    void
    +
    setKeystore(File keystore)
    +
     
    +
    void
    +
    setKeystorePassword(char[] keystorePassword)
    +
     
    +
    void
    +
    setMetricsStep(long metricsStep)
    +
     
    +
    void
    +
    setNoAutoReconnect(boolean noAutoReconnect)
    +
     
    +
    void
    +
    setPassword(char[] password)
    +
     
    +
    void
    +
    setPort(int port)
    +
     
    +
    void
    +
    setProtocolVersion(io.lettuce.core.protocol.ProtocolVersion protocolVersion)
    +
     
    +
    void
    +
    setSocket(String socket)
    +
     
    +
    void
    +
    setTimeout(long timeout)
    +
     
    +
    void
    +
    setTls(boolean tls)
    +
     
    +
    void
    +
    setTrustedCerts(File trustedCerts)
    +
     
    +
    void
    +
    setTruststore(File truststore)
    +
     
    +
    void
    +
    setTruststorePassword(char[] truststorePassword)
    +
     
    +
    void
    + +
     
    +
    void
    +
    setUsername(String username)
     
    @@ -146,6 +284,282 @@

    redisOptions

    public RedisClientOptions redisOptions()
    +
  • +
    +

    getUri

    +
    public String getUri()
    +
    +
  • +
  • +
    +

    setUri

    +
    public void setUri(String uri)
    +
    +
  • +
  • +
    +

    getHost

    +
    public String getHost()
    +
    +
  • +
  • +
    +

    setHost

    +
    public void setHost(String host)
    +
    +
  • +
  • +
    +

    getPort

    +
    public int getPort()
    +
    +
  • +
  • +
    +

    setPort

    +
    public void setPort(int port)
    +
    +
  • +
  • +
    +

    getSocket

    +
    public String getSocket()
    +
    +
  • +
  • +
    +

    setSocket

    +
    public void setSocket(String socket)
    +
    +
  • +
  • +
    +

    getUsername

    +
    public String getUsername()
    +
    +
  • +
  • +
    +

    setUsername

    +
    public void setUsername(String username)
    +
    +
  • +
  • +
    +

    getPassword

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

    setPassword

    +
    public void setPassword(char[] password)
    +
    +
  • +
  • +
    +

    getTimeout

    +
    public long getTimeout()
    +
    +
  • +
  • +
    +

    setTimeout

    +
    public void setTimeout(long timeout)
    +
    +
  • +
  • +
    +

    getDatabase

    +
    public int getDatabase()
    +
    +
  • +
  • +
    +

    setDatabase

    +
    public void setDatabase(int database)
    +
    +
  • +
  • +
    +

    getClientName

    +
    public String getClientName()
    +
    +
  • +
  • +
    +

    setClientName

    +
    public void setClientName(String clientName)
    +
    +
  • +
  • +
    +

    isTls

    +
    public boolean isTls()
    +
    +
  • +
  • +
    +

    setTls

    +
    public void setTls(boolean tls)
    +
    +
  • +
  • +
    +

    isInsecure

    +
    public boolean isInsecure()
    +
    +
  • +
  • +
    +

    setInsecure

    +
    public void setInsecure(boolean insecure)
    +
    +
  • +
  • +
    +

    isCluster

    +
    public boolean isCluster()
    +
    +
  • +
  • +
    +

    setCluster

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

    getMetricsStep

    +
    public long getMetricsStep()
    +
    +
  • +
  • +
    +

    setMetricsStep

    +
    public void setMetricsStep(long metricsStep)
    +
    +
  • +
  • +
    +

    isNoAutoReconnect

    +
    public boolean isNoAutoReconnect()
    +
    +
  • +
  • +
    +

    setNoAutoReconnect

    +
    public void setNoAutoReconnect(boolean noAutoReconnect)
    +
    +
  • +
  • +
    +

    getProtocolVersion

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

    setProtocolVersion

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

    getKeystore

    +
    public File getKeystore()
    +
    +
  • +
  • +
    +

    setKeystore

    +
    public void setKeystore(File keystore)
    +
    +
  • +
  • +
    +

    getKeystorePassword

    +
    public char[] getKeystorePassword()
    +
    +
  • +
  • +
    +

    setKeystorePassword

    +
    public void setKeystorePassword(char[] keystorePassword)
    +
    +
  • +
  • +
    +

    getTruststore

    +
    public File getTruststore()
    +
    +
  • +
  • +
    +

    setTruststore

    +
    public void setTruststore(File truststore)
    +
    +
  • +
  • +
    +

    getTruststorePassword

    +
    public char[] getTruststorePassword()
    +
    +
  • +
  • +
    +

    setTruststorePassword

    +
    public void setTruststorePassword(char[] truststorePassword)
    +
    +
  • +
  • +
    +

    getKeyCert

    +
    public File getKeyCert()
    +
    +
  • +
  • +
    +

    setKeyCert

    +
    public void setKeyCert(File keyCert)
    +
    +
  • +
  • +
    +

    getKey

    +
    public File getKey()
    +
    +
  • +
  • +
    +

    setKey

    +
    public void setKey(File key)
    +
    +
  • +
  • +
    +

    getKeyPassword

    +
    public char[] getKeyPassword()
    +
    +
  • +
  • +
    +

    setKeyPassword

    +
    public void setKeyPassword(char[] keyPassword)
    +
    +
  • +
  • +
    +

    getTrustedCerts

    +
    public File getTrustedCerts()
    +
    +
  • +
  • +
    +

    setTrustedCerts

    +
    public void setTrustedCerts(File trustedCerts)
    +
    +
  • diff --git a/api/com/redis/riot/cli/RedisReaderArgs.html b/api/com/redis/riot/cli/RedisReaderArgs.html index 172a856af..cca8b9844 100644 --- a/api/com/redis/riot/cli/RedisReaderArgs.html +++ b/api/com/redis/riot/cli/RedisReaderArgs.html @@ -121,14 +121,68 @@

    Method Summary

    Modifier and Type
    Method
    Description
    +
    int
    + +
     
    +
    int
    + +
     
    +
    int
    + +
     
    +
    int
    + +
     
    +
    int
    + +
     
    + + +
     
    +
    long
    + +
     
    + + +
     
    + + +
     
    +
    int
    + +
     
     
    void
    -
    setIdleTimeout(long timeout)
    +
    setChunkSize(int chunkSize)
    +
     
    +
    void
    +
    setMemLimit(int memLimit)
    +
     
    +
    void
    +
    setMemSamples(int memSamples)
    +
     
    +
    void
    +
    setPoolSize(int poolSize)
    +
     
    +
    void
    +
    setQueueCapacity(int queueCapacity)
    +
     
    +
    void
    + +
     
    +
    void
    +
    setScanCount(long scanCount)
     
    void
    - +
    setScanMatch(String scanMatch)
    +
     
    +
    void
    +
    setScanType(String scanType)
    +
     
    +
    void
    +
    setThreads(int threads)
     
    @@ -162,21 +216,129 @@

    RedisReaderArgs

    Method Details

    diff --git a/api/com/redis/riot/cli/RedisWriterArgs.html b/api/com/redis/riot/cli/RedisWriterArgs.html index 196b44fb0..8ae40067f 100644 --- a/api/com/redis/riot/cli/RedisWriterArgs.html +++ b/api/com/redis/riot/cli/RedisWriterArgs.html @@ -106,6 +106,36 @@

    Method Summary

    Modifier and Type
    Method
    Description
    +
    int
    + +
     
    +
    int
    + +
     
    +
    long
    + +
     
    +
    boolean
    + +
     
    +
    boolean
    + +
     
    +
    void
    +
    setMerge(boolean merge)
    +
     
    +
    void
    +
    setMultiExec(boolean multiExec)
    +
     
    +
    void
    +
    setPoolSize(int poolSize)
    +
     
    +
    void
    +
    setWaitReplicas(int waitReplicas)
    +
     
    +
    void
    +
    setWaitTimeout(long waitTimeout)
    +
     
     
    @@ -146,6 +176,66 @@

    writerOptions

    public RedisWriterOptions writerOptions()
    +
  • +
    +

    isMultiExec

    +
    public boolean isMultiExec()
    +
    +
  • +
  • +
    +

    setMultiExec

    +
    public void setMultiExec(boolean multiExec)
    +
    +
  • +
  • +
    +

    getWaitReplicas

    +
    public int getWaitReplicas()
    +
    +
  • +
  • +
    +

    setWaitReplicas

    +
    public void setWaitReplicas(int waitReplicas)
    +
    +
  • +
  • +
    +

    getWaitTimeout

    +
    public long getWaitTimeout()
    +
    +
  • +
  • +
    +

    setWaitTimeout

    +
    public void setWaitTimeout(long waitTimeout)
    +
    +
  • +
  • +
    +

    getPoolSize

    +
    public int getPoolSize()
    +
    +
  • +
  • +
    +

    setPoolSize

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

    isMerge

    +
    public boolean isMerge()
    +
    +
  • +
  • +
    +

    setMerge

    +
    public void setMerge(boolean merge)
    +
    +
  • diff --git a/api/com/redis/riot/cli/ReplicateCommand.html b/api/com/redis/riot/cli/ReplicateCommand.html index 4dddd3772..ecbdc3c62 100644 --- a/api/com/redis/riot/cli/ReplicateCommand.html +++ b/api/com/redis/riot/cli/ReplicateCommand.html @@ -138,12 +138,78 @@

    Method Summary

    org.springframework.batch.item.ItemReader<?> reader, org.springframework.batch.item.ItemWriter<?> writer)
     
    +
    CompareMode
    +
    getCompareMode()
    +
     
    +
    long
    +
    getFlushInterval()
    +
     
    +
    long
    +
    getIdleTimeout()
    +
     
    +
    ReplicationMode
    +
    getMode()
    +
     
    +
    int
    +
    getNotificationQueueCapacity()
    +
     
    +
    RedisReaderArgs.ReadFromEnum
    +
    getTargetReadFrom()
    +
     
    +
    RedisArgs
    +
    getTargetRedisArgs()
    +
     
    +
    long
    +
    getTtlTolerance()
    +
     
    +
    RedisWriterArgs
    +
    getWriterArgs()
    +
     
    +
    boolean
    +
    isShowDiffs()
    +
     
    +
    boolean
    +
    isType()
    +
     
    +
    void
    +
    setCompareMode(CompareMode compareMode)
    +
     
    void
    -
    setName(String name)
    +
    setFlushInterval(long flushInterval)
    +
     
    +
    void
    +
    setIdleTimeout(long timeout)
    +
     
    +
    void
    +
    setMode(ReplicationMode mode)
    +
     
    +
    void
    +
    setName(String name)
    +
     
    +
    void
    +
    setNotificationQueueCapacity(int capacity)
     
    void
    setProgressStyle(com.redis.riot.cli.AbstractRiotCommand.ProgressStyle style)
     
    +
    void
    +
    setShowDiffs(boolean showDiffs)
    +
     
    +
    void
    +
    setTargetReadFrom(RedisReaderArgs.ReadFromEnum targetReadFrom)
    +
     
    +
    void
    +
    setTargetRedisArgs(RedisArgs targetRedisArgs)
    +
     
    +
    void
    +
    setTtlTolerance(long ttlTolerance)
    +
     
    +
    void
    +
    setType(boolean type)
    +
     
    +
    void
    +
    setWriterArgs(RedisWriterArgs writerArgs)
    +
     
    protected String
    taskName(String stepName)
     
    @@ -152,7 +218,7 @@

    Method Summary

    Methods inherited from class com.redis.riot.cli.AbstractExportCommand

    -initialMaxSupplier, runnable
    +getKeyFilterArgs, getProcessorArgs, getReaderArgs, initialMaxSupplier, runnable, setKeyFilterArgs, setProcessorArgs, setReaderArgs

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    @@ -220,6 +286,138 @@

    extraMessageSupplier

  • +
    +

    setIdleTimeout

    +
    public void setIdleTimeout(long timeout)
    +
    +
  • +
  • +
    +

    setNotificationQueueCapacity

    +
    public void setNotificationQueueCapacity(int capacity)
    +
    +
  • +
  • +
    +

    getMode

    +
    public ReplicationMode getMode()
    +
    +
  • +
  • +
    +

    setMode

    +
    public void setMode(ReplicationMode mode)
    +
    +
  • +
  • +
    +

    isType

    +
    public boolean isType()
    +
    +
  • +
  • +
    +

    setType

    +
    public void setType(boolean type)
    +
    +
  • +
  • +
    +

    getTtlTolerance

    +
    public long getTtlTolerance()
    +
    +
  • +
  • +
    +

    setTtlTolerance

    +
    public void setTtlTolerance(long ttlTolerance)
    +
    +
  • +
  • +
    +

    isShowDiffs

    +
    public boolean isShowDiffs()
    +
    +
  • +
  • +
    +

    setShowDiffs

    +
    public void setShowDiffs(boolean showDiffs)
    +
    +
  • +
  • +
    +

    getCompareMode

    +
    public CompareMode getCompareMode()
    +
    +
  • +
  • +
    +

    setCompareMode

    +
    public void setCompareMode(CompareMode compareMode)
    +
    +
  • +
  • +
    +

    getTargetRedisArgs

    +
    public RedisArgs getTargetRedisArgs()
    +
    +
  • +
  • +
    +

    setTargetRedisArgs

    +
    public void setTargetRedisArgs(RedisArgs targetRedisArgs)
    +
    +
  • +
  • +
    +

    getTargetReadFrom

    +
    public RedisReaderArgs.ReadFromEnum getTargetReadFrom()
    +
    +
  • +
  • +
    +

    setTargetReadFrom

    +
    public void setTargetReadFrom(RedisReaderArgs.ReadFromEnum targetReadFrom)
    +
    +
  • +
  • +
    +

    getFlushInterval

    +
    public long getFlushInterval()
    +
    +
  • +
  • +
    +

    setFlushInterval

    +
    public void setFlushInterval(long flushInterval)
    +
    +
  • +
  • +
    +

    getWriterArgs

    +
    public RedisWriterArgs getWriterArgs()
    +
    +
  • +
  • +
    +

    setWriterArgs

    +
    public void setWriterArgs(RedisWriterArgs writerArgs)
    +
    +
  • +
  • +
    +

    getIdleTimeout

    +
    public long getIdleTimeout()
    +
    +
  • +
  • +
    +

    getNotificationQueueCapacity

    +
    public int getNotificationQueueCapacity()
    +
    +
  • +
  • setName

    public void setName(String name)
    diff --git a/api/com/redis/riot/cli/class-use/DbArgs.html b/api/com/redis/riot/cli/class-use/DbArgs.html index bfb892160..2023552d4 100644 --- a/api/com/redis/riot/cli/class-use/DbArgs.html +++ b/api/com/redis/riot/cli/class-use/DbArgs.html @@ -63,16 +63,28 @@

    Uses of Class<
  • Uses of DbArgs in com.redis.riot.cli

    -
    Subclasses of DbArgs in com.redis.riot.cli
    +
    Methods in com.redis.riot.cli that return DbArgs
    Modifier and Type
    -
    Class
    +
    Method
    Description
    -
    class 
    - + +
    DbExportCommand.getDbArgs()
     
    -
    class 
    - + +
    DbImportCommand.getDbArgs()
    +
     
    +
    +
    Methods in com.redis.riot.cli with parameters of type DbArgs
    +
    +
    Modifier and Type
    +
    Method
    +
    Description
    +
    void
    +
    DbExportCommand.setDbArgs(DbArgs dbArgs)
    +
     
    +
    void
    +
    DbImportCommand.setDbArgs(DbArgs dbArgs)
     
    diff --git a/api/com/redis/riot/cli/class-use/DbImportArgs.html b/api/com/redis/riot/cli/class-use/DbImportArgs.html deleted file mode 100644 index c3ac81b6d..000000000 --- a/api/com/redis/riot/cli/class-use/DbImportArgs.html +++ /dev/null @@ -1,58 +0,0 @@ - - - - -Uses of Class com.redis.riot.cli.DbImportArgs (riot unspecified) - - - - - - - - - - - - - - -
    - -
    -
    -
    -

    Uses of Class
    com.redis.riot.cli.DbImportArgs

    -
    -No usage of com.redis.riot.cli.DbImportArgs
    -
    -
    - - diff --git a/api/com/redis/riot/cli/class-use/FileArgs.html b/api/com/redis/riot/cli/class-use/FileArgs.html index 7aefc09a2..4404c9b55 100644 --- a/api/com/redis/riot/cli/class-use/FileArgs.html +++ b/api/com/redis/riot/cli/class-use/FileArgs.html @@ -63,20 +63,29 @@

    Uses of Clas
  • Uses of FileArgs in com.redis.riot.cli

    -
    Subclasses of FileArgs in com.redis.riot.cli
    +
    Methods in com.redis.riot.cli that return FileArgs
    Modifier and Type
    -
    Class
    +
    Method
    Description
    -
    class 
    - + +
    FileDumpExportCommand.getFileArgs()
     
    -
    class 
    - + +
    FileImportCommand.getFileArgs()
     
    -
    class 
    - +
    +
    Methods in com.redis.riot.cli with parameters of type FileArgs
    +
    +
    Modifier and Type
    +
    Method
    +
    Description
    +
    void
    +
    FileDumpExportCommand.setFileArgs(FileArgs fileArgs)
     
    +
    void
    +
    FileImportCommand.setFileArgs(FileArgs fileArgs)
    +
     
  • diff --git a/api/com/redis/riot/cli/class-use/FileDumpExportArgs.html b/api/com/redis/riot/cli/class-use/FileDumpExportArgs.html deleted file mode 100644 index 227c8b453..000000000 --- a/api/com/redis/riot/cli/class-use/FileDumpExportArgs.html +++ /dev/null @@ -1,58 +0,0 @@ - - - - -Uses of Class com.redis.riot.cli.FileDumpExportArgs (riot unspecified) - - - - - - - - - - - - - - -
    - -
    -
    -
    -

    Uses of Class
    com.redis.riot.cli.FileDumpExportArgs

    -
    -No usage of com.redis.riot.cli.FileDumpExportArgs
    -
    -
    - - diff --git a/api/com/redis/riot/cli/class-use/FileDumpImportArgs.html b/api/com/redis/riot/cli/class-use/FileDumpImportArgs.html deleted file mode 100644 index 59e9569ba..000000000 --- a/api/com/redis/riot/cli/class-use/FileDumpImportArgs.html +++ /dev/null @@ -1,58 +0,0 @@ - - - - -Uses of Class com.redis.riot.cli.FileDumpImportArgs (riot unspecified) - - - - - - - - - - - - - - -
    - -
    -
    -
    -

    Uses of Class
    com.redis.riot.cli.FileDumpImportArgs

    -
    -No usage of com.redis.riot.cli.FileDumpImportArgs
    -
    -
    - - diff --git a/api/com/redis/riot/cli/class-use/FileImportArgs.html b/api/com/redis/riot/cli/class-use/FileImportArgs.html deleted file mode 100644 index af46bb238..000000000 --- a/api/com/redis/riot/cli/class-use/FileImportArgs.html +++ /dev/null @@ -1,58 +0,0 @@ - - - - -Uses of Class com.redis.riot.cli.FileImportArgs (riot unspecified) - - - - - - - - - - - - - - -
    - -
    -
    -
    -

    Uses of Class
    com.redis.riot.cli.FileImportArgs

    -
    -No usage of com.redis.riot.cli.FileImportArgs
    -
    -
    - - diff --git a/api/com/redis/riot/cli/class-use/KeyFilterArgs.html b/api/com/redis/riot/cli/class-use/KeyFilterArgs.html index 12cda751b..4aad68437 100644 --- a/api/com/redis/riot/cli/class-use/KeyFilterArgs.html +++ b/api/com/redis/riot/cli/class-use/KeyFilterArgs.html @@ -51,7 +51,41 @@

    Uses of Class
    com.redis.riot.cli.KeyFilterArgs

    -No usage of com.redis.riot.cli.KeyFilterArgs +
    Packages that use KeyFilterArgs
    +
    +
    Package
    +
    Description
    + +
     
    +
    +
    + +
    + diff --git a/api/com/redis/riot/cli/class-use/KeyValueProcessorArgs.html b/api/com/redis/riot/cli/class-use/KeyValueProcessorArgs.html index d4db4d9f7..64ae479d7 100644 --- a/api/com/redis/riot/cli/class-use/KeyValueProcessorArgs.html +++ b/api/com/redis/riot/cli/class-use/KeyValueProcessorArgs.html @@ -51,7 +51,41 @@

    Uses of Class
    com.redis.riot.cli.KeyValueProcessorArgs

    -No usage of com.redis.riot.cli.KeyValueProcessorArgs +
    Packages that use KeyValueProcessorArgs
    +
    +
    Package
    +
    Description
    + +
     
    +
    +
    + +
    + diff --git a/api/com/redis/riot/cli/class-use/RedisArgs.html b/api/com/redis/riot/cli/class-use/RedisArgs.html index a923d445b..85d8293ed 100644 --- a/api/com/redis/riot/cli/class-use/RedisArgs.html +++ b/api/com/redis/riot/cli/class-use/RedisArgs.html @@ -51,7 +51,47 @@

    Uses of Class
    com.redis.riot.cli.RedisArgs

    -No usage of com.redis.riot.cli.RedisArgs +
    Packages that use RedisArgs
    +
    +
    Package
    +
    Description
    + +
     
    +
    +
    + +
    + diff --git a/api/com/redis/riot/cli/class-use/RedisReaderArgs.ReadFromEnum.html b/api/com/redis/riot/cli/class-use/RedisReaderArgs.ReadFromEnum.html index 0631c1a3a..92e6acbf5 100644 --- a/api/com/redis/riot/cli/class-use/RedisReaderArgs.ReadFromEnum.html +++ b/api/com/redis/riot/cli/class-use/RedisReaderArgs.ReadFromEnum.html @@ -68,6 +68,12 @@

    Uses of Modifier and Type
    Method
    Description
    +
    +
    RedisReaderArgs.getReadFrom()
    +
     
    + +
    ReplicateCommand.getTargetReadFrom()
    +
     
    RedisReaderArgs.ReadFromEnum.valueOf(String name)
    @@ -80,6 +86,18 @@

    Uses of Methods in com.redis.riot.cli with parameters of type RedisReaderArgs.ReadFromEnum

    +
    +
    Modifier and Type
    +
    Method
    +
    Description
    +
    void
    +
    RedisReaderArgs.setReadFrom(RedisReaderArgs.ReadFromEnum readFrom)
    +
     
    +
    void
    +
    ReplicateCommand.setTargetReadFrom(RedisReaderArgs.ReadFromEnum targetReadFrom)
    +
     
    +

  • diff --git a/api/com/redis/riot/cli/class-use/RedisReaderArgs.html b/api/com/redis/riot/cli/class-use/RedisReaderArgs.html index 8ac86d07b..9ea7a730d 100644 --- a/api/com/redis/riot/cli/class-use/RedisReaderArgs.html +++ b/api/com/redis/riot/cli/class-use/RedisReaderArgs.html @@ -51,7 +51,41 @@

    Uses of Class
    com.redis.riot.cli.RedisReaderArgs

    -No usage of com.redis.riot.cli.RedisReaderArgs +
    Packages that use RedisReaderArgs
    +
    +
    Package
    +
    Description
    + +
     
    +
    +
    + +
    + diff --git a/api/com/redis/riot/cli/class-use/RedisWriterArgs.html b/api/com/redis/riot/cli/class-use/RedisWriterArgs.html index 86354bfa3..191cbe29d 100644 --- a/api/com/redis/riot/cli/class-use/RedisWriterArgs.html +++ b/api/com/redis/riot/cli/class-use/RedisWriterArgs.html @@ -51,7 +51,41 @@

    Uses of Class
    com.redis.riot.cli.RedisWriterArgs

    -No usage of com.redis.riot.cli.RedisWriterArgs +
    Packages that use RedisWriterArgs
    +
    +
    Package
    +
    Description
    + +
     
    +
    +
    + +
    + diff --git a/api/com/redis/riot/cli/package-summary.html b/api/com/redis/riot/cli/package-summary.html index 2c246c0e6..15c981546 100644 --- a/api/com/redis/riot/cli/package-summary.html +++ b/api/com/redis/riot/cli/package-summary.html @@ -102,11 +102,7 @@

    Package com.redis.riot.cli<
     
     
    - -
     
    - -
     
    - +
     
     
    @@ -116,52 +112,46 @@

    Package com.redis.riot.cli<
     
     
    - -
     
    - -
     
    - +
     
     
    - +
     
    - +
     
    - +
     
    - +
     
    - +
     
    - +
     
    - +
     
    - +
     
    - -
     
    - - diff --git a/api/com/redis/riot/cli/package-tree.html b/api/com/redis/riot/cli/package-tree.html index e0c7e9b8e..ff20cdd85 100644 --- a/api/com/redis/riot/cli/package-tree.html +++ b/api/com/redis/riot/cli/package-tree.html @@ -91,20 +91,9 @@

    Class Hierarchy

  • com.redis.riot.cli.CompositeExecutionStrategy (implements picocli.CommandLine.IExecutionStrategy)
  • -
  • com.redis.riot.cli.DbArgs - -
  • +
  • com.redis.riot.cli.DbArgs
  • com.redis.riot.cli.EvaluationContextArgs
  • -
  • com.redis.riot.cli.FileArgs - -
  • +
  • com.redis.riot.cli.FileArgs
  • org.springframework.batch.core.listener.ItemListenerSupport<I,O> (implements org.springframework.batch.core.ItemProcessListener<T,S>, org.springframework.batch.core.ItemReadListener<T>, org.springframework.batch.core.ItemWriteListener<S>) diff --git a/api/com/redis/riot/core/AbstractImport.html b/api/com/redis/riot/core/AbstractImport.html index 958a58ce0..7540d74e6 100644 --- a/api/com/redis/riot/core/AbstractImport.html +++ b/api/com/redis/riot/core/AbstractImport.html @@ -73,20 +73,24 @@

    Class AbstractImport

    java.lang.Object -
    com.redis.riot.core.AbstractExecutable -
    +
    All Implemented Interfaces:
    +
    AutoCloseable, Callable<org.springframework.batch.core.JobExecution>, org.springframework.beans.factory.InitializingBean
    +
    +
    Direct Known Subclasses:
    -
    DatabaseImport, FakerImport, FileImport
    +
    AbstractMapImport, FileDumpImport, GeneratorImport

    public abstract class AbstractImport -extends AbstractRedisRunnable
    +extends AbstractRedisCallable
    +
  • @@ -123,51 +130,26 @@

    Method Summary

    Modifier and Type
    Method
    Description
    -
    protected org.springframework.expression.spel.support.StandardEvaluationContext
    -
    evaluationContext()
    -
     
    -
    EvaluationContextOptions
    -
    getEvaluationContextOptions()
    -
     
    -
    List<com.redis.spring.batch.operation.Operation<String,String,Map<String,Object>,Object>>
    -
    getOperations()
    -
     
    -
    ImportProcessorOptions
    -
    getProcessorOptions()
    -
     
    -
    RedisWriterOptions
    -
    getWriterOptions()
    -
     
    -
    protected org.springframework.batch.item.ItemProcessor<Map<String,Object>,Map<String,Object>>
    -
    processor()
    -
     
    -
    void
    -
    setEvaluationContextOptions(EvaluationContextOptions evaluationContextOptions)
    -
     
    -
    void
    -
    setOperations(com.redis.spring.batch.operation.Operation<String,String,Map<String,Object>,Object>... operations)
    -
     
    -
    void
    -
    setOperations(List<com.redis.spring.batch.operation.Operation<String,String,Map<String,Object>,Object>> operations)
    +
    protected <K, +V, +T> void
    +
    configure(com.redis.spring.batch.RedisItemWriter<K,V,T> writer)
     
    -
    void
    -
    setProcessorOptions(ImportProcessorOptions options)
    +
    RedisWriterOptions
    +
    getWriterOptions()
     
    void
    setWriterOptions(RedisWriterOptions options)
     
    -
    protected org.springframework.batch.item.ItemWriter<Map<String,Object>>
    -
    writer()
    -
     
    -

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

    -execute, getRedisClient, getRedisClientOptions, getRedisURI, setRedisClientOptions
    +

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

    +afterPropertiesSet, close, configure, evaluationContext, expressionFunction, getEvaluationContext, getRedisClientOptions, longExpressionFunction, setEvaluationContextOptions, setRedisClientOptions
    -

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

    -addStepConfiguration, faultTolerant, getChunkSize, getJobFactory, getName, getRetryLimit, getSkipLimit, getSleep, getThreads, isDryRun, job, jobBuilder, name, setChunkSize, setDryRun, setJobFactory, setName, setRetryLimit, setSkipLimit, setSleep, setThreads, step, writer
    +

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

    +addStepConfiguration, call, faultTolerant, getChunkSize, getJobFactory, getName, getRetryLimit, getSkipLimit, getSleep, getThreads, isDryRun, job, jobBuilder, name, setChunkSize, setDryRun, setJobFactory, setName, setRetryLimit, setSkipLimit, setSleep, setThreads, step

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    @@ -197,36 +179,6 @@

    AbstractImport

    Method Details

    diff --git a/api/com/redis/riot/core/AbstractMapExport.html b/api/com/redis/riot/core/AbstractMapExport.html index 886fff5fc..5852079b1 100644 --- a/api/com/redis/riot/core/AbstractMapExport.html +++ b/api/com/redis/riot/core/AbstractMapExport.html @@ -73,8 +73,8 @@

    Class AbstractMapExport

    java.lang.Object -
    com.redis.riot.core.AbstractExecutable -
    com.redis.riot.core.AbstractRedisRunnable +
    com.redis.riot.core.AbstractRiotCallable +
    com.redis.riot.core.AbstractRedisCallable
    com.redis.riot.core.AbstractExport
    com.redis.riot.core.AbstractMapExport
    @@ -83,6 +83,10 @@

    Class AbstractMapExport

    +
    All Implemented Interfaces:
    +
    AutoCloseable, Callable<org.springframework.batch.core.JobExecution>, org.springframework.beans.factory.InitializingBean
    +
    +
    Direct Known Subclasses:
    DatabaseExport
    @@ -106,8 +110,11 @@

    Field Summary

     
    +

    Fields inherited from class com.redis.riot.core.AbstractRedisCallable

    +redisCommands, redisURI
    + @@ -157,13 +164,13 @@

    Method Summary

    +configure, getKeyFilterOptions, getProcessorOptions, getReaderOptions, keyFilterPredicate, processor, setKeyFilterOptions, setProcessorOptions, setReaderOptions
    -

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

    -execute, getRedisClient, getRedisClientOptions, getRedisURI, setRedisClientOptions
    +

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

    +afterPropertiesSet, close, configure, evaluationContext, expressionFunction, getEvaluationContext, getRedisClientOptions, longExpressionFunction, setEvaluationContextOptions, setRedisClientOptions
    -

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

    -addStepConfiguration, faultTolerant, getChunkSize, getJobFactory, getName, getRetryLimit, getSkipLimit, getSleep, getThreads, isDryRun, jobBuilder, name, setChunkSize, setDryRun, setJobFactory, setName, setRetryLimit, setSkipLimit, setSleep, setThreads, step, writer
    +

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

    +addStepConfiguration, call, faultTolerant, getChunkSize, getJobFactory, getName, getRetryLimit, getSkipLimit, getSleep, getThreads, isDryRun, jobBuilder, name, setChunkSize, setDryRun, setJobFactory, setName, setRetryLimit, setSkipLimit, setSleep, setThreads, step

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    @@ -218,7 +225,7 @@

    job

    protected org.springframework.batch.core.Job job()
    Specified by:
    -
    job in class AbstractExecutable
    +
    job in class AbstractRiotCallable
    diff --git a/api/com/redis/riot/core/AbstractMapImport.html b/api/com/redis/riot/core/AbstractMapImport.html new file mode 100644 index 000000000..83445aa01 --- /dev/null +++ b/api/com/redis/riot/core/AbstractMapImport.html @@ -0,0 +1,283 @@ + + + + +AbstractMapImport (riot unspecified) + + + + + + + + + + + + + + +
    + +
    +
    + +
    + +

    Class AbstractMapImport

    +
    + +
    +
    +
    All Implemented Interfaces:
    +
    AutoCloseable, Callable<org.springframework.batch.core.JobExecution>, org.springframework.beans.factory.InitializingBean
    +
    +
    +
    Direct Known Subclasses:
    +
    DatabaseImport, FakerImport, FileImport
    +
    +
    +
    public abstract class AbstractMapImport +extends AbstractImport
    +
    +
    + +
    +
    + +
    + +
    +
    +
    + + diff --git a/api/com/redis/riot/core/AbstractRedisCallable.html b/api/com/redis/riot/core/AbstractRedisCallable.html new file mode 100644 index 000000000..e09810099 --- /dev/null +++ b/api/com/redis/riot/core/AbstractRedisCallable.html @@ -0,0 +1,320 @@ + + + + +AbstractRedisCallable (riot unspecified) + + + + + + + + + + + + + + +
    + +
    +
    + +
    + +

    Class AbstractRedisCallable

    +
    +
    java.lang.Object +
    com.redis.riot.core.AbstractRiotCallable +
    com.redis.riot.core.AbstractRedisCallable
    +
    +
    +
    +
    +
    All Implemented Interfaces:
    +
    AutoCloseable, Callable<org.springframework.batch.core.JobExecution>, org.springframework.beans.factory.InitializingBean
    +
    +
    +
    Direct Known Subclasses:
    +
    AbstractExport, AbstractImport, Ping
    +
    +
    +
    public abstract class AbstractRedisCallable +extends AbstractRiotCallable
    +
    +
    + +
    +
    +
      + +
    • +
      +

      Field Details

      +
        +
      • +
        +

        redisURI

        +
        protected io.lettuce.core.RedisURI redisURI
        +
        +
      • +
      • +
        +

        redisCommands

        +
        protected com.redis.lettucemod.api.sync.RedisModulesCommands<String,String> redisCommands
        +
        +
      • +
      +
      +
    • + +
    • +
      +

      Constructor Details

      +
        +
      • +
        +

        AbstractRedisCallable

        +
        public AbstractRedisCallable()
        +
        +
      • +
      +
      +
    • + +
    • +
      +

      Method Details

      +
        +
      • +
        +

        afterPropertiesSet

        +
        public void afterPropertiesSet() + throws Exception
        +
        +
        Specified by:
        +
        afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean
        +
        Overrides:
        +
        afterPropertiesSet in class AbstractRiotCallable
        +
        Throws:
        +
        Exception
        +
        +
        +
      • +
      • +
        +

        evaluationContext

        +
        protected org.springframework.expression.spel.support.StandardEvaluationContext evaluationContext()
        +
        +
      • +
      • +
        +

        close

        +
        public void close()
        +
        +
      • +
      • +
        +

        getRedisClientOptions

        +
        public RedisClientOptions getRedisClientOptions()
        +
        +
      • +
      • +
        +

        setRedisClientOptions

        +
        public void setRedisClientOptions(RedisClientOptions options)
        +
        +
      • +
      • +
        +

        getEvaluationContext

        +
        public org.springframework.expression.spel.support.StandardEvaluationContext getEvaluationContext()
        +
        +
      • +
      • +
        +

        setEvaluationContextOptions

        +
        public void setEvaluationContextOptions(EvaluationContextOptions spelProcessorOptions)
        +
        +
      • +
      • +
        +

        configure

        +
        protected <K, +V, +T> void configure(com.redis.spring.batch.RedisItemReader<K,V,T> reader)
        +
        +
      • +
      • +
        +

        configure

        +
        protected <K, +V, +T> void configure(com.redis.spring.batch.RedisItemWriter<K,V,T> writer)
        +
        +
      • +
      • +
        +

        expressionFunction

        +
        protected <T> ExpressionFunction<T,String> expressionFunction(org.springframework.expression.Expression expression)
        +
        +
      • +
      • +
        +

        longExpressionFunction

        +
        protected <T> LongExpressionFunction<T> longExpressionFunction(org.springframework.expression.Expression expression)
        +
        +
      • +
      +
      +
    • +
    +
    + +
    +
    +
    + + diff --git a/api/com/redis/riot/core/AbstractRedisRunnable.html b/api/com/redis/riot/core/AbstractRedisRunnable.html deleted file mode 100644 index de16c7dc8..000000000 --- a/api/com/redis/riot/core/AbstractRedisRunnable.html +++ /dev/null @@ -1,220 +0,0 @@ - - - - -AbstractRedisRunnable (riot unspecified) - - - - - - - - - - - - - - -
    - -
    -
    - -
    - -

    Class AbstractRedisRunnable

    -
    -
    java.lang.Object -
    com.redis.riot.core.AbstractExecutable -
    com.redis.riot.core.AbstractRedisRunnable
    -
    -
    -
    -
    -
    Direct Known Subclasses:
    -
    AbstractExport, AbstractImport, AbstractStructImport, Ping
    -
    -
    -
    public abstract class AbstractRedisRunnable -extends AbstractExecutable
    -
    -
    - -
    -
    -
      - -
    • -
      -

      Constructor Details

      -
        -
      • -
        -

        AbstractRedisRunnable

        -
        public AbstractRedisRunnable()
        -
        -
      • -
      -
      -
    • - -
    • -
      -

      Method Details

      -
        -
      • -
        -

        execute

        -
        public void execute() - throws Exception
        -
        -
        Overrides:
        -
        execute in class AbstractExecutable
        -
        Throws:
        -
        Exception
        -
        -
        -
      • -
      • -
        -

        getRedisClientOptions

        -
        public RedisClientOptions getRedisClientOptions()
        -
        -
      • -
      • -
        -

        setRedisClientOptions

        -
        public void setRedisClientOptions(RedisClientOptions options)
        -
        -
      • -
      • -
        -

        getRedisURI

        -
        protected io.lettuce.core.RedisURI getRedisURI()
        -
        -
      • -
      • -
        -

        getRedisClient

        -
        protected io.lettuce.core.AbstractRedisClient getRedisClient()
        -
        -
      • -
      -
      -
    • -
    -
    - -
    -
    -
    - - diff --git a/api/com/redis/riot/core/AbstractExecutable.html b/api/com/redis/riot/core/AbstractRiotCallable.html similarity index 77% rename from api/com/redis/riot/core/AbstractExecutable.html rename to api/com/redis/riot/core/AbstractRiotCallable.html index 3a55e39f9..c52edf3c6 100644 --- a/api/com/redis/riot/core/AbstractExecutable.html +++ b/api/com/redis/riot/core/AbstractRiotCallable.html @@ -2,10 +2,10 @@ -AbstractExecutable (riot unspecified) +AbstractRiotCallable (riot unspecified) - + @@ -35,7 +35,7 @@
  • Overview
  • Package
  • -
  • Use
  • +
  • Use
  • Tree
  • Index
  • Help
  • @@ -70,19 +70,24 @@
    -

    Class AbstractExecutable

    +

    Class AbstractRiotCallable

    java.lang.Object -
    com.redis.riot.core.AbstractExecutable
    +
    com.redis.riot.core.AbstractRiotCallable
    +
    All Implemented Interfaces:
    +
    AutoCloseable, Callable<org.springframework.batch.core.JobExecution>, org.springframework.beans.factory.InitializingBean
    +
    +
    Direct Known Subclasses:
    -
    AbstractRedisRunnable
    +
    AbstractRedisCallable

    -
    public abstract class AbstractExecutable -extends Object
    +
    public abstract class AbstractRiotCallable +extends Object +implements org.springframework.beans.factory.InitializingBean, Callable<org.springframework.batch.core.JobExecution>, AutoCloseable
    @@ -146,78 +151,77 @@

    Method Summary

    addStepConfiguration(StepConfiguration configuration)
     
    void
    -
    execute()
    +
    afterPropertiesSet()
     
    -
    protected <I, -O> org.springframework.batch.core.step.builder.FaultTolerantStepBuilder<I,O>
    -
    faultTolerant(org.springframework.batch.core.step.builder.SimpleStepBuilder<I,O> step)
    +
    org.springframework.batch.core.JobExecution
    +
    call()
     
    -
    int
    -
    getChunkSize()
    -
     
    -
    com.redis.spring.batch.common.JobFactory
    -
    getJobFactory()
    -
     
    -
    String
    -
    getName()
    +
    protected <I, +O> org.springframework.batch.core.step.builder.FaultTolerantStepBuilder<I,O>
    +
    faultTolerant(org.springframework.batch.core.step.builder.SimpleStepBuilder<I,O> step)
     
    int
    -
    getRetryLimit()
    +
    getChunkSize()
     
    -
    int
    -
    getSkipLimit()
    +
    com.redis.spring.batch.common.JobFactory
    +
    getJobFactory()
     
    -
    Duration
    -
    getSleep()
    +
    String
    +
    getName()
     
    int
    -
    getThreads()
    +
    getRetryLimit()
     
    -
    boolean
    -
    isDryRun()
    +
    int
    +
    getSkipLimit()
     
    -
    protected abstract org.springframework.batch.core.Job
    -
    job()
    -
     
    -
    protected org.springframework.batch.core.job.builder.JobBuilder
    -
    jobBuilder()
    +
    Duration
    +
    getSleep()
    +
     
    +
    int
    +
    getThreads()
     
    -
    protected String
    -
    name(String... suffixes)
    +
    boolean
    +
    isDryRun()
     
    -
    void
    -
    setChunkSize(int chunkSize)
    +
    protected abstract org.springframework.batch.core.Job
    +
    job()
    +
     
    +
    protected org.springframework.batch.core.job.builder.JobBuilder
    +
    jobBuilder()
    +
     
    +
    protected String
    +
    name(String... suffixes)
     
    void
    -
    setDryRun(boolean dryRun)
    +
    setChunkSize(int chunkSize)
     
    void
    -
    setJobFactory(com.redis.spring.batch.common.JobFactory jobFactory)
    +
    setDryRun(boolean dryRun)
     
    void
    -
    setName(String name)
    +
    setJobFactory(com.redis.spring.batch.common.JobFactory jobFactory)
     
    void
    -
    setRetryLimit(int retryLimit)
    +
    setName(String name)
     
    void
    -
    setSkipLimit(int skipLimit)
    +
    setRetryLimit(int retryLimit)
     
    void
    -
    setSleep(Duration sleep)
    +
    setSkipLimit(int skipLimit)
     
    void
    -
    setThreads(int threads)
    +
    setSleep(Duration sleep)
     
    -
    protected <I, +
    void
    +
    setThreads(int threads)
    +
     
    +
    protected <I, O> org.springframework.batch.core.step.builder.FaultTolerantStepBuilder<I,O>
    -
    step(String name, +
    step(String name, org.springframework.batch.item.ItemReader<I> reader, org.springframework.batch.item.ItemWriter<O> writer)
    -
     
    -
    protected void
    -
    writer(com.redis.spring.batch.RedisItemWriter<?,?,?> writer, - RedisWriterOptions options)
     
    @@ -225,6 +229,9 @@

    Method Summary

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    +
    +

    Methods inherited from interface java.lang.AutoCloseable

    +close
    @@ -250,7 +257,7 @@

    DEFAULT_SKIP_LIMIT

    See Also:
    @@ -264,7 +271,7 @@

    DEFAULT_RETRY_LIMIT

    See Also:
    @@ -284,7 +291,7 @@

    DEFAULT_CHUNK_SIZE

    See Also:
    @@ -298,7 +305,7 @@

    DEFAULT_THREADS

    See Also:
    @@ -314,8 +321,8 @@

    Constructor Details

    • -

      AbstractExecutable

      -
      protected AbstractExecutable()
      +

      AbstractRiotCallable

      +
      protected AbstractRiotCallable()
    @@ -351,11 +358,26 @@

    setJobFactory

  • -
    -

    execute

    -
    public void execute() - throws Exception
    +
    +

    afterPropertiesSet

    +
    public void afterPropertiesSet() + throws Exception
    +
    Specified by:
    +
    afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean
    +
    Throws:
    +
    Exception
    +
    +
    +
  • +
  • +
    +

    call

    +
    public org.springframework.batch.core.JobExecution call() + throws Exception
    +
    +
    Specified by:
    +
    call in interface Callable<org.springframework.batch.core.JobExecution>
    Throws:
    Exception
    @@ -374,13 +396,6 @@

    job

  • -
    -

    writer

    -
    protected void writer(com.redis.spring.batch.RedisItemWriter<?,?,?> writer, - RedisWriterOptions options)
    -
    -
  • -
  • step

    protected <I, diff --git a/api/com/redis/riot/core/AbstractStructImport.html b/api/com/redis/riot/core/AbstractStructImport.html deleted file mode 100644 index 628983fbe..000000000 --- a/api/com/redis/riot/core/AbstractStructImport.html +++ /dev/null @@ -1,191 +0,0 @@ - - - - -AbstractStructImport (riot unspecified) - - - - - - - - - - - - - - -
    - -
    -
    - -
    - -

    Class AbstractStructImport

    -
    - -
    -
    -
    Direct Known Subclasses:
    -
    FileDumpImport, GeneratorImport
    -
    -
    -
    public abstract class AbstractStructImport -extends AbstractRedisRunnable
    -
    -
    - -
    -
    -
      - -
    • -
      -

      Constructor Details

      -
        -
      • -
        -

        AbstractStructImport

        -
        public AbstractStructImport()
        -
        -
      • -
      -
      -
    • - -
    • -
      -

      Method Details

      -
        -
      • -
        -

        setWriterOptions

        -
        public void setWriterOptions(RedisWriterOptions options)
        -
        -
      • -
      • -
        -

        writer

        -
        protected com.redis.spring.batch.RedisItemWriter<String,String,com.redis.spring.batch.KeyValue<String,Object>> writer()
        -
        -
      • -
      -
      -
    • -
    -
    - -
    -
    -
    - - diff --git a/api/com/redis/riot/core/KeyFilterOptions.html b/api/com/redis/riot/core/KeyFilterOptions.html index e201dfc6e..f8d838210 100644 --- a/api/com/redis/riot/core/KeyFilterOptions.html +++ b/api/com/redis/riot/core/KeyFilterOptions.html @@ -115,15 +115,18 @@

    Method Summary

     
    -
    void
    -
    setExcludes(List<String> patterns)
    +
    boolean
    +
     
    void
    -
    setIncludes(List<String> patterns)
    +
    setExcludes(List<String> patterns)
     
    void
    - +
    setIncludes(List<String> patterns)
     
    +
    void
    + +
     
    @@ -191,6 +194,12 @@

    setSlots

    public void setSlots(List<SlotRange> ranges)
  • +
  • +
    +

    isEmpty

    +
    public boolean isEmpty()
    +
    +
  • diff --git a/api/com/redis/riot/core/RedisReaderOptions.html b/api/com/redis/riot/core/RedisReaderOptions.html index 152bfa585..c411ee195 100644 --- a/api/com/redis/riot/core/RedisReaderOptions.html +++ b/api/com/redis/riot/core/RedisReaderOptions.html @@ -94,36 +94,27 @@

    Field Summary

    static final int
     
    -
    static final Duration
    - -
     
    -
    static final Duration
    - -
     
    static final org.springframework.util.unit.DataSize
     
    static final int
     
    -
    static final int
    - +
    static final Duration
    +
     
    -
    static final Duration
    - +
    static final int
    +
     
    static final int
    - +
     
    -
    static final int
    - +
    static final long
    +
     
    -
    static final long
    - +
    static final int
    +
     
    -
    static final int
    - -
     
    @@ -151,22 +142,16 @@

    Method Summary

    Modifier and Type
    Method
    Description
    -
    int
    - -
     
    - - -
     
    - - +
    void
    +
    configure(com.redis.spring.batch.RedisItemReader<?,?,?> reader)
     
    - - +
    int
    +
     
     
    -
    com.redis.spring.batch.KeyValue.Type
    +
     
    org.springframework.util.unit.DataSize
    @@ -175,44 +160,32 @@

    Method Summary

    int
     
    -
    int
    - -
     
    - - -
     
    -
    int
    - + +
     
    int
    - -
     
    -
    io.lettuce.core.ReadFrom
    - -
     
    -
    long
    - +
     
    int
    - +
     
    -
    void
    -
    setChunkSize(int chunkSize)
    +
    io.lettuce.core.ReadFrom
    +
     
    -
    void
    - +
    long
    +
     
    -
    void
    - +
    int
    +
     
    void
    - +
    setChunkSize(int chunkSize)
     
    void
     
    void
    -
    setKeyType(com.redis.spring.batch.KeyValue.Type type)
    +
     
    void
    setMemoryUsageLimit(org.springframework.util.unit.DataSize memoryUsageLimit)
    @@ -221,26 +194,23 @@

    Method Summary

    setMemoryUsageSamples(int memoryUsageSamples)
     
    void
    - +
    setPollTimeout(Duration pollTimeout)
     
    void
    -
    setPollTimeout(Duration pollTimeout)
    +
    setPoolSize(int poolSize)
     
    void
    -
    setPoolSize(int poolSize)
    +
    setQueueCapacity(int capacity)
     
    void
    -
    setQueueCapacity(int capacity)
    +
    setReadFrom(io.lettuce.core.ReadFrom readFrom)
     
    void
    -
    setReadFrom(io.lettuce.core.ReadFrom readFrom)
    +
    setScanCount(long count)
     
    void
    -
    setScanCount(long count)
    +
    setThreads(int threads)
     
    -
    void
    -
    setThreads(int threads)
    -
     
    @@ -341,20 +311,6 @@

    DEFAULT_MEMORY_USAGE_SAMPLES

  • -
    -

    DEFAULT_NOTIFICATION_QUEUE_CAPACITY

    -
    public static final int DEFAULT_NOTIFICATION_QUEUE_CAPACITY
    -
    -
    See Also:
    -
    - -
    -
    -
    -
  • -
  • DEFAULT_SCAN_COUNT

    public static final long DEFAULT_SCAN_COUNT
    @@ -368,18 +324,6 @@

    DEFAULT_SCAN_COUNT

  • -
  • -
    -

    DEFAULT_FLUSH_INTERVAL

    -
    public static final Duration DEFAULT_FLUSH_INTERVAL
    -
    -
  • -
  • -
    -

    DEFAULT_IDLE_TIMEOUT

    -
    public static final Duration DEFAULT_IDLE_TIMEOUT
    -
    -
  • @@ -403,54 +347,6 @@

    RedisReaderOptions

    Method Details

    • -
      -

      getKeyFilterOptions

      -
      public KeyFilterOptions getKeyFilterOptions()
      -
      -
    • -
    • -
      -

      setKeyFilterOptions

      -
      public void setKeyFilterOptions(KeyFilterOptions options)
      -
      -
    • -
    • -
      -

      getFlushInterval

      -
      public Duration getFlushInterval()
      -
      -
    • -
    • -
      -

      setFlushInterval

      -
      public void setFlushInterval(Duration interval)
      -
      -
    • -
    • -
      -

      getIdleTimeout

      -
      public Duration getIdleTimeout()
      -
      -
    • -
    • -
      -

      setIdleTimeout

      -
      public void setIdleTimeout(Duration timeout)
      -
      -
    • -
    • -
      -

      getNotificationQueueCapacity

      -
      public int getNotificationQueueCapacity()
      -
      -
    • -
    • -
      -

      setNotificationQueueCapacity

      -
      public void setNotificationQueueCapacity(int capacity)
      -
      -
    • -
    • getKeyPattern

      public String getKeyPattern()
      @@ -477,13 +373,13 @@

      setScanCount

    • getKeyType

      -
      public com.redis.spring.batch.KeyValue.Type getKeyType()
      +
      public String getKeyType()
    • -
      +

      setKeyType

      -
      public void setKeyType(com.redis.spring.batch.KeyValue.Type type)
      +
      public void setKeyType(String type)
    • @@ -582,6 +478,12 @@

      setMemoryUsageSamples

      public void setMemoryUsageSamples(int memoryUsageSamples)
    • +
    • +
      +

      configure

      +
      public void configure(com.redis.spring.batch.RedisItemReader<?,?,?> reader)
      +
      +
    diff --git a/api/com/redis/riot/core/RedisWriterOptions.html b/api/com/redis/riot/core/RedisWriterOptions.html index 8a3405293..7958a887e 100644 --- a/api/com/redis/riot/core/RedisWriterOptions.html +++ b/api/com/redis/riot/core/RedisWriterOptions.html @@ -124,36 +124,39 @@

    Method Summary

    Modifier and Type
    Method
    Description
    -
    int
    - +
    void
    +
    configure(com.redis.spring.batch.RedisItemWriter<?,?,?> writer)
     
    int
    - +
     
    - - +
    int
    +
     
    -
    boolean
    - + +
     
    boolean
    - +
     
    -
    void
    -
    setMerge(boolean merge)
    +
    boolean
    +
     
    void
    -
    setMultiExec(boolean enable)
    +
    setMerge(boolean merge)
     
    void
    -
    setPoolSize(int size)
    +
    setMultiExec(boolean enable)
     
    void
    -
    setWaitReplicas(int replicas)
    +
    setPoolSize(int size)
     
    void
    - +
    setWaitReplicas(int replicas)
     
    +
    void
    + +
     
    @@ -273,6 +276,12 @@

    setWaitTimeout

    public void setWaitTimeout(Duration timeout)
    +
  • +
    +

    configure

    +
    public void configure(com.redis.spring.batch.RedisItemWriter<?,?,?> writer)
    +
    +
  • diff --git a/api/com/redis/riot/core/RiotUtils.html b/api/com/redis/riot/core/RiotUtils.html index fcbff39df..12e292eb9 100644 --- a/api/com/redis/riot/core/RiotUtils.html +++ b/api/com/redis/riot/core/RiotUtils.html @@ -94,25 +94,11 @@

    Method Summary

    Method
    Description
    - -
     
    -
    static <K> Predicate<K>
    -
    globPredicate(io.lettuce.core.codec.RedisCodec<K,?> codec, - KeyFilterOptions options)
    -
     
    -
     
    static boolean
    isPositive(Duration duration)
     
    - - -
     
    -
    static <K> Predicate<K>
    -
    keyFilterPredicate(io.lettuce.core.codec.RedisCodec<K,?> codec, - KeyFilterOptions options)
    -
     
    static org.springframework.expression.Expression
    parse(String expressionString)
     
    @@ -131,16 +117,12 @@

    Method Summary

    T> org.springframework.batch.item.ItemProcessor<S,T>
    processor(org.springframework.batch.item.ItemProcessor<?,?>... processors)
     
    -
    static <K> Predicate<K>
    -
    slotsPredicate(io.lettuce.core.codec.RedisCodec<K,?> codec, - KeyFilterOptions options)
    +
    static <T> org.springframework.batch.item.ItemWriter<T>
    +
    writer(Collection<? extends org.springframework.batch.item.ItemWriter<T>> writers)
     
    static <T> org.springframework.batch.item.ItemWriter<T>
    -
    writer(Collection<? extends org.springframework.batch.item.ItemWriter<T>> writers)
    +
    writer(org.springframework.batch.item.ItemWriter<T>... writers)
     
    -
    static <T> org.springframework.batch.item.ItemWriter<T>
    -
    writer(org.springframework.batch.item.ItemWriter<T>... writers)
    -
     
    @@ -178,39 +160,6 @@

    predicate

  • -
    -

    keyFilterPredicate

    -
    public static Predicate<String> keyFilterPredicate(KeyFilterOptions options)
    -
    -
  • -
  • -
    -

    keyFilterPredicate

    -
    public static <K> Predicate<K> keyFilterPredicate(io.lettuce.core.codec.RedisCodec<K,?> codec, - KeyFilterOptions options)
    -
    -
  • -
  • -
    -

    slotsPredicate

    -
    public static <K> Predicate<K> slotsPredicate(io.lettuce.core.codec.RedisCodec<K,?> codec, - KeyFilterOptions options)
    -
    -
  • -
  • -
    -

    globPredicate

    -
    public static <K> Predicate<K> globPredicate(io.lettuce.core.codec.RedisCodec<K,?> codec, - KeyFilterOptions options)
    -
    -
  • -
  • -
    -

    globPredicate

    -
    public static Predicate<String> globPredicate(KeyFilterOptions options)
    -
    -
  • -
  • globPredicate

    public static Predicate<String> globPredicate(List<String> patterns)
    diff --git a/api/com/redis/riot/core/class-use/AbstractImport.html b/api/com/redis/riot/core/class-use/AbstractImport.html index 512b90370..c8f963ac1 100644 --- a/api/com/redis/riot/core/class-use/AbstractImport.html +++ b/api/com/redis/riot/core/class-use/AbstractImport.html @@ -57,11 +57,15 @@

    Uses
    Description
     
    - +
     
    - +
     
    - + +
     
    + +
     
    +
     
    @@ -75,17 +79,25 @@

    Uses of Method
    Description
    -
    AbstractImportCommand.importRunnable()
    +
    AbstractStructImportCommand.importRunnable()
     
    protected AbstractImport
    -
    DbImportCommand.importRunnable()
    +
    AbstractStructImportCommand.runnable()
     
    -
    protected AbstractImport
    -
    FileImportCommand.importRunnable()
    + +

    +

  • +
  • +
    +

    Uses of AbstractImport in com.redis.riot.core

    + +
    +
    Modifier and Type
    +
    Class
    +
    Description
    +
    class 
    +
     
    -
    protected AbstractImport
    -
    AbstractImportCommand.runnable()
    -
     
  • @@ -126,7 +138,24 @@

    Uses of Class
    Description
    class 
    -
    + +
     
    +
    class 
    + +
     
    + + + +
  • +
    +

    Uses of AbstractImport in com.redis.riot.redis

    + +
    +
    Modifier and Type
    +
    Class
    +
    Description
    +
    class 
    +
     
    diff --git a/api/com/redis/riot/core/class-use/AbstractStructImport.html b/api/com/redis/riot/core/class-use/AbstractMapImport.html similarity index 50% rename from api/com/redis/riot/core/class-use/AbstractStructImport.html rename to api/com/redis/riot/core/class-use/AbstractMapImport.html index 94a58f78e..417a64a1a 100644 --- a/api/com/redis/riot/core/class-use/AbstractStructImport.html +++ b/api/com/redis/riot/core/class-use/AbstractMapImport.html @@ -2,10 +2,10 @@ -Uses of Class com.redis.riot.core.AbstractStructImport (riot unspecified) +Uses of Class com.redis.riot.core.AbstractMapImport (riot unspecified) - + @@ -30,7 +30,7 @@