本文整理了Java中org.apache.geode.cache.RegionAttributes.getIndexMaintenanceSynchronous
方法的一些代码示例,展示了RegionAttributes.getIndexMaintenanceSynchronous
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。RegionAttributes.getIndexMaintenanceSynchronous
方法的具体详情如下:
包路径:org.apache.geode.cache.RegionAttributes
类名称:RegionAttributes
方法名:getIndexMaintenanceSynchronous
[英]Returns the value of IndexMaintenanceSynchronous
which specifies whether the region indexes are updated synchronously when a region is modified or asynchronously in a background thread. Default value is true.
[中]返回IndexMaintenanceSynchronous
的值,该值指定在后台线程中修改区域时是同步更新区域索引,还是异步更新区域索引。默认值为true。
代码示例来源:origin: apache/geode
/**
* Constructor for partitioned indexed. Creates the partitioned index on given a partitioned
* region. An index can be created programmatically or through cache.xml during initialization.
*/
public PartitionedIndex(InternalCache cache, IndexType iType, String indexName, Region r,
String indexedExpression, String fromClause, String imports) {
super(cache, indexName, r, fromClause, indexedExpression, null, fromClause, indexedExpression,
null, null);
this.type = iType;
this.imports = imports;
if (iType == IndexType.HASH) {
if (!getRegion().getAttributes().getIndexMaintenanceSynchronous()) {
throw new UnsupportedOperationException(
"Hash index is currently not supported for regions with Asynchronous index maintenance.");
}
}
}
代码示例来源:origin: apache/geode
if (!getRegion().getAttributes().getIndexMaintenanceSynchronous()) {
return false;
代码示例来源:origin: apache/geode
"ConcurrencyChecksEnabled is not the same");
if (this.indexMaintenanceSynchronous != other.getIndexMaintenanceSynchronous()) {
throw new RuntimeException(
"Index Maintenance Synchronous is not the same");
代码示例来源:origin: apache/geode
public IndexManager(InternalCache cache, Region region) {
this.cache = cache;
this.region = region;
// must be a SortedMap to ensure the indexes are iterated over in fixed
// order
// to avoid deadlocks when acquiring locks
// indexes = Collections.synchronizedSortedMap(new TreeMap());
indexMaintenanceSynchronous = region.getAttributes().getIndexMaintenanceSynchronous();
isOverFlowToDisk =
region.getAttributes().getEvictionAttributes().getAction().isOverflowToDisk();
this.offHeap = region.getAttributes().getOffHeap();
if (!indexMaintenanceSynchronous) {
updater = new IndexUpdaterThread(this.INDEX_MAINTENANCE_BUFFER,
"OqlIndexUpdater:" + region.getFullPath());
updater.start();
}
}
代码示例来源:origin: apache/geode
enableSubscriptionConflation = ra.getEnableSubscriptionConflation();
ignoreJTA = ra.getIgnoreJTA();
indexMaintenanceSynchronous = ra.getIndexMaintenanceSynchronous();
initialCapacity = ra.getInitialCapacity();
loadFactor = ra.getLoadFactor();
代码示例来源:origin: apache/geode
boolean multicastEnabled = regAttrs.getMulticastEnabled();
int concurrencyLevel = regAttrs.getConcurrencyLevel();
boolean indexMaintenanceSynchronous = regAttrs.getIndexMaintenanceSynchronous();
boolean statisticsEnabled = regAttrs.getStatisticsEnabled();
代码示例来源:origin: apache/geode
this.indexMaintenanceSynchronous = attrs.getIndexMaintenanceSynchronous();
this.partitionAttributes = attrs.getPartitionAttributes();
this.membershipAttributes = attrs.getMembershipAttributes();
代码示例来源:origin: apache/geode
this.publisher = attrs.getPublisher();
this.enableAsyncConflation = attrs.getEnableAsyncConflation();
this.indexMaintenanceSynchronous = attrs.getIndexMaintenanceSynchronous();
this.mcastEnabled = attrs.getMulticastEnabled();
this.partitionAttributes = attrs.getPartitionAttributes();
代码示例来源:origin: apache/geode
regionAttributes.getIndexMaintenanceSynchronous();
this.regionAttributes.partitionAttributes = regionAttributes.getPartitionAttributes();
this.regionAttributes.evictionAttributes =
代码示例来源:origin: apache/geode
if (parentIsUserSpecified) {
if (parentWithHas.hasIndexMaintenanceSynchronous()) {
setIndexMaintenanceSynchronous(parent.getIndexMaintenanceSynchronous());
setIndexMaintenanceSynchronous(parent.getIndexMaintenanceSynchronous());
代码示例来源:origin: org.springframework.data/spring-data-geode-test
when(mockRegionAttributes.getGatewaySenderIds()).thenReturn(gatewaySenderIds);
when(mockRegionAttributes.getIgnoreJTA()).thenAnswer(newGetter(ignoreJta));
when(mockRegionAttributes.getIndexMaintenanceSynchronous()).thenAnswer(newGetter(indexMaintenanceSynchronous));
when(mockRegionAttributes.getInitialCapacity()).thenAnswer(newGetter(initialCapacity));
when(mockRegionAttributes.getKeyConstraint()).thenAnswer(newGetter(keyConstraint));
代码示例来源:origin: org.springframework.data/spring-data-geode-test
when(mockRegionAttributes.getIndexMaintenanceSynchronous()).thenAnswer(newGetter(baseRegionAttributes::getIndexMaintenanceSynchronous));
when(mockRegionAttributes.getInitialCapacity()).thenAnswer(newGetter(baseRegionAttributes::getInitialCapacity));
when(mockRegionAttributes.getKeyConstraint()).thenAnswer(newGetter(baseRegionAttributes::getKeyConstraint));
代码示例来源:origin: org.springframework.data/spring-data-geode
regionFactory.setIndexMaintenanceSynchronous(regionAttributes.getIndexMaintenanceSynchronous());
regionFactory.setInitialCapacity(regionAttributes.getInitialCapacity());
regionFactory.setKeyConstraint(regionAttributes.getKeyConstraint());
代码示例来源:origin: org.springframework.data/spring-data-gemfire
regionFactory.setIndexMaintenanceSynchronous(regionAttributes.getIndexMaintenanceSynchronous());
regionFactory.setInitialCapacity(regionAttributes.getInitialCapacity());
regionFactory.setKeyConstraint(regionAttributes.getKeyConstraint());
内容来源于网络,如有侵权,请联系作者删除!