Advanced Topics
This sections covers advanced options related to Space Where GigaSpaces data is stored. It is the logical cache that holds data objects in memory and might also hold them in layered in tiering. Data is hosted from multiple SoRs, consolidated as a unified data model. Persistency.
Properties
Here are the Space Persistency Properties:
Property | Description | Default |
---|---|---|
space-config.external-data-source.shared-iterator.enabled | This attribute enables shared iterator mode which tries to optimize data source access by sharing the same iterator for the same query operations when possible. | true |
space-config.external-data-source.shared-iterator.time-to-live | This attribute specify for how long in milliseconds an iterator can be shared in shared iterator mode. If two equivalent queries are done concurrently, but the time that elapsed between the first query and the second query exceeds the time to live, the second query will open a new iterator on the data source and will not share the first one. | 10000 |
space-config.external-data-source.init-properties-file | This properties file content is passed directly to the data source implementation in the init() method. This file can be used to pass any custom parameters to the data source. |
|
cluster-config.cache-loader.external-data-source | Provides cluster-wide support. | true |
cluster-config.cache-loader.central-data-source | Provides clustered database wide support. | true |
Troubleshooting
To enable Space Persistency logging, edit the $GS_HOME\config\log\xap_logging.properties
file, and set the persistent level to CONFIG
or FINER
.
CONFIG
messages are intended to provide a variety of static configuration information, and to assist in debugging problems that may be associated with particular configurations.
com.gigaspaces.persistent.level = CONFIG
FINER
messages log calls for entering, returning, or throwing an exception to and from the cache interface implementations.
com.gigaspaces.persistent.level = FINER
Initial Space Load
When the space is started, restarted, or cleaned, the system can initially fill the space with space objects that are likely to be required by the application. You can specify the data to loaded using the ExternalDataSource.initialLoad
method that is called once the space is started. See the Space Persistency Initial Load for details. The space is not available for clients, until the data load process has been completed.
The Initial Load is supported with the partitioned
cluster schema. If you would like to pre-load a clustered space using the Initial-Load without running backups set ZERO as the amount of backups.
Refreshing Space Object when using a space data source
In order to refresh a space object, you should remove it from the space using the take
, takeById
, write
with short lease or clear
operations and read it back using the read
or readById
operations. This in turn will load the latest version of the object from the data source (i.e. database) via the SpaceDataSource
implementation back into the space. When having such a scenario you should be aware of the recent deletes mechanism.
The recent deletes mechanism running within the space ensures that there will not be a race condition, if an object is removed from the space and loaded by two or more different threads at the same time. This mechanism prevents the SpaceDataSource
implementation from loading an object that has been removed from the space and after a short time been loaded again (with the same ID) to happen.
In order to allow an object that has been removed to be loaded again into the space you should use one the following options:
- Use only the
SpaceDataSource
extension (read-only mode). Using theSpaceSynchronizationEndpoint
extension turns on the recent deletes mechanism. - Perform the read operation several times (with short sleeps in between) until the object will be loaded into the space (you will not get a null back).
Eliminating Resonance Affect when Using Mirror Service
When using the Mirror Service, and the SpaceDatasource
is enabled for the space, all data loaded into the space using SpaceDataSource.initialDataLoad
while it is being started, is not replicated back to the Mirror Performs the replication of changes to the target table or accumulation of source table changes used to replicate changes to the target table at a later time. If you have implemented bidirectional replication in your environment, mirroring can occur to and from both the source and target tables. Service.
Count Operation
The scope of IJSpace.count()
or GigaSpace.count()
and IMap.Size()
is the data stored within the space. These methods do not take into account the data stored within the underlying data source.
When using the Map API with a local cache, the value of IMap.Size()
is the amount of objects in the local cache (it might be less than what actually exists in the space).
Recursive Calls
The SpaceDataSource
and SpaceSynchronizationEndpoint
implementations should avoid performing space operations to prevent deadlocks and recursive behavior.
UID Generation
The space embeds a unique identifier into each space Object. This ID is used implicitly when performing update operations, and read/take operations based on ID.
If you write an object into the space, or load an object that has a ID that already exists within the space, the operation will be rejected with the exception:com.j_spaces.core.client.EntryAlreadyInSpaceException
. When specifying the SpaceId
field make sure the auto-generate
attribute should be set to false
.
Hibernate ID Generation
Hibernate supports multiple ID generators as detailed in Hibernate documentation. Your hibernate mapping file should use algorithm that is appropriate for your use case.
Some generators increase the number of database operations and result into overall adverse performance. You need to watch out for generators + database combinations that automatically disable the batch insert mode transparently as mentioned here.
"Hibernate disables insert batching at the JDBC Java DataBase Connectivity. This is an application programming interface (API) for the Java programming language, which defines how a client may access a database. level transparently if you use an identity identifier generator."
Using a sequence number increases the database reads on some databases, because Hibernate reads the next sequence number before each new INSERT
in the batch. This also disables batch persistence used by GigaSpaces DefaultHibernateSpaceSynchronizationEndpoint.
A better strategy would be to use a dummy generator like "increment" in hibernate mapping file, on the database side define a INSERT trigger on this table to generate a new id using a sequence. You will see orders of magnitude performance improvement in the database operations making this simple change.
Considerations
- When a space is configured to be persistent, and a
POJO Plain Old Java Object. A regular Java object with no special restrictions other than those forced by the Java Language Specification and does not require any classpath.
is used as the Space Domain class, it must use theSpaceId(autogenerate=false)
decoration. - When running in LRU Last Recently Used.
This is a common caching strategy. It defines the policy to evict elements from the cache to make room for new elements when the cache is full, meaning it discards the least recently used items first. Cache policy the
GigaSpace.count
operation using the data within the space only and does not access the space data source (database) to return the object count. - When a space is configured to be persistent, only Native serialization mode should be used.
- Objects loaded via the
SpaceDataSource.initialDataLoad
can be expired using the@SpaceLeaseExpiration
annotation. See the POJO Support - Advanced page for more details. - When using the Map API, the key must be
Serializable
. - The
SpaceDataSource.initialDataLoad()
loads data into partitioned spaces, by reading all the data into the space and filtering it at the space side. To tune this behavior, you should execute the relevant query from the database on the partition ID, to fetch the relevant result set to load into the space. See the Space Persistency Initial Load for more details. - Hibernate Lazy load is not supported when using the
DefaultHibernateSpaceDataSource
implementation. See Space Object Modeling for more details. - When running in
ALL_IN_CACHE
cache policy mode, optimistic locking is supported - i.e. updates in optimistic locking mode will be rejected, in case the client performs an update with the non-latest version of the entry. The loaded object from the database should include the latest version or the value 1. - When running a local cache, the client cache will be updated using an optimistic locking mode - i.e. updates will include the correct version of the entry.
- Optimistic locking is not supported when running in
LRU
cache policy mode, in case the loaded object does not include data within theSpaceVersion
field. - When running in LRU Cache policy the
engine.initial_load
property should be configured with a small number, to avoid memory shortage in persistent spaces with large data. - Optimal number of connection to database would be number of partitions in the cluster.