Package org.apache.ignite.dump
Class DumpReaderConfiguration
- java.lang.Object
-
- org.apache.ignite.dump.DumpReaderConfiguration
-
public class DumpReaderConfiguration extends Object
Configuration class ofDumpReader.- See Also:
DumpReader,DumpConsumer
-
-
Field Summary
Fields Modifier and Type Field Description static intDFLT_THREAD_CNTDefault thread count.static DurationDFLT_TIMEOUTDefault timeout.
-
Constructor Summary
Constructors Constructor Description DumpReaderConfiguration(File dir, DumpConsumer cnsmr)DumpReaderConfiguration(File dir, DumpConsumer cnsmr, int thCnt, Duration timeout, boolean failFast, boolean keepBinary, boolean keepRaw, String[] cacheGrpNames, boolean skipCopies, EncryptionSpi encSpi)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description String[]cacheGroupNames()DumpConsumerconsumer()FiledumpRoot()EncryptionSpiencryptionSpi()booleanfailFast()booleankeepBinary()Actual only ifkeepRawisfalse.booleankeepRaw()booleanskipCopies()intthreadCount()Durationtimeout()
-
-
-
Field Detail
-
DFLT_TIMEOUT
public static final Duration DFLT_TIMEOUT
Default timeout.
-
DFLT_THREAD_CNT
public static final int DFLT_THREAD_CNT
Default thread count.- See Also:
- Constant Field Values
-
-
Constructor Detail
-
DumpReaderConfiguration
public DumpReaderConfiguration(File dir, DumpConsumer cnsmr)
- Parameters:
dir- Root dump directory.cnsmr- Dump consumer.
-
DumpReaderConfiguration
public DumpReaderConfiguration(File dir, DumpConsumer cnsmr, int thCnt, Duration timeout, boolean failFast, boolean keepBinary, boolean keepRaw, String[] cacheGrpNames, boolean skipCopies, EncryptionSpi encSpi)
- Parameters:
dir- Root dump directory.cnsmr- Dump consumer.thCnt- Count of threads to consume dumped partitions.timeout- Timeout of dump reader invocation.failFast- Stop processing partitions if consumer fail to process one.keepBinary- Iftrueand ifkeepRawisfalsethen keepsDumpEntry.key()andDumpEntry.value()asBinaryObject.keepRaw- Iftrue, doesn't deserialize cache data and keepsDumpEntry.key()asKeyCacheObjectandDumpEntry.value()asCacheObject. Iftrue, disableskeepBinary.cacheGrpNames- Cache group names.skipCopies- Skip copies.encSpi- Encryption SPI.
-
-
Method Detail
-
dumpRoot
public File dumpRoot()
- Returns:
- Root dump directiory.
-
consumer
public DumpConsumer consumer()
- Returns:
- Dump consumer instance.
-
threadCount
public int threadCount()
- Returns:
- Count of threads to consume dumped partitions.
-
timeout
public Duration timeout()
- Returns:
- Timeout of dump reader invocation.
-
failFast
public boolean failFast()
- Returns:
Trueif stop processing after first consumer error.
-
keepBinary
public boolean keepBinary()
Actual only ifkeepRawisfalse.- Returns:
TrueifDumpEntry.key()andDumpEntry.value()are kept asBinaryObject.
-
keepRaw
public boolean keepRaw()
- Returns:
TrueifDumpEntry.key()andDumpEntry.value()are kept asKeyCacheObjectandCacheObjectrespectively.
-
cacheGroupNames
public String[] cacheGroupNames()
- Returns:
- Cache group names.
-
skipCopies
public boolean skipCopies()
- Returns:
- Skip copies.
-
encryptionSpi
public EncryptionSpi encryptionSpi()
- Returns:
- Encryption SPI
-
-