voldemort.server
Class VoldemortConfig

java.lang.Object
  voldemort.server.VoldemortConfig

All Implemented Interfaces:

java.io.Serializable

public class VoldemortConfig
extends java.lang.Object
implements java.io.Serializable

Configuration parameters for the voldemort server.

See Also:

Serialized Form

Field Summary

static int	VOLDEMORT_DEFAULT_ADMIN_PORT
static java.lang.String	VOLDEMORT_HOME_VAR_NAME

Constructor Summary

VoldemortConfig(int nodeId, java.lang.String voldemortHome)

VoldemortConfig(java.util.Properties props)

VoldemortConfig(Props props)

Method Summary

int	getAdminConnectionTimeout()
int	getAdminCoreThreads()
int	getAdminMaxThreads()
int	getAdminSocketBufferSize()
int	getAdminSocketTimeout()
Props	getAllProps()
int	getBdbBtreeFanout() The btree node fanout.
long	getBdbCacheSize() The cache size given by "bdb.cache.size" in bytes default: 200MB
long	getBdbCheckpointBytes()
boolean	getBdbCheckpointerHighPriority() If true, the checkpointer uses more resources in order to complete the checkpoint in a shorter time interval.
long	getBdbCheckpointMs()
int	getBdbCleanerLookAheadCacheSize()
int	getBdbCleanerMaxBatchFiles() The maximum number of log files in the cleaner's backlog, or zero if there is no limit property: "bdb.cleaner.max.batch.files" default: 0 minimum: 0 maximum: 100000
int	getBdbCleanerMinFileUtilization() A log file will be cleaned if its utilization percentage is below this value, irrespective of total utilization.
int	getBdbCleanerMinUtilization() The cleaner will keep the total disk space utilization percentage above this value.
int	getBdbCleanerThreads() The number of cleaner threads property: "bdb.cleaner.threads" default: 1 minimum: 1
boolean	getBdbCursorPreload() Do we preload the cursor or not? The advantage of preloading for cursor is faster streaming performance, as entries are fetched in disk order.
java.lang.String	getBdbDataDirectory() The directory in which bdb data is stored.
boolean	getBdbFairLatches()
int	getBdbLockNLockTables()
long	getBdbLockTimeoutMs() The lock timeout for all transactional and non-transactional operations.
long	getBdbMaxLogFileSize() The maximum size of a single .jdb log file in bytes.
boolean	getBdbReadUncommitted()
int	getClientConnectionTimeoutMs()
int	getClientMaxConnectionsPerNode()
int	getClientMaxQueuedRequests()
int	getClientMaxThreads()
int	getClientNodeBannageMs() Deprecated. Use getFailureDetectorBannagePeriod() instead
int	getClientRoutingTimeoutMs()
int	getClientSelectors()
int	getClientThreadIdleMs()
int	getCoreThreads() The comfortable number of threads the threadpool will attempt to maintain.
java.lang.String	getDataDirectory() The directory name given by "data.directory" default: voldemort.home/data
long	getFailureDetectorAsyncRecoveryInterval()
long	getFailureDetectorBannagePeriod()
java.util.List<java.lang.String>	getFailureDetectorCatastrophicErrorTypes()
java.lang.String	getFailureDetectorImplementation()
long	getFailureDetectorRequestLengthThreshold()
int	getFailureDetectorThreshold()
int	getFailureDetectorThresholdCountMinimum()
long	getFailureDetectorThresholdInterval()
int	getGossipInterval() The interval at which gossip is run to exchange metadata
int	getMaxParallelStoresRebalancing()
int	getMaxRebalancingAttempt()
int	getMaxThreads() The maximum number of threadpool threads set by "max.threads" default: 100
java.lang.String	getMetadataDirectory() The directory name given by "metadata.directory" default: voldemort.home/config
java.lang.String	getMysqlDatabaseName()
java.lang.String	getMysqlHost()
java.lang.String	getMysqlPassword()
int	getMysqlPort()
java.lang.String	getMysqlUsername()
int	getNioAdminConnectorSelectors()
int	getNioConnectorSelectors()
int	getNodeId() The node id given by "node.id" property default: VOLDEMORT_NODE_ID environment variable
int	getNumScanPermits()
java.lang.String	getPusherType() The type of streaming job we would want to use to send hints.
int	getReadOnlyBackups()
java.lang.String	getReadOnlyDataStorageDirectory()
int	getReadOnlyDeleteBackupMs() Amount of time we will wait before we start deleting the backup.
java.lang.String	getReadOnlySearchStrategy()
boolean	getRebalancingOptimization()
long	getRebalancingTimeoutSec()
long	getRepairStartMs()
RequestFormatType	getRequestFormatType()
int	getRetentionCleanupFirstStartTimeInHour()
int	getRetentionCleanupScheduledPeriodInHour()
int	getSchedulerThreads()
int	getSlopBatchSize() Returns the size of the batch used while streaming slops
long	getSlopFrequencyMs()
long	getSlopMaxReadBytesPerSec()
long	getSlopMaxWriteBytesPerSec()
java.lang.String	getSlopStoreType() The underlying store type which will be used to store slops.
int	getSlopZonesDownToTerminate() Number of zones declared down before we terminate the pusher job
int	getSocketBufferSize()
boolean	getSocketKeepAlive()
int	getSocketTimeoutMs()
java.util.List<java.lang.String>	getStorageConfigurations()
long	getStreamMaxReadBytesPerSec()
long	getStreamMaxWriteBytesPerSec()
boolean	getUseNioConnector()
java.lang.String	getVoldemortHome() The node id given by "voldemort.home" default: VOLDEMORT_HOME environment variable
boolean	isAdminServerEnabled()
boolean	isBdbFlushTransactionsEnabled() Given by "bdb.flush.transactions".
boolean	isBdbOneEnvPerStore()
boolean	isBdbSortedDuplicatesEnabled()
boolean	isBdbWriteTransactionsEnabled()
boolean	isEnableRebalanceService()
boolean	isGossipEnabled()
boolean	isGuiEnabled()
boolean	isHttpServerEnabled()
boolean	isJmxEnabled()
boolean	isMetadataCheckingEnabled()
boolean	isNetworkClassLoaderEnabled()
boolean	isPipelineRoutedStoreEnabled()
boolean	isRepairEnabled()
boolean	isServerRoutingEnabled()
boolean	isSlopEnabled()
boolean	isSlopPusherJobEnabled()
boolean	isSocketServerEnabled()
boolean	isStatTrackingEnabled()
boolean	isVerboseLoggingEnabled()
static VoldemortConfig	loadFromEnvironmentVariable()
static VoldemortConfig	loadFromVoldemortHome(java.lang.String voldemortHome)
void	setAdminConnectionTimeout(int adminConnectionTimeout)
void	setAdminCoreThreads(int coreThreads)
void	setAdminMaxThreads(int maxThreads)
void	setAdminServerEnabled(boolean enableSocketServer)
void	setAdminSocketBufferSize(int socketBufferSize)
void	setAdminSocketTimeout(int adminSocketTimeout)
void	setBdbBtreeFanout(int bdbBtreeFanout)
void	setBdbCacheSize(int bdbCacheSize)
void	setBdbCheckpointBytes(long bdbCheckpointBytes)
void	setBdbCheckpointerHighPriority(boolean bdbCheckpointerHighPriority)
void	setBdbCheckpointMs(long bdbCheckpointMs)
void	setBdbCleanerLookAheadCacheSize(int bdbCleanerLookAheadCacheSize)
void	setBdbCleanerMaxBatchFiles(int bdbCleanerMaxBatchFiles)
void	setBdbCleanerMinFileUtilization(int minFileUtilization)
void	setBdbCleanerMinUtilization(int minUtilization)
void	setBdbCleanerThreads(int bdbCleanerThreads)
void	setBdbCursorPreload(boolean bdbCursorPreload)
void	setBdbDataDirectory(java.lang.String bdbDataDirectory)
void	setBdbFairLatches(boolean bdbFairLatches)
void	setBdbFlushTransactions(boolean bdbSyncTransactions)
void	setBdbLockNLockTables(int bdbLockNLockTables)
void	setBdbLockTimeoutMs(long bdbLockTimeoutMs)
void	setBdbMaxLogFileSize(long bdbMaxLogFileSize)
void	setBdbOneEnvPerStore(boolean bdbOneEnvPerStore)
void	setBdbReadUncommitted(boolean bdbReadUncommitted)
void	setBdbSortedDuplicates(boolean enable)
void	setBdbWriteTransactions(boolean bdbWriteTransactions)
void	setClientConnectionTimeoutMs(int connectionTimeoutMs)
void	setClientMaxConnectionsPerNode(int maxConnectionsPerNode)
void	setClientMaxQueuedRequests(int clientMaxQueuedRequests)
void	setClientMaxThreads(int clientMaxThreads)
void	setClientNodeBannageMs(int nodeBannageMs) Deprecated. Use setFailureDetectorBannagePeriod(long) instead
void	setClientRoutingTimeoutMs(int routingTimeoutMs)
void	setClientSelectors(int clientSelectors)
void	setClientThreadIdleMs(int clientThreadIdleMs)
void	setCoreThreads(int coreThreads)
void	setDataDirectory(java.lang.String dataDirectory)
void	setEnableAdminServer(boolean enableAdminServer)
void	setEnableGossip(boolean enableGossip)
void	setEnableGui(boolean enableGui)
void	setEnableHttpServer(boolean enableHttpServer)
void	setEnableJmx(boolean enableJmx)
void	setEnableMetadataChecking(boolean enableMetadataChecking)
void	setEnableNetworkClassLoader(boolean enableNetworkClassLoader)
void	setEnablePipelineRoutedStore(boolean enablePipelineRoutedStore)
void	setEnableRebalanceService(boolean enableRebalanceService)
void	setEnableRepair(boolean enableRepair)
void	setEnableServerRouting(boolean enableServerRouting)
void	setEnableSlop(boolean enableSlop)
void	setEnableSlopPusherJob(boolean enableSlopPusherJob)
void	setEnableStatTracking(boolean enableStatTracking)
void	setEnableVerboseLogging(boolean enableVerboseLogging)
void	setFailureDetectorAsyncRecoveryInterval(long failureDetectorAsyncRecoveryInterval)
void	setFailureDetectorBannagePeriod(long failureDetectorBannagePeriod)
void	setFailureDetectorCatastrophicErrorTypes(java.util.List<java.lang.String> failureDetectorCatastrophicErrorTypes)
void	setFailureDetectorImplementation(java.lang.String failureDetectorImplementation)
void	setFailureDetectorRequestLengthThreshold(long failureDetectorRequestLengthThreshold)
void	setFailureDetectorThreshold(int failureDetectorThreshold)
void	setFailureDetectorThresholdCountMinimum(int failureDetectorThresholdCountMinimum)
void	setFailureDetectorThresholdInterval(long failureDetectorThresholdInterval)
void	setGossipInterval(int gossipInterval)
void	setMaxParallelStoresRebalancing(boolean rebalancingOptimization)
void	setMaxParallelStoresRebalancing(int maxParallelStoresRebalancing)
void	setMaxRebalancingAttempt(int maxRebalancingAttempt)
void	setMaxThreads(int maxThreads)
void	setMetadataDirectory(java.lang.String metadataDirectory)
void	setMysqlDatabaseName(java.lang.String mysqlDatabaseName)
void	setMysqlHost(java.lang.String mysqlHost)
void	setMysqlPassword(java.lang.String mysqlPassword)
void	setMysqlPort(int mysqlPort)
void	setMysqlUsername(java.lang.String mysqlUsername)
void	setNioAdminConnectorSelectors(int nioAdminConnectorSelectors)
void	setNioConnectorSelectors(int nioConnectorSelectors)
void	setNodeId(int nodeId)
void	setNumScanPermits(int numScanPermits)
void	setPusherType(java.lang.String pusherType)
void	setReadOnlyBackups(int readOnlyBackups)
void	setReadOnlyDataStorageDirectory(java.lang.String readOnlyStorageDir)
void	setReadOnlyDeleteBackupMs(int readOnlyDeleteBackupTimeMs)
void	setReadOnlySearchStrategy(java.lang.String readOnlySearchStrategy)
void	setRebalancingTimeoutSec(long rebalancingTimeoutSec)
void	setRepairStartMs(long repairStartMs)
void	setRequestFormatType(RequestFormatType type)
void	setRetentionCleanupFirstStartTimeInHour(int retentionCleanupFirstStartTimeInHour)
void	setRetentionCleanupScheduledPeriodInHour(int retentionCleanupScheduledPeriodInHour)
void	setSchedulerThreads(int schedulerThreads)
void	setSlopBatchSize(int slopBatchSize)
void	setSlopFrequencyMs(long slopFrequencyMs)
void	setSlopMaxReadBytesPerSec(long slopMaxReadBytesPerSec)
void	setSlopMaxWriteBytesPerSec(long slopMaxWriteBytesPerSec)
void	setSlopStoreType(java.lang.String slopStoreType)
void	setSlopZonesDownToTerminate(int slopZonesDownToTerminate)
void	setSocketBufferSize(int socketBufferSize)
void	setSocketKeepAlive(boolean on)
void	setSocketTimeoutMs(int socketTimeoutMs)
void	setStorageConfigurations(java.util.List<java.lang.String> storageConfigurations)
void	setStreamMaxReadBytesPerSec(long streamMaxReadBytesPerSec)
void	setStreamMaxWriteBytesPerSec(long streamMaxWriteBytesPerSec)
void	setUseNioConnector(boolean useNio)
void	setVoldemortHome(java.lang.String voldemortHome)

