voldemort.store.routed
Class RoutedStoreFactory

java.lang.Object
  voldemort.store.routed.RoutedStoreFactory

public class RoutedStoreFactory
extends java.lang.Object

Constructor Summary

RoutedStoreFactory(boolean isPipelineRoutedStoreEnabled, java.util.concurrent.ExecutorService threadPool, TimeoutConfig timeoutConfig)

Method Summary

RoutedStore	create(Cluster cluster, StoreDefinition storeDefinition, java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> nodeStores, boolean repairReads, FailureDetector failureDetector)
RoutedStore	create(Cluster cluster, StoreDefinition storeDefinition, java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> nodeStores, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores, java.util.Map<java.lang.Integer,Store<ByteArray,Slop,byte[]>> slopStores, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingSlopStores, boolean repairReads, int clientZoneId, FailureDetector failureDetector)
RoutedStore	create(Cluster cluster, StoreDefinition storeDefinition, java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> nodeStores, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores, java.util.Map<java.lang.Integer,Store<ByteArray,Slop,byte[]>> slopStores, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingSlopStores, boolean repairReads, int clientZoneId, FailureDetector failureDetector, boolean jmxEnabled, int jmxId)
NonblockingStore	toNonblockingStore(Store<ByteArray,byte[],byte[]> store)

Methods inherited from class java.lang.Object

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

Constructor Detail

RoutedStoreFactory

public RoutedStoreFactory(boolean isPipelineRoutedStoreEnabled,
                          java.util.concurrent.ExecutorService threadPool,
                          TimeoutConfig timeoutConfig)

Method Detail

toNonblockingStore

public NonblockingStore toNonblockingStore(Store<ByteArray,byte[],byte[]> store)

create

public RoutedStore create(Cluster cluster,
                          StoreDefinition storeDefinition,
                          java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> nodeStores,
                          java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores,
                          java.util.Map<java.lang.Integer,Store<ByteArray,Slop,byte[]>> slopStores,
                          java.util.Map<java.lang.Integer,NonblockingStore> nonblockingSlopStores,
                          boolean repairReads,
                          int clientZoneId,
                          FailureDetector failureDetector)

create

public RoutedStore create(Cluster cluster,
                          StoreDefinition storeDefinition,
                          java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> nodeStores,
                          java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores,
                          java.util.Map<java.lang.Integer,Store<ByteArray,Slop,byte[]>> slopStores,
                          java.util.Map<java.lang.Integer,NonblockingStore> nonblockingSlopStores,
                          boolean repairReads,
                          int clientZoneId,
                          FailureDetector failureDetector,
                          boolean jmxEnabled,
                          int jmxId)

create

public RoutedStore create(Cluster cluster,
                          StoreDefinition storeDefinition,
                          java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> nodeStores,
                          boolean repairReads,
                          FailureDetector failureDetector)