com.indeed.lsmtree.recordcache

Class ReplicatingStoreBuilder<K,V>

java.lang.Object

com.indeed.lsmtree.recordcache.ReplicatingStoreBuilder<K,V>

public final class ReplicatingStoreBuilder<K,V>
extends Object

Author:

jplaisance

Constructor Summary

Constructors

Constructor and Description
ReplicatingStoreBuilder(File recordsPath, File indexPath, com.indeed.util.serialization.Serializer<K> keySerializer, com.indeed.util.serialization.Serializer<V> valueSerializer)

Method Summary

Modifier and Type	Method and Description
RecordLogStore<K,V>	build()
ReplicatingStoreBuilder<K,V>	setCheckpointDir(File checkpointDir)
ReplicatingStoreBuilder<K,V>	setCodec(com.indeed.util.compress.CompressionCodec codec)
ReplicatingStoreBuilder<K,V>	setComparator(Comparator<K> comparator)
ReplicatingStoreBuilder<K,V>	setDedicatedPartition(boolean dedicatedPartition)
ReplicatingStoreBuilder<K,V>	setKeyCollectionSerializer(com.indeed.util.serialization.Serializer<Collection<K>> keyCollectionSerializer)
ReplicatingStoreBuilder<K,V>	setMaxVolatileGenerationSize(long maxVolatileGenerationSize)
ReplicatingStoreBuilder<K,V>	setReservedSpaceThreshold(long reservedSpaceThreshold)
ReplicatingStoreBuilder<K,V>	setStorageType(StorageType storageType)
ReplicatingStoreBuilder<K,V>	setStoreCodec(com.indeed.util.compress.CompressionCodec codec)

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicatingStoreBuilder

public ReplicatingStoreBuilder(File recordsPath,
                               File indexPath,
                               com.indeed.util.serialization.Serializer<K> keySerializer,
                               com.indeed.util.serialization.Serializer<V> valueSerializer)

Method Detail

setKeyCollectionSerializer

public ReplicatingStoreBuilder<K,V> setKeyCollectionSerializer(com.indeed.util.serialization.Serializer<Collection<K>> keyCollectionSerializer)

setCodec

public ReplicatingStoreBuilder<K,V> setCodec(com.indeed.util.compress.CompressionCodec codec)

setDedicatedPartition

public ReplicatingStoreBuilder<K,V> setDedicatedPartition(boolean dedicatedPartition)

setReservedSpaceThreshold

public ReplicatingStoreBuilder<K,V> setReservedSpaceThreshold(long reservedSpaceThreshold)

setComparator

public ReplicatingStoreBuilder<K,V> setComparator(Comparator<K> comparator)

setMaxVolatileGenerationSize

public ReplicatingStoreBuilder<K,V> setMaxVolatileGenerationSize(long maxVolatileGenerationSize)

setStorageType

public ReplicatingStoreBuilder<K,V> setStorageType(StorageType storageType)

setStoreCodec

public ReplicatingStoreBuilder<K,V> setStoreCodec(com.indeed.util.compress.CompressionCodec codec)

setCheckpointDir

public ReplicatingStoreBuilder<K,V> setCheckpointDir(File checkpointDir)

build

public RecordLogStore<K,V> build()
                          throws IOException

Throws:

IOException