Methods inherited from class java.lang.Object

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

Field Detail

VOLDEMORT_HOME_VAR_NAME

public static final java.lang.String VOLDEMORT_HOME_VAR_NAME

See Also:

Constant Field Values

VOLDEMORT_DEFAULT_ADMIN_PORT

public static int VOLDEMORT_DEFAULT_ADMIN_PORT

Constructor Detail

VoldemortConfig

public VoldemortConfig(java.util.Properties props)

VoldemortConfig

public VoldemortConfig(Props props)

VoldemortConfig

public VoldemortConfig(int nodeId,
                       java.lang.String voldemortHome)

Method Detail

loadFromEnvironmentVariable

public static VoldemortConfig loadFromEnvironmentVariable()

loadFromVoldemortHome

public static VoldemortConfig loadFromVoldemortHome(java.lang.String voldemortHome)

getGossipInterval

public int getGossipInterval()

The interval at which gossip is run to exchange metadata

setGossipInterval

public void setGossipInterval(int gossipInterval)

getNodeId

public int getNodeId()

The node id given by "node.id" property default: VOLDEMORT_NODE_ID environment variable

setNodeId

public void setNodeId(int nodeId)

getVoldemortHome

public java.lang.String getVoldemortHome()

The node id given by "voldemort.home" default: VOLDEMORT_HOME environment variable

