Package org.apache.ignite.internal.processors.cache.persistence.wal.reader

Class IgniteWalIteratorFactory.IteratorParametersBuilder

java.lang.Object

org.apache.ignite.internal.processors.cache.persistence.wal.reader.IgniteWalIteratorFactory.IteratorParametersBuilder

Enclosing class:

IgniteWalIteratorFactory

public static class IgniteWalIteratorFactory.IteratorParametersBuilder
extends Object

Wal iterator parameter builder.

Field Summary

Fields

Modifier and Type	Field	Description
static WALPointer	DFLT_HIGH_BOUND
static WALPointer	DFLT_LOW_BOUND

Constructor Summary

Constructors

Constructor	Description
IteratorParametersBuilder()

Method Summary

Modifier and Type	Method	Description
IgniteWalIteratorFactory.IteratorParametersBuilder	addFilter(IgniteBiPredicate<WALRecord.RecordType,WALPointer> filter)
IgniteWalIteratorFactory.IteratorParametersBuilder	binaryMetadataFileStoreDir(File binaryMetadataFileStoreDir)
IgniteWalIteratorFactory.IteratorParametersBuilder	bufferSize(int bufferSize)
IgniteWalIteratorFactory.IteratorParametersBuilder	copy()	Copy current state of builder to new instance.
IgniteWalIteratorFactory.IteratorParametersBuilder	filesOrDirs(File... filesOrDirs)
IgniteWalIteratorFactory.IteratorParametersBuilder	filesOrDirs(String... filesOrDirs)
IgniteWalIteratorFactory.IteratorParametersBuilder	filter(IgniteBiPredicate<WALRecord.RecordType,WALPointer> filter)
IgniteWalIteratorFactory.IteratorParametersBuilder	from(WALPointer lowBound)
IgniteWalIteratorFactory.IteratorParametersBuilder	igniteConfigurationModifier(Consumer<IgniteConfiguration> ignCfgMod)
IgniteWalIteratorFactory.IteratorParametersBuilder	ioFactory(FileIOFactory ioFactory)
IgniteWalIteratorFactory.IteratorParametersBuilder	keepBinary(boolean keepBinary)
IgniteWalIteratorFactory.IteratorParametersBuilder	log(IgniteLogger log)
IgniteWalIteratorFactory.IteratorParametersBuilder	marshallerMappingFileStoreDir(File marshallerMappingFileStoreDir)
IgniteWalIteratorFactory.IteratorParametersBuilder	pageSize(int pageSize)
IgniteWalIteratorFactory.IteratorParametersBuilder	sharedContext(GridCacheSharedContext sharedCtx)
IgniteWalIteratorFactory.IteratorParametersBuilder	strictBoundsCheck(boolean flag)
IgniteWalIteratorFactory.IteratorParametersBuilder	to(WALPointer highBound)
void	validate()
static IgniteWalIteratorFactory.IteratorParametersBuilder	withIteratorParameters()	Factory method for IgniteWalIteratorFactory.IteratorParametersBuilder.

Methods inherited from class java.lang.Object

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

Field Detail

DFLT_LOW_BOUND

public static final WALPointer DFLT_LOW_BOUND

DFLT_HIGH_BOUND

public static final WALPointer DFLT_HIGH_BOUND

Constructor Detail

IteratorParametersBuilder

public IteratorParametersBuilder()

Method Detail

withIteratorParameters

public static IgniteWalIteratorFactory.IteratorParametersBuilder withIteratorParameters()

Factory method for IgniteWalIteratorFactory.IteratorParametersBuilder.

Returns:

Instance of IgniteWalIteratorFactory.IteratorParametersBuilder.

log

public IgniteWalIteratorFactory.IteratorParametersBuilder log(IgniteLogger log)

Parameters:

log - Logger.

Returns:

IteratorParametersBuilder Self reference.

filesOrDirs

public IgniteWalIteratorFactory.IteratorParametersBuilder filesOrDirs(String... filesOrDirs)

