Package com.j_spaces.core

Class JSpaceAttributes

java.lang.Object
java.util.Dictionary<K,V>
java.util.Hashtable<Object,Object>
java.util.Properties
com.j_spaces.core.JSpaceAttributes
All Implemented Interfaces:
SmartExternalizable, Externalizable, Serializable, Cloneable, Map<Object,Object>
Direct Known Subclasses:
SpaceConfig, ZKCollocatedClientConfig
public class JSpaceAttributes extends Properties implements SmartExternalizable
JSpaceAttributes that contains all information per space.
Version:
1.0
Author:
Igor Goldenberg
See Also:

  • Field Details

    • m_isClustered

      @Deprecated public boolean m_isClustered
      Deprecated.
      Use in methods setClustered(boolean isClustered) and isClustered() instead of referring to this deprecated class member. Should be used for read purposes only, not for update. Updating is performing only by method setClustered(boolean isClustered)

  • Constructor Details

    • JSpaceAttributes

      public JSpaceAttributes()
      Default constructor.

    • JSpaceAttributes

      public JSpaceAttributes(Properties prop)

    • JSpaceAttributes

      public JSpaceAttributes(String schemaName, Properties customProperties, boolean isLoadSpaceOnStartup)
      Initialize JSpace attributes.
      Parameters:
      schemaName - The space/container schema name. If not null we use this schema xml file as the space/container configuration template for this space.
      customProperties - if passed we use it to overwrite the space/container JProperties.

    • JSpaceAttributes

      public JSpaceAttributes(String schemaName, boolean isLoadSpaceOnStartup)
      Initialize JSpace attributes.
      Parameters:
      schemaName - The space/container schema name. If not null we use this schema xml file as the space/container configuration template for this space.

    • JSpaceAttributes

      public JSpaceAttributes(String schemaName, String clusterConfigURL)
      Initialize JSpace attributes.
      Parameters:
      schemaName - The space/container schema name. If not null we use this schema xml file as the space configuration template for this space.
      clusterConfigURL - URL to cluster configuration file.

  • Method Details

    • setProperty

      public Object setProperty(String key, String value)
      Overrides method of super class. Checks value for null, only if value is not null appropriate method of parent class will be called. In such way NullPointerException is prevented.
      Overrides:
      setProperty in class Properties
      Parameters:
      key - the key to be placed into this property list.
      value - the value corresponding to key.

    • clone

      public Object clone()
      Overrides:
      clone in class Properties

    • toString

      public String toString()
      Overrides:
      toString in class Properties

    • isPersistent

      public boolean isPersistent()

    • setPersistent

      public void setPersistent(boolean isPersistent)
      Parameters:
      isPersistent -

    • isQPAutoCommit

      public boolean isQPAutoCommit()

    • setQPAutoCommit

      public void setQPAutoCommit(boolean isQPAutoCommit)
      Parameters:
      isQPAutoCommit -

    • isQPParserCaseSensetivity

      public boolean isQPParserCaseSensetivity()

    • setQPParserCaseSensetivity

      public void setQPParserCaseSensetivity(boolean isQPParserCaseSensetivity)
      Parameters:
      isQPParserCaseSensetivity -

    • isQPTraceExecTime

      public boolean isQPTraceExecTime()

    • setQPTraceExecTime

      public void setQPTraceExecTime(boolean isQPTraceExecTime)
      Parameters:
      isQPTraceExecTime -

    • getQpSpaceReadLeaseTime

      public int getQpSpaceReadLeaseTime()

    • setQpSpaceReadLeaseTime

      public void setQpSpaceReadLeaseTime(int qpSpaceReadLeaseTime)
      Parameters:
      qpSpaceReadLeaseTime -

    • getQpSpaceWriteLeaseTime

      public long getQpSpaceWriteLeaseTime()

    • setQpSpaceWriteLeaseTime

      public void setQpSpaceWriteLeaseTime(long qpSpaceWriteLeaseTime)
      Parameters:
      qpSpaceWriteLeaseTime -

    • getQpTransactionTimeout

      public int getQpTransactionTimeout()

    • setQpTransactionTimeout

      public void setQpTransactionTimeout(int qpTransactionTimeout)
      Parameters:
      qpTransactionTimeout -

    • getQpDateFormat

      public String getQpDateFormat()

    • setQpDateFormat

      public void setQpDateFormat(String qpDateFormat)
      Parameters:
      qpDateFormat -

    • getQpDateTimeFormat

      public String getQpDateTimeFormat()

    • setQpDateTimeFormat

      public void setQpDateTimeFormat(String qpDateTimeFormat)
      Parameters:
      qpDateTimeFormat -

    • getQpTimeFormat

      public String getQpTimeFormat()

    • setQpTimeFormat

      public void setQpTimeFormat(String qpTimeFormat)
      Parameters:
      qpTimeFormat -

    • getQpUtilDateFormat

      public String getQpUtilDateFormat()

    • setQpUtilDateFormat

      public void setQpUtilDateFormat(String qpUtilDateFormat)
      Parameters:
      qpUtilDateFormat -

    • getQpSqlDateFormat

      public String getQpSqlDateFormat()

    • setQpSqlDateFormat

      public void setQpSqlDateFormat(String qpSqlDateFormat)
      Parameters:
      qpSqlDateFormat -

    • getQpLocalDateTimeFormat

      public String getQpLocalDateTimeFormat()

    • setQpLocalDateTimeFormat

      public void setQpLocalDateTimeFormat(String qpLocalDateTimeFormat)
      Parameters:
      qpLocalDateTimeFormat -

    • getQpLocalTimeFormat

      public String getQpLocalTimeFormat()

    • setQpLocalTimeFormat

      public void setQpLocalTimeFormat(String qpLocalTimeFormat)
      Parameters:
      qpLocalTimeFormat -

    • getQpLocalDateFormat

      public String getQpLocalDateFormat()

    • setQpLocalDateFormat

      public void setQpLocalDateFormat(String qpLocalDateFormat)
      Parameters:
      qpLocalDateFormat -

    • getQpSqlTimeFormat

      public String getQpSqlTimeFormat()

    • setQpSqlTimeFormat

      public void setQpSqlTimeFormat(String qpSqlTimeFormat)
      Parameters:
      qpSqlTimeFormat -

    • getQpTimestampFormat

      public String getQpTimestampFormat()

    • setQpTimestampFormat

      public void setQpTimestampFormat(String qpTimestampFormat)
      Parameters:
      qpTimestampFormat -

    • getQpInstantFormat

      public String getQpInstantFormat()

    • setQpInstantFormat

      public void setQpInstantFormat(String qpInstantFormat)
      Parameters:
      qpInstantFormat -

    • isEngineMemoryUsageEnabled

      public String isEngineMemoryUsageEnabled()

    • setEngineMemoryUsageEnabled

      public void setEngineMemoryUsageEnabled(String isMemoryUsageEnabled)
      Parameters:
      isMemoryUsageEnabled -

    • setEngineMemoryUsageHighPercentageRatio

      public void setEngineMemoryUsageHighPercentageRatio(String highPercentageRatio)
      Parameters:
      highPercentageRatio -

    • getEngineMemoryUsageHighPercentageRatio

      public String getEngineMemoryUsageHighPercentageRatio()

    • setEngineMemoryUsageWriteOnlyBlockPercentageRatio

      public void setEngineMemoryUsageWriteOnlyBlockPercentageRatio(String blockPercentageRatio)
      Parameters:
      blockPercentageRatio -

    • getEngineMemoryUsageWriteOnlyBlockPercentageRatio

      public String getEngineMemoryUsageWriteOnlyBlockPercentageRatio()

    • setEngineMemoryWriteOnlyCheckPercentageRatio

      public void setEngineMemoryWriteOnlyCheckPercentageRatio(String writeOnlyCheckPercentageRatio)
      Parameters:
      writeOnlyCheckPercentageRatio -

    • getEngineMemoryWriteOnlyCheckPercentageRatio

      public String getEngineMemoryWriteOnlyCheckPercentageRatio()

    • setEngineMemoryUsageLowPercentageRatio

      public void setEngineMemoryUsageLowPercentageRatio(String lowPercentageRatio)
      Parameters:
      lowPercentageRatio -

    • getEngineMemoryUsageLowPercentageRatio

      public String getEngineMemoryUsageLowPercentageRatio()

    • isEngineMemoryExplicitGSEnabled

      public String isEngineMemoryExplicitGSEnabled()

    • setEngineMemoryExplicitGSEnabled

      public void setEngineMemoryExplicitGSEnabled(String isMemoryExplicitGSEnabled)
      Parameters:
      isMemoryExplicitGSEnabled -

    • isEngineMemoryGCBeforeShortageEnabled

      public String isEngineMemoryGCBeforeShortageEnabled()

    • setEngineMemoryGCBeforeShortageEnabled

      public void setEngineMemoryGCBeforeShortageEnabled(String gcBeforeShortage)

    • setEngineMemoryUsageRetryCount

      public void setEngineMemoryUsageRetryCount(String retryCount)
      * @param retryCount

    • getEngineMemoryUsageRetryCount

      public String getEngineMemoryUsageRetryCount()

    • setEngineMemoryUsageEvictionBatchSize

      public void setEngineMemoryUsageEvictionBatchSize(String evictionBatchSize)
      Parameters:
      evictionBatchSize -

    • getEngineMemoryUsageEvictionBatchSize

      public String getEngineMemoryUsageEvictionBatchSize()

    • setEngineMaxThreads

      public void setEngineMaxThreads(String maxThreads)
      Parameters:
      maxThreads -

    • getEngineMaxThreads

      public String getEngineMaxThreads()

    • setEngineMinThreads

      public void setEngineMinThreads(String minThreads)
      Parameters:
      minThreads -

    • getEngineMinThreads

      public String getEngineMinThreads()

    • setDCacheConfigName

      public void setDCacheConfigName(String dCacheConfigName)
      Parameters:
      dCacheConfigName -

    • getDCacheConfigName

      public String getDCacheConfigName()

    • setNotifyRetries

      public void setNotifyRetries(String notifyRetries)
      Parameters:
      notifyRetries -

    • getNotifyRetries

      public String getNotifyRetries()

    • setConnectionRetries

      public void setConnectionRetries(String connectionRetries)

    • getConnectionRetries

      public String getConnectionRetries()

    • setBlobstoreRocksDBAllowDuplicateUIDs

      public void setBlobstoreRocksDBAllowDuplicateUIDs(String isEnabled)

    • setSerializationType

      public void setSerializationType(int serializationType)
      Parameters:
      serializationType -

    • getSerializationType

      public int getSerializationType()

    • isPrivate

      public boolean isPrivate()

    • setPrivate

      public void setPrivate(boolean isPrivate)
      Parameters:
      isPrivate -

    • setExpirationTimeInterval

      public void setExpirationTimeInterval(String expirationTimeInterval)
      Parameters:
      expirationTimeInterval -

    • getExpirationTimeInterval

      public String getExpirationTimeInterval()

    • setExpirationTimeRecentDeletes

      public void setExpirationTimeRecentDeletes(String expirationTimeRecentDeletes)

    • getExpirationTimeRecentDeletes

      public String getExpirationTimeRecentDeletes()

    • setExpirationTimeRecentUpdate

      public void setExpirationTimeRecentUpdate(String expirationTimeRecentUpdates)

    • getExpirationTimeRecentUpdates

      public String getExpirationTimeRecentUpdates()

    • setExpirationStaleReplicas

      public void setExpirationStaleReplicas(String expirationStaleReplicas)

    • getExpirationStaleReplicas

      public String getExpirationStaleReplicas()

    • setSpaceState

      public void setSpaceState(String spaceState)
      Parameters:
      spaceState -

    • getSpaceState

      public String getSpaceState()

    • setSchemaName

      public void setSchemaName(String schemaName)
      Parameters:
      schemaName -

    • getSchemaName

      public String getSchemaName()

    • setLoadOnStartup

      public void setLoadOnStartup(boolean isLoadOnStartup)
      Parameters:
      isLoadOnStartup -

    • isLoadOnStartup

      public boolean isLoadOnStartup()

    • setCacheManagerSize

      public void setCacheManagerSize(String cacheManagerSize)
      Parameters:
      cacheManagerSize -

    • getCacheManagerSize

      public String getCacheManagerSize()
      max cache size

    • setCachePolicy

      public void setCachePolicy(String cachePolicy)
      Parameters:
      cachePolicy -

    • getCachePolicy

      public String getCachePolicy()

    • isClustered

      public boolean isClustered()

    • setClustered

      public void setClustered(boolean isClustered)
      Parameters:
      isClustered -

    • setClusterConfigURL

      public void setClusterConfigURL(String clusterConfigURL)
      Parameters:
      clusterConfigURL -

    • getClusterConfigURL

      public String getClusterConfigURL()

    • setCustomProperties

      public void setCustomProperties(Properties customProperties)
      Parameters:
      customProperties -

    • getCustomProperties

      public Properties getCustomProperties()

    • setFiltersInfo

      public void setFiltersInfo(FiltersInfo[] filtersInfo)
      Parameters:
      filtersInfo -

    • setFilterInfoAt

      public void setFilterInfoAt(FiltersInfo filterInfo, int index)
      Parameters:
      filterInfo -
      index -

    • getFiltersInfo

      public FiltersInfo[] getFiltersInfo()

    • setClusterPolicy

      public void setClusterPolicy(ClusterPolicy clusterPolicy)
      Parameters:
      clusterPolicy -

    • getClusterPolicy

      public ClusterPolicy getClusterPolicy()

    • setDCacheProperties

      public void setDCacheProperties(JSpaceAttributes dCacheProperties)
      Parameters:
      dCacheProperties -

    • getDCacheProperties

      public JSpaceAttributes getDCacheProperties()

    • isMirrorServiceEnabled

      public boolean isMirrorServiceEnabled()
      Is mirror service
      Returns:
      true if the space has a mirror service enabled, otherwise false returned

    • setMirrorServiceEnabled

      public void setMirrorServiceEnabled(boolean isMirrorServiceEnabled)
      Set mirror service enabled.
      Parameters:
      isMirrorServiceEnabled - true if the space has a mirror service enabled, otherwise false returned

    • setMaxClassLoaders

      public void setMaxClassLoaders(int maxClassLoaders)

    • getMaxClassLoaders

      public String getMaxClassLoaders()

    • setSupportCodeChange

      public void setSupportCodeChange(boolean enableTaskReloading)

    • getSupportCodeChange

      public String getSupportCodeChange()

    • getDataSourceClass

      public String getDataSourceClass()

    • getSpaceInstanceConfig

      public SpaceInstanceConfig getSpaceInstanceConfig()

    • getCustomComponents

      public Map<String,SpaceCustomComponent> getCustomComponents()

    • getSpaceDataSourceInstance

      public SpaceDataSource getSpaceDataSourceInstance()

    • getSpaceDataSourceClassName

      public String getSpaceDataSourceClassName()

    • getSynchronizationEndpointInstance

      public SpaceSynchronizationEndpoint getSynchronizationEndpointInstance()

    • getSynchronizationEndpointClassName

      public String getSynchronizationEndpointClassName()

    • setDataSourceClass

      public void setDataSourceClass(String className)
      Parameters:
      className -

    • getDataPropertiesFile

      public String getDataPropertiesFile()

    • setDataPropertiesFile

      public void setDataPropertiesFile(String propertiesFile)
      Parameters:
      propertiesFile -

    • getDataClass

      public String getDataClass()

    • getQueryBuilderClass

      public String getQueryBuilderClass()

    • setQueryBuilderClass

      public void setQueryBuilderClass(String className)
      Parameters:
      className -

    • setDataClass

      public void setDataClass(String className)
      Parameters:
      className -

    • getUsage

      public String getUsage()
      usage

    • setUsage

      public void setUsage(String usage)
      Set data source usage

    • isSupportsInheritanceEnabled

      public boolean isSupportsInheritanceEnabled()
      supports-inheritance
      Returns:
      true if the data source support inheritance , otherwise false returned

    • setSupportsInheritanceEnabled

      public void setSupportsInheritanceEnabled(boolean isSupportsInheritanceEnabled)
      Set supports-inheritance
      Parameters:
      isSupportsInheritanceEnabled - true if the data source supports inheritance, otherwise false returned

    • isSupportsVersionEnabled

      public boolean isSupportsVersionEnabled()
      supports-version
      Returns:
      true if the data source support version, otherwise false returned

    • setSupportsVersionEnabled

      public void setSupportsVersionEnabled(boolean isSupportsVersionEnabled)
      Set supports-version
      Parameters:
      isSupportsVersionEnabled - true if the data source supports version, otherwise false returned

    • isSupportsPartialUpdateEnabled

      public boolean isSupportsPartialUpdateEnabled()

    • setSupportsPartialUpdateEnabled

      public void setSupportsPartialUpdateEnabled(boolean isSupportsPartialUpdateEnabled)

    • isSupportsRemoveByIdEnabled

      public boolean isSupportsRemoveByIdEnabled()

    • setSupportsRemoveByIdEnabled

      public void setSupportsRemoveByIdEnabled(boolean isSupportsRemoveByIdEnabled)

    • getDataSourceSharedIteratorMode

      public boolean getDataSourceSharedIteratorMode()
      Gets shared iterator mode
      Returns:
      true if the data source should be wrapped with a shared iterator decorator which optimize concurrent read access for SQLDataProvider data sources

    • setDataSourceSharedIteratorMode

      public void setDataSourceSharedIteratorMode(boolean enabled)
      Set shared iterator mode
      Parameters:
      enabled - true if the data source should be wrapped with a shared iterator decorator which optimize concurrent read access for SQLDataProvider data sources

    • getDataSourceSharedIteratorTimeToLive

      public long getDataSourceSharedIteratorTimeToLive()
      Get shared iterator time to live
      Returns:
      time to live in miliseconds of a shared data iterator, once it has expired the iterator will no longer be shared by new requests

    • setDataSourceSharedIteratorTimeToLive

      public void setDataSourceSharedIteratorTimeToLive(long timeToLive)
      Set shared iterator time to live
      Parameters:
      timeToLive - time to live in miliseconds of a shared data iterator, once it has expired the iterator will no longer be shared by new requests

    • getProxyConnectionMode

      public String getProxyConnectionMode()

    • setProxyConnectionMode

      public void setProxyConnectionMode(String connectionMode)

    • getProxyMonitorFrequency

      public long getProxyMonitorFrequency()

    • setProxyMonitorFrequency

      public void setProxyMonitorFrequency(long frequency)

    • getProxyDetectorFrequency

      public long getProxyDetectorFrequency()

    • setProxyDetectorFrequency

      public void setProxyDetectorFrequency(long frequency)

    • getProxyConnectionRetries

      public int getProxyConnectionRetries()

    • setProxyConnectionRetries

      public void setProxyConnectionRetries(int connectionRetries)

    • isTieredStorageCachePolicy

      public boolean isTieredStorageCachePolicy()

    • getTieredStorageConfig

      public TieredStorageConfig getTieredStorageConfig()

    • getBlobStoreCapacityGB

      @Deprecated public int getBlobStoreCapacityGB()
      Deprecated.
      Use instead all blobstore properties is located inside.

    • getBlobStoreCacheCapacityMB

      @Deprecated public int getBlobStoreCacheCapacityMB()
      Deprecated.
      Use instead all blobstore properties is located inside.

    • getBlobStoreDevices

      @Deprecated public String getBlobStoreDevices()
      Deprecated.
      Use instead all blobstore properties is located inside.

    • getBlobStoreVolumeDir

      @Deprecated public String getBlobStoreVolumeDir()
      Deprecated.

    • getBlobStoreDurabilityLevel

      @Deprecated public String getBlobStoreDurabilityLevel()
      Deprecated.
      Use instead all blobstore properties is located inside.

    • isBlobstorePersistent

      @Deprecated public boolean isBlobstorePersistent()
      Deprecated.
      Use instead all blobstore properties is located inside.

    • getBlobStoreCacheSize

      @Deprecated public int getBlobStoreCacheSize()
      Deprecated.
      Use instead all blobstore properties is located inside.

    • getBlobStoreProperties

      public Properties getBlobStoreProperties()
      Gets all blobstore properties from blobstore driver and the cache manager.}

    • setBlobStoreProperties

      public void setBlobStoreProperties(Properties blobstoreProperties)

    • getZookeeperConnectionTimeout

      public int getZookeeperConnectionTimeout()

    • setZookeeperConnectionTimeout

      public void setZookeeperConnectionTimeout(long connectionTimeout)

    • getZookeeperSessionTimeout

      public int getZookeeperSessionTimeout()

    • setZookeeperSessionTimeout

      public void setZookeeperSessionTimeout(long sessionTimeout)

    • getZookeeperRetryTimeout

      public int getZookeeperRetryTimeout()

    • setZookeeperRetryTimeout

      public void setZookeeperRetryTimeout(long retryTimeout)

    • getZookeeperRetryInterval

      public int getZookeeperRetryInterval()

    • setZookeeperRetryInterval

      public void setZookeeperRetryInterval(long retryInterval)

    • isMvccEnabled

      public boolean isMvccEnabled()

    • setMvccEnabled

      public void setMvccEnabled(boolean isMvccEnabled)

    • getMvccHistoricalEntryLifetime

      public long getMvccHistoricalEntryLifetime()

    • setMvccHistoricalEntryLifetime

      public void setMvccHistoricalEntryLifetime(int entryLifetime)

    • getMvccHistoricalEntryLifetimeTimeUnit

      public TimeUnit getMvccHistoricalEntryLifetimeTimeUnit()

    • setMvccHistoricalEntryLifetimeTimeUnit

      public void setMvccHistoricalEntryLifetimeTimeUnit(String entryLifetimeTimeUnit)
      Validate that timeUnit is in supported format and set if timeunit is not valid -> throw IllegalArgumentException
      Parameters:
      entryLifetimeTimeUnit - - can not be null

    • getMvccHistoricalEntriesLimit

      public int getMvccHistoricalEntriesLimit()

    • setMvccHistoricalEntriesLimit

      public void setMvccHistoricalEntriesLimit(int historicalEntriesLimit)
      Validate that limit is not less than 1 - It is the minimal allowed limit(keep in history at least latest generation)
      If limit is not valid -> throw IllegalArgumentException

    • getMvccFixedCleanupDelayMillis

      public long getMvccFixedCleanupDelayMillis()

    • setMvccFixedCleanupDelayMillis

      public void setMvccFixedCleanupDelayMillis(int fixedCleanupDelayMillis)

    • clear

      public void clear()
      Clears all properties held, including defaults, custom properties, and dcache properties.
      Specified by:
      clear in interface Map<Object,Object>
      Overrides:
      clear in class Properties

    • getClusterInfo

      public SpaceClusterInfo getClusterInfo()

    • setClusterInfo

      public void setClusterInfo(SpaceClusterInfo newClusterInfo)

    • cloneAndUpdate

      public SpaceConfig cloneAndUpdate(ClusterTopology chunksMap)

    • readExternal

      public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
      Specified by:
      readExternal in interface Externalizable
      Throws:
      IOException
      ClassNotFoundException

    • writeExternal

      public void writeExternal(ObjectOutput out) throws IOException
      Specified by:
      writeExternal in interface Externalizable
      Throws:
      IOException