setVoldemortHome

public void setVoldemortHome(java.lang.String voldemortHome)

getDataDirectory

public java.lang.String getDataDirectory()

The directory name given by "data.directory" default: voldemort.home/data

setDataDirectory

public void setDataDirectory(java.lang.String dataDirectory)

getMetadataDirectory

public java.lang.String getMetadataDirectory()

The directory name given by "metadata.directory" default: voldemort.home/config

setMetadataDirectory

public void setMetadataDirectory(java.lang.String metadataDirectory)

getBdbCacheSize

public long getBdbCacheSize()

The cache size given by "bdb.cache.size" in bytes default: 200MB

setBdbCacheSize

public void setBdbCacheSize(int bdbCacheSize)

isBdbFlushTransactionsEnabled

public boolean isBdbFlushTransactionsEnabled()

Given by "bdb.flush.transactions". If true then sync transactions to disk immediately. default: false

setBdbFlushTransactions

public void setBdbFlushTransactions(boolean bdbSyncTransactions)

getBdbDataDirectory

public java.lang.String getBdbDataDirectory()

The directory in which bdb data is stored. Given by "bdb.data.directory" default: data.directory/bdb

setBdbDataDirectory

public void setBdbDataDirectory(java.lang.String bdbDataDirectory)

getBdbMaxLogFileSize