Parameters:

filesOrDirs - Paths to files or directories.

Returns:

IteratorParametersBuilder Self reference.

filesOrDirs

public IgniteWalIteratorFactory.IteratorParametersBuilder filesOrDirs(File... filesOrDirs)

Parameters:

filesOrDirs - Files or directories.

Returns:

IteratorParametersBuilder Self reference.

pageSize

public IgniteWalIteratorFactory.IteratorParametersBuilder pageSize(int pageSize)

Parameters:

pageSize - Page size.

Returns:

IteratorParametersBuilder Self reference.

bufferSize

public IgniteWalIteratorFactory.IteratorParametersBuilder bufferSize(int bufferSize)

Parameters:

bufferSize - Initial size of buffer for reading segments.

Returns:

IteratorParametersBuilder Self reference.

keepBinary

public IgniteWalIteratorFactory.IteratorParametersBuilder keepBinary(boolean keepBinary)

Returns:

IteratorParametersBuilder Self reference.

ioFactory

public IgniteWalIteratorFactory.IteratorParametersBuilder ioFactory(FileIOFactory ioFactory)

Parameters:

ioFactory - Custom IO factory for reading files.

Returns:

IteratorParametersBuilder Self reference.

binaryMetadataFileStoreDir

public IgniteWalIteratorFactory.IteratorParametersBuilder binaryMetadataFileStoreDir(File binaryMetadataFileStoreDir)

Parameters:

binaryMetadataFileStoreDir - Path to the binary metadata.

Returns:

IteratorParametersBuilder Self reference.

marshallerMappingFileStoreDir

public IgniteWalIteratorFactory.IteratorParametersBuilder marshallerMappingFileStoreDir(File marshallerMappingFileStoreDir)

Parameters:

marshallerMappingFileStoreDir - Path to the marshaller mapping.

Returns:

IteratorParametersBuilder Self reference.

sharedContext

public IgniteWalIteratorFactory.IteratorParametersBuilder sharedContext(GridCacheSharedContext sharedCtx)

Parameters:

sharedCtx - Cache shared context.

Returns:

IteratorParametersBuilder Self reference.

igniteConfigurationModifier

public IgniteWalIteratorFactory.IteratorParametersBuilder igniteConfigurationModifier(Consumer<IgniteConfiguration> ignCfgMod)

Parameters:

ignCfgMod - Ignite configuration modifier.

Returns:

IteratorParametersBuilder Self reference.

filter

public IgniteWalIteratorFactory.IteratorParametersBuilder filter(IgniteBiPredicate<WALRecord.RecordType,WALPointer> filter)

Parameters:

filter - Record filter for skip records during iteration.

Returns:

IteratorParametersBuilder Self reference.

addFilter

public IgniteWalIteratorFactory.IteratorParametersBuilder addFilter(IgniteBiPredicate<WALRecord.RecordType,WALPointer> filter)

Parameters:

filter - Record filter for skip records during iteration.

Returns:

IteratorParametersBuilder Self reference.

from

public IgniteWalIteratorFactory.IteratorParametersBuilder from(WALPointer lowBound)

Parameters:

lowBound - WAL pointer to start from.

Returns:

IteratorParametersBuilder Self reference.

to

public IgniteWalIteratorFactory.IteratorParametersBuilder to(WALPointer highBound)

Parameters:

highBound - WAL pointer to end of.

Returns:

IteratorParametersBuilder Self reference.

strictBoundsCheck

public IgniteWalIteratorFactory.IteratorParametersBuilder strictBoundsCheck(boolean flag)

Parameters:

flag - Use strict check.

Returns:

IteratorParametersBuilder Self reference.

copy

public IgniteWalIteratorFactory.IteratorParametersBuilder copy()

Copy current state of builder to new instance.

Returns:

IteratorParametersBuilder Self reference.

validate

public void validate()
              throws IllegalArgumentException

Throws:

IllegalArgumentException - If validation failed.