Skip to content
Open
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -426,8 +426,9 @@ public void setVersion(long ver) {

cfg.setDiscoverySpi(discoSpi);

cfg.setCacheConfiguration(generalRegionConfiguration(DEFAULT_UPDATE_TIMESTAMPS_REGION_UNQUALIFIED_NAME),
generalRegionConfiguration(DEFAULT_QUERY_RESULTS_REGION_UNQUALIFIED_NAME),
cfg.setCacheConfiguration(
transactionalRegionConfiguration(DEFAULT_UPDATE_TIMESTAMPS_REGION_UNQUALIFIED_NAME),
transactionalRegionConfiguration(DEFAULT_QUERY_RESULTS_REGION_UNQUALIFIED_NAME),
transactionalRegionConfiguration(ENTITY_NAME),
transactionalRegionConfiguration(ENTITY2_NAME),
transactionalRegionConfiguration(VERSIONED_ENTITY_NAME),
Expand All @@ -440,30 +441,6 @@ public void setVersion(long ver) {
return cfg;
}

/**
* @param regionName Region name.
* @return Cache configuration for {@link IgniteGeneralDataRegion}.
*/
private CacheConfiguration generalRegionConfiguration(String regionName) {
CacheConfiguration cfg = new CacheConfiguration();

cfg.setName(regionName);

cfg.setCacheMode(PARTITIONED);

cfg.setAtomicityMode(ATOMIC);

cfg.setWriteSynchronizationMode(FULL_SYNC);

cfg.setBackups(1);

cfg.setStatisticsEnabled(true);

//cfg.setAffinity(new RendezvousAffinityFunction(false, 10));

return cfg;
}

/**
* @param regionName Region name.
* @return Transactional Cache configuration
Expand Down