public long getBdbMaxLogFileSize()

The maximum size of a single .jdb log file in bytes. Given by "bdb.max.logfile.size" default: 60MB

setBdbMaxLogFileSize

public void setBdbMaxLogFileSize(long bdbMaxLogFileSize)

getBdbCleanerMinFileUtilization

public int getBdbCleanerMinFileUtilization()

A log file will be cleaned if its utilization percentage is below this value, irrespective of total utilization.

• property: "bdb.cleaner.minFileUtilization"
• default: 5
• minimum: 0
• maximum: 50

setBdbCleanerMinFileUtilization

public final void setBdbCleanerMinFileUtilization(int minFileUtilization)

getBdbCheckpointerHighPriority

public boolean getBdbCheckpointerHighPriority()

If true, the checkpointer uses more resources in order to complete the checkpoint in a shorter time interval.

• property: "bdb.checkpointer.high.priority"
• default: false

setBdbCheckpointerHighPriority

public final void setBdbCheckpointerHighPriority(boolean bdbCheckpointerHighPriority)

getBdbCleanerMaxBatchFiles

public int getBdbCleanerMaxBatchFiles()

The maximum number of log files in the cleaner's backlog, or zero if there is no limit

• property: "bdb.cleaner.max.batch.files"
• default: 0
• minimum: 0
• maximum: 100000

