org.apache.geode.cache.RegionAttributes.getIndexMaintenanceSynchronous()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(5.4k)|赞(0)|评价(0)|浏览(43)

本文整理了Java中org.apache.geode.cache.RegionAttributes.getIndexMaintenanceSynchronous方法的一些代码示例,展示了RegionAttributes.getIndexMaintenanceSynchronous的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。RegionAttributes.getIndexMaintenanceSynchronous方法的具体详情如下:
包路径:org.apache.geode.cache.RegionAttributes
类名称:RegionAttributes
方法名:getIndexMaintenanceSynchronous

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());

相关文章

微信公众号

最新文章

更多

RegionAttributes类方法