setBdbCleanerMaxBatchFiles

public final void setBdbCleanerMaxBatchFiles(int bdbCleanerMaxBatchFiles)

getBdbCleanerThreads

public int getBdbCleanerThreads()

The number of cleaner threads

• property: "bdb.cleaner.threads"
• default: 1
• minimum: 1

setBdbCleanerThreads

public final void setBdbCleanerThreads(int bdbCleanerThreads)

getBdbCleanerLookAheadCacheSize

public int getBdbCleanerLookAheadCacheSize()

setBdbCleanerLookAheadCacheSize

public final void setBdbCleanerLookAheadCacheSize(int bdbCleanerLookAheadCacheSize)

getBdbLockTimeoutMs

public long getBdbLockTimeoutMs()

The lock timeout for all transactional and non-transactional operations. Value of zero disables lock timeouts i.e. a deadlock scenario will block forever

• property: "bdb.lock.timeout.ms"
• default: 500
• minimum: 0
• maximum: 75 * 60 * 1000

setBdbLockTimeoutMs

public final void setBdbLockTimeoutMs(long bdbLockTimeoutMs)

setBdbLockNLockTables

public void setBdbLockNLockTables(int bdbLockNLockTables)

getBdbLockNLockTables

public int getBdbLockNLockTables()

getBdbFairLatches

public boolean getBdbFairLatches()

setBdbFairLatches

public void setBdbFairLatches(boolean bdbFairLatches)

getBdbReadUncommitted

public boolean getBdbReadUncommitted()

setBdbReadUncommitted

public void setBdbReadUncommitted(boolean bdbReadUncommitted)

getBdbCleanerMinUtilization

public int getBdbCleanerMinUtilization()

The cleaner will keep the total disk space utilization percentage above this value.

• property: "bdb.cleaner.minUtilization"
• default: 50
• minimum: 0
• maximum: 90

setBdbCleanerMinUtilization

public final void setBdbCleanerMinUtilization(int minUtilization)

getBdbBtreeFanout

public int getBdbBtreeFanout()

The btree node fanout. Given by "bdb.btree.fanout". default: 512

setBdbBtreeFanout

public void setBdbBtreeFanout(int bdbBtreeFanout)

getBdbCursorPreload

public boolean getBdbCursorPreload()

Do we preload the cursor or not? The advantage of preloading for cursor is faster streaming performance, as entries are fetched in disk order. Incidentally, pre-loading is only a side-effect of what we're really trying to do: fetch in disk (as opposed to key) order, but there doesn't seem to be an easy/intuitive way to do for BDB JE.

setBdbCursorPreload

public void setBdbCursorPreload(boolean bdbCursorPreload)

getCoreThreads

public int getCoreThreads()

The comfortable number of threads the threadpool will attempt to maintain. Specified by "core.threads" default: max(1, floor(0.5 * max.threads))

setCoreThreads

public void setCoreThreads(int coreThreads)

getMaxThreads

public int getMaxThreads()

The maximum number of threadpool threads set by "max.threads" default: 100

setMaxThreads

public void setMaxThreads(int maxThreads)

getAdminCoreThreads

public int getAdminCoreThreads()

setAdminCoreThreads

public void setAdminCoreThreads(int coreThreads)

getAdminMaxThreads

public int getAdminMaxThreads()

setAdminMaxThreads

public void setAdminMaxThreads(int maxThreads)

isHttpServerEnabled

public boolean isHttpServerEnabled()

setEnableHttpServer

public void setEnableHttpServer(boolean enableHttpServer)

isSocketServerEnabled

public boolean isSocketServerEnabled()

setAdminServerEnabled

public void setAdminServerEnabled(boolean enableSocketServer)

isAdminServerEnabled

public boolean isAdminServerEnabled()

getStreamMaxReadBytesPerSec

public long getStreamMaxReadBytesPerSec()

setStreamMaxReadBytesPerSec

public void setStreamMaxReadBytesPerSec(long streamMaxReadBytesPerSec)

getStreamMaxWriteBytesPerSec

public long getStreamMaxWriteBytesPerSec()

setStreamMaxWriteBytesPerSec

public void setStreamMaxWriteBytesPerSec(long streamMaxWriteBytesPerSec)

getSlopMaxWriteBytesPerSec

public long getSlopMaxWriteBytesPerSec()

setSlopMaxWriteBytesPerSec

public void setSlopMaxWriteBytesPerSec(long slopMaxWriteBytesPerSec)

getSlopMaxReadBytesPerSec

public long getSlopMaxReadBytesPerSec()

setSlopMaxReadBytesPerSec

public void setSlopMaxReadBytesPerSec(long slopMaxReadBytesPerSec)

setEnableAdminServer

public void setEnableAdminServer(boolean enableAdminServer)

isJmxEnabled

public boolean isJmxEnabled()

setEnableJmx

public void setEnableJmx(boolean enableJmx)

isPipelineRoutedStoreEnabled

public boolean isPipelineRoutedStoreEnabled()

setEnablePipelineRoutedStore

public void setEnablePipelineRoutedStore(boolean enablePipelineRoutedStore)

isGuiEnabled

public boolean isGuiEnabled()

setEnableGui

public void setEnableGui(boolean enableGui)

getMysqlUsername

public java.lang.String getMysqlUsername()

setMysqlUsername

public void setMysqlUsername(java.lang.String mysqlUsername)

getMysqlPassword

public java.lang.String getMysqlPassword()

setMysqlPassword

public void setMysqlPassword(java.lang.String mysqlPassword)

getMysqlDatabaseName

public java.lang.String getMysqlDatabaseName()

setMysqlDatabaseName

public void setMysqlDatabaseName(java.lang.String mysqlDatabaseName)

getMysqlHost

public java.lang.String getMysqlHost()

setMysqlHost

public void setMysqlHost(java.lang.String mysqlHost)

getMysqlPort

public int getMysqlPort()

setMysqlPort

public void setMysqlPort(int mysqlPort)

getSlopStoreType

public java.lang.String getSlopStoreType()

The underlying store type which will be used to store slops. Defaults to Bdb

setSlopStoreType

public void setSlopStoreType(java.lang.String slopStoreType)

getPusherType

public java.lang.String getPusherType()

The type of streaming job we would want to use to send hints. Defaults to streaming

setPusherType

public void setPusherType(java.lang.String pusherType)

getSlopZonesDownToTerminate

public int getSlopZonesDownToTerminate()

Number of zones declared down before we terminate the pusher job

setSlopZonesDownToTerminate

public void setSlopZonesDownToTerminate(int slopZonesDownToTerminate)

getSlopBatchSize

public int getSlopBatchSize()

Returns the size of the batch used while streaming slops

setSlopBatchSize

public void setSlopBatchSize(int slopBatchSize)

getSocketTimeoutMs

public int getSocketTimeoutMs()

getSlopFrequencyMs

public long getSlopFrequencyMs()

setSlopFrequencyMs

public void setSlopFrequencyMs(long slopFrequencyMs)

getRepairStartMs

public long getRepairStartMs()

setRepairStartMs

public void setRepairStartMs(long repairStartMs)

setSocketTimeoutMs

public void setSocketTimeoutMs(int socketTimeoutMs)

getClientSelectors

public int getClientSelectors()

setClientSelectors

public void setClientSelectors(int clientSelectors)

getClientRoutingTimeoutMs

public int getClientRoutingTimeoutMs()

setClientRoutingTimeoutMs

public void setClientRoutingTimeoutMs(int routingTimeoutMs)

getClientMaxConnectionsPerNode

public int getClientMaxConnectionsPerNode()

setClientMaxConnectionsPerNode

public void setClientMaxConnectionsPerNode(int maxConnectionsPerNode)

getClientConnectionTimeoutMs

public int getClientConnectionTimeoutMs()

setClientConnectionTimeoutMs

public void setClientConnectionTimeoutMs(int connectionTimeoutMs)

getClientNodeBannageMs

@Deprecated
public int getClientNodeBannageMs()

Deprecated. Use getFailureDetectorBannagePeriod() instead

setClientNodeBannageMs

@Deprecated
public void setClientNodeBannageMs(int nodeBannageMs)

Deprecated. Use setFailureDetectorBannagePeriod(long) instead

getClientMaxThreads

public int getClientMaxThreads()

setClientMaxThreads

public void setClientMaxThreads(int clientMaxThreads)

getClientThreadIdleMs

public int getClientThreadIdleMs()

setClientThreadIdleMs

public void setClientThreadIdleMs(int clientThreadIdleMs)

getClientMaxQueuedRequests

public int getClientMaxQueuedRequests()

setClientMaxQueuedRequests

public void setClientMaxQueuedRequests(int clientMaxQueuedRequests)

isSlopEnabled

public boolean isSlopEnabled()

setEnableSlop

public void setEnableSlop(boolean enableSlop)

isSlopPusherJobEnabled

public boolean isSlopPusherJobEnabled()

setEnableSlopPusherJob

public void setEnableSlopPusherJob(boolean enableSlopPusherJob)

isRepairEnabled

public boolean isRepairEnabled()

setEnableRepair

public void setEnableRepair(boolean enableRepair)

isVerboseLoggingEnabled

public boolean isVerboseLoggingEnabled()

setEnableVerboseLogging

public void setEnableVerboseLogging(boolean enableVerboseLogging)

isStatTrackingEnabled

public boolean isStatTrackingEnabled()

setEnableStatTracking

public void setEnableStatTracking(boolean enableStatTracking)

isMetadataCheckingEnabled

public boolean isMetadataCheckingEnabled()

setEnableMetadataChecking

public void setEnableMetadataChecking(boolean enableMetadataChecking)

getBdbCheckpointBytes

public long getBdbCheckpointBytes()

setBdbCheckpointBytes

public void setBdbCheckpointBytes(long bdbCheckpointBytes)

getBdbCheckpointMs

public long getBdbCheckpointMs()

setBdbCheckpointMs

public void setBdbCheckpointMs(long bdbCheckpointMs)

getSchedulerThreads

public int getSchedulerThreads()

setSchedulerThreads

public void setSchedulerThreads(int schedulerThreads)

getReadOnlyDataStorageDirectory

public java.lang.String getReadOnlyDataStorageDirectory()

setReadOnlyDataStorageDirectory

public void setReadOnlyDataStorageDirectory(java.lang.String readOnlyStorageDir)

getReadOnlyBackups

public int getReadOnlyBackups()

setReadOnlyBackups

public void setReadOnlyBackups(int readOnlyBackups)

getReadOnlyDeleteBackupMs

public int getReadOnlyDeleteBackupMs()

Amount of time we will wait before we start deleting the backup. This happens during swaps when old backups need to be deleted. Some delay is required so that we don't cause a sudden increase of IOPs during swap.

Returns:

The start time in ms

setReadOnlyDeleteBackupMs

public void setReadOnlyDeleteBackupMs(int readOnlyDeleteBackupTimeMs)

isBdbWriteTransactionsEnabled

public boolean isBdbWriteTransactionsEnabled()

setBdbWriteTransactions

public void setBdbWriteTransactions(boolean bdbWriteTransactions)

isBdbSortedDuplicatesEnabled

public boolean isBdbSortedDuplicatesEnabled()

setBdbSortedDuplicates

public void setBdbSortedDuplicates(boolean enable)

setBdbOneEnvPerStore

public void setBdbOneEnvPerStore(boolean bdbOneEnvPerStore)

isBdbOneEnvPerStore

public boolean isBdbOneEnvPerStore()

getSocketBufferSize

public int getSocketBufferSize()

setSocketBufferSize

public void setSocketBufferSize(int socketBufferSize)

getSocketKeepAlive

public boolean getSocketKeepAlive()

setSocketKeepAlive

public void setSocketKeepAlive(boolean on)

getUseNioConnector

public boolean getUseNioConnector()

setUseNioConnector

public void setUseNioConnector(boolean useNio)

getNioConnectorSelectors

public int getNioConnectorSelectors()

setNioConnectorSelectors

public void setNioConnectorSelectors(int nioConnectorSelectors)

getNioAdminConnectorSelectors

public int getNioAdminConnectorSelectors()

setNioAdminConnectorSelectors

public void setNioAdminConnectorSelectors(int nioAdminConnectorSelectors)

getAdminSocketBufferSize

public int getAdminSocketBufferSize()

setAdminSocketBufferSize

public void setAdminSocketBufferSize(int socketBufferSize)

getStorageConfigurations

public java.util.List<java.lang.String> getStorageConfigurations()

setStorageConfigurations

public void setStorageConfigurations(java.util.List<java.lang.String> storageConfigurations)

getAllProps

public Props getAllProps()

setRequestFormatType

public void setRequestFormatType(RequestFormatType type)

getRequestFormatType

public RequestFormatType getRequestFormatType()

isServerRoutingEnabled

public boolean isServerRoutingEnabled()

setEnableServerRouting

public void setEnableServerRouting(boolean enableServerRouting)

getNumScanPermits

public int getNumScanPermits()

setNumScanPermits

public void setNumScanPermits(int numScanPermits)

getFailureDetectorImplementation

public java.lang.String getFailureDetectorImplementation()

setFailureDetectorImplementation

public void setFailureDetectorImplementation(java.lang.String failureDetectorImplementation)

getFailureDetectorBannagePeriod

public long getFailureDetectorBannagePeriod()

setFailureDetectorBannagePeriod

public void setFailureDetectorBannagePeriod(long failureDetectorBannagePeriod)

getFailureDetectorThreshold

public int getFailureDetectorThreshold()

setFailureDetectorThreshold

public void setFailureDetectorThreshold(int failureDetectorThreshold)

getFailureDetectorThresholdCountMinimum

public int getFailureDetectorThresholdCountMinimum()

setFailureDetectorThresholdCountMinimum

public void setFailureDetectorThresholdCountMinimum(int failureDetectorThresholdCountMinimum)

getFailureDetectorThresholdInterval

public long getFailureDetectorThresholdInterval()

setFailureDetectorThresholdInterval

public void setFailureDetectorThresholdInterval(long failureDetectorThresholdInterval)

getFailureDetectorAsyncRecoveryInterval

public long getFailureDetectorAsyncRecoveryInterval()

setFailureDetectorAsyncRecoveryInterval

public void setFailureDetectorAsyncRecoveryInterval(long failureDetectorAsyncRecoveryInterval)

getFailureDetectorCatastrophicErrorTypes

public java.util.List<java.lang.String> getFailureDetectorCatastrophicErrorTypes()

setFailureDetectorCatastrophicErrorTypes

public void setFailureDetectorCatastrophicErrorTypes(java.util.List<java.lang.String> failureDetectorCatastrophicErrorTypes)

getFailureDetectorRequestLengthThreshold

public long getFailureDetectorRequestLengthThreshold()

setFailureDetectorRequestLengthThreshold

public void setFailureDetectorRequestLengthThreshold(long failureDetectorRequestLengthThreshold)

getRetentionCleanupFirstStartTimeInHour

public int getRetentionCleanupFirstStartTimeInHour()

setRetentionCleanupFirstStartTimeInHour

public void setRetentionCleanupFirstStartTimeInHour(int retentionCleanupFirstStartTimeInHour)

getRetentionCleanupScheduledPeriodInHour

public int getRetentionCleanupScheduledPeriodInHour()

setRetentionCleanupScheduledPeriodInHour

public void setRetentionCleanupScheduledPeriodInHour(int retentionCleanupScheduledPeriodInHour)

getAdminSocketTimeout

public int getAdminSocketTimeout()

setAdminSocketTimeout

public void setAdminSocketTimeout(int adminSocketTimeout)

getAdminConnectionTimeout

public int getAdminConnectionTimeout()

setAdminConnectionTimeout

public void setAdminConnectionTimeout(int adminConnectionTimeout)

setMaxRebalancingAttempt

public void setMaxRebalancingAttempt(int maxRebalancingAttempt)

getMaxRebalancingAttempt

public int getMaxRebalancingAttempt()

getRebalancingTimeoutSec

public long getRebalancingTimeoutSec()

setRebalancingTimeoutSec

public void setRebalancingTimeoutSec(long rebalancingTimeoutSec)

isGossipEnabled

public boolean isGossipEnabled()

setEnableGossip

public void setEnableGossip(boolean enableGossip)

getReadOnlySearchStrategy

public java.lang.String getReadOnlySearchStrategy()

setReadOnlySearchStrategy

public void setReadOnlySearchStrategy(java.lang.String readOnlySearchStrategy)

isNetworkClassLoaderEnabled

public boolean isNetworkClassLoaderEnabled()

setEnableNetworkClassLoader

public void setEnableNetworkClassLoader(boolean enableNetworkClassLoader)

setEnableRebalanceService

public void setEnableRebalanceService(boolean enableRebalanceService)

isEnableRebalanceService

public boolean isEnableRebalanceService()

getMaxParallelStoresRebalancing

public int getMaxParallelStoresRebalancing()

setMaxParallelStoresRebalancing

public void setMaxParallelStoresRebalancing(int maxParallelStoresRebalancing)

getRebalancingOptimization

public boolean getRebalancingOptimization()

setMaxParallelStoresRebalancing

public void setMaxParallelStoresRebalancing(boolean rebalancingOptimization)