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

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

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

RegionAttributes.getRegionTimeToLive介绍

[英]Gets the timeToLive expiration attributes for the region as a whole. Default is 0 which indicates that no expiration of this type will happen.
[中]获取整个区域的timeToLive过期属性。默认值为0，表示不会发生此类型的过期。

代码示例

代码示例来源：origin: apache/geode

@Override
public ExpirationAction getRegionTimeToLiveAction() {
 return this.ra.getRegionTimeToLive().getAction();
}

代码示例来源：origin: apache/geode

@Override
public int getRegionTimeToLiveTimeLimit() {
 return this.ra.getRegionTimeToLive().getTimeout();
}

代码示例来源：origin: apache/geode

private void validateExpirationAttributes(final RegionAttributes userRA,
  final PartitionRegionConfig prconf) {
 if (!userRA.getRegionIdleTimeout().equals(prconf.getRegionIdleTimeout())) {
  throw new IllegalStateException(
    String.format(
      "The %1$s set in RegionAttributes is incompatible with %1$s used by other distributed members.",
      new Object[] {" region idle timout "}));
 }
 if (!userRA.getRegionTimeToLive().equals(prconf.getRegionTimeToLive())) {
  throw new IllegalStateException(
    String.format(
      "The %1$s set in RegionAttributes is incompatible with %1$s used by other distributed members.",
      new Object[] {" region time to live "}));
 }
 if (!userRA.getEntryIdleTimeout().equals(prconf.getEntryIdleTimeout())) {
  throw new IllegalStateException(
    String.format(
      "The %1$s set in RegionAttributes is incompatible with %1$s used by other distributed members.",
      new Object[] {" entry idle timout "}));
 }
 if (!userRA.getEntryTimeToLive().equals(prconf.getEntryTimeToLive())) {
  throw new IllegalStateException(
    String.format(
      "The %1$s set in RegionAttributes is incompatible with %1$s used by other distributed members.",
      new Object[] {" entry time to live "}));
 }
}

代码示例来源：origin: apache/geode

private PartitionAttributes initializeAttributes(final Cache cache) {
 PartitionAttributes partitionAttributes = mock(PartitionAttributes.class);
 RegionAttributes attributes = mock(RegionAttributes.class);
 when(attributes.getCacheListeners()).thenReturn(new CacheListener[0]);
 when(attributes.getRegionTimeToLive()).thenReturn(ExpirationAttributes.DEFAULT);
 when(attributes.getRegionIdleTimeout()).thenReturn(ExpirationAttributes.DEFAULT);
 when(attributes.getEntryTimeToLive()).thenReturn(ExpirationAttributes.DEFAULT);
 when(attributes.getEntryIdleTimeout()).thenReturn(ExpirationAttributes.DEFAULT);
 when(attributes.getMembershipAttributes()).thenReturn(new MembershipAttributes());
 when(cache.getRegionAttributes(RegionShortcut.PARTITION.toString())).thenReturn(attributes);
 when(partitionAttributes.getTotalNumBuckets()).thenReturn(113);
 return partitionAttributes;
}

代码示例来源：origin: apache/geode

allRegionTtl.add(ra.getRegionTimeToLive());
allEntryTtl.add(ra.getEntryTimeToLive());
allCustomTtl.add(ra.getCustomEntryTimeToLive().toString());

代码示例来源：origin: apache/geode

when(regionAttributes.getRegionTimeToLive()).thenReturn(expirationAttributes);
when(regionAttributes.getRegionIdleTimeout()).thenReturn(expirationAttributes);
when(regionAttributes.getEntryTimeToLive()).thenReturn(expirationAttributes);

代码示例来源：origin: apache/geode

entryIdleTimeout = ra.getEntryIdleTimeout().getTimeout();
regionIdleTimeout = ra.getRegionIdleTimeout().getTimeout();
regionTimeToLive = ra.getRegionTimeToLive().getTimeout();
expAction = ra.getRegionTimeToLive().getAction();

代码示例来源：origin: apache/geode

|| attrs.getRegionTimeToLive().getAction() == ExpirationAction.LOCAL_INVALIDATE) {
   throw new IllegalStateException(
     "ExpirationAction.LOCAL_INVALIDATE on the region is incompatible with distributed replication");
if (!attrs.getStatisticsEnabled() && (attrs.getRegionTimeToLive().getTimeout() != 0
  || attrs.getRegionIdleTimeout().getTimeout() != 0
  || attrs.getEntryTimeToLive().getTimeout() != 0
   .validateWhenAllAttributesAreSet(attrs instanceof RegionAttributesCreation);
 ExpirationAttributes regionIdleTimeout = attrs.getRegionIdleTimeout();
 ExpirationAttributes regionTimeToLive = attrs.getRegionTimeToLive();
 AbstractRegion.validatePRRegionExpirationAttributes(regionIdleTimeout);
 AbstractRegion.validatePRRegionExpirationAttributes(regionTimeToLive);

代码示例来源：origin: apache/geode

int regionTimeToLive = regAttrs.getRegionTimeToLive().getTimeout();
int regionIdleTimeout = regAttrs.getRegionIdleTimeout().getTimeout();
int entryTimeToLive = regAttrs.getEntryTimeToLive().getTimeout();

代码示例来源：origin: apache/geode

if (generateDefaults() || !attrs.getRegionTimeToLive().equals(ExpirationAttributes.DEFAULT))
 generate(REGION_TIME_TO_LIVE, attrs.getRegionTimeToLive(), null);

代码示例来源：origin: apache/geode

prConfig = new PartitionRegionConfig(this.partitionedRegionId, this.getFullPath(),
  prAttribs, this.getScope(), getAttributes().getEvictionAttributes(),
  getAttributes().getRegionIdleTimeout(), getAttributes().getRegionTimeToLive(),
  getAttributes().getEntryIdleTimeout(), getAttributes().getEntryTimeToLive(),
  this.getAllGatewaySenderIds());

代码示例来源：origin: apache/geode

this.loadFactor = attrs.getLoadFactor();
this.regionIdleTimeout = attrs.getRegionIdleTimeout();
this.regionTimeToLive = attrs.getRegionTimeToLive();
this.scope = attrs.getScope();
this.statisticsEnabled = attrs.getStatisticsEnabled();

代码示例来源：origin: apache/geode

this.regionAttributes.regionTimeToLive = regionAttributes.getRegionTimeToLive().getTimeout();
this.regionAttributes.regionTimeToLiveExpirationAction =
  regionAttributes.getRegionTimeToLive().getAction();
this.regionAttributes.regionIdleTimeout = regionAttributes.getRegionIdleTimeout().getTimeout();
this.regionAttributes.regionIdleTimeoutExpirationAction =

代码示例来源：origin: apache/geode

assignCacheLoader(attrs.getCacheLoader());
assignCacheWriter(attrs.getCacheWriter());
this.regionTimeToLive = attrs.getRegionTimeToLive().getTimeout();
this.regionTimeToLiveExpirationAction = attrs.getRegionTimeToLive().getAction();
setRegionTimeToLiveAtts();
this.regionIdleTimeout = attrs.getRegionIdleTimeout().getTimeout();

代码示例来源：origin: apache/geode

factory.setRegionIdleTimeout(ea);
ea = this.partitionedRegion.getAttributes().getRegionTimeToLive();
if (ea != null) {
 if (ea.getAction() != ExpirationAction.DESTROY)

代码示例来源：origin: apache/geode

this.keyConstraint = attr.getKeyConstraint();
this.valueConstraint = attr.getValueConstraint();
this.rTtl = attr.getRegionTimeToLive();
this.rIdleTimeout = attr.getRegionIdleTimeout();
this.eTtl = attr.getEntryTimeToLive();

代码示例来源：origin: apache/geode

assertNull(attrs.getCacheListener());
assertEquals(Arrays.asList(new CacheListener[0]), Arrays.asList(attrs.getCacheListeners()));
assertEquals(0, attrs.getRegionTimeToLive().getTimeout());
assertEquals(0, attrs.getRegionIdleTimeout().getTimeout());
assertEquals(0, attrs.getEntryTimeToLive().getTimeout());

代码示例来源：origin: apache/geode

if (parentIsUserSpecified) {
 if (parentWithHas.hasRegionTimeToLive()) {
  setRegionTimeToLive(parent.getRegionTimeToLive());
 setRegionTimeToLive(parent.getRegionTimeToLive());

代码示例来源：origin: org.springframework.data/spring-data-geode

private Optional<String> configureWithRegionAttributes(ClientRegionFactory<K, V> clientRegionFactory) {
  AtomicReference<String> regionAttributesPoolName = new AtomicReference<>(null);
  Optional.ofNullable(getAttributes()).ifPresent(regionAttributes -> {
    regionAttributesPoolName.set(regionAttributes.getPoolName());
    stream(nullSafeArray(regionAttributes.getCacheListeners(), CacheListener.class))
      .forEach(clientRegionFactory::addCacheListener);
    clientRegionFactory.setCloningEnabled(regionAttributes.getCloningEnabled());
    clientRegionFactory.setCompressor(regionAttributes.getCompressor());
    clientRegionFactory.setConcurrencyChecksEnabled(regionAttributes.getConcurrencyChecksEnabled());
    clientRegionFactory.setConcurrencyLevel(regionAttributes.getConcurrencyLevel());
    clientRegionFactory.setCustomEntryIdleTimeout(regionAttributes.getCustomEntryIdleTimeout());
    clientRegionFactory.setCustomEntryTimeToLive(regionAttributes.getCustomEntryTimeToLive());
    clientRegionFactory.setDiskStoreName(regionAttributes.getDiskStoreName());
    clientRegionFactory.setDiskSynchronous(regionAttributes.isDiskSynchronous());
    clientRegionFactory.setEntryIdleTimeout(regionAttributes.getEntryIdleTimeout());
    clientRegionFactory.setEntryTimeToLive(regionAttributes.getEntryTimeToLive());
    clientRegionFactory.setEvictionAttributes(regionAttributes.getEvictionAttributes());
    clientRegionFactory.setInitialCapacity(regionAttributes.getInitialCapacity());
    clientRegionFactory.setKeyConstraint(regionAttributes.getKeyConstraint());
    clientRegionFactory.setLoadFactor(regionAttributes.getLoadFactor());
    clientRegionFactory.setRegionIdleTimeout(regionAttributes.getRegionIdleTimeout());
    clientRegionFactory.setRegionTimeToLive(regionAttributes.getRegionTimeToLive());
    clientRegionFactory.setStatisticsEnabled(regionAttributes.getStatisticsEnabled());
    clientRegionFactory.setValueConstraint(regionAttributes.getValueConstraint());
  });
  return Optional.ofNullable(regionAttributesPoolName.get()).filter(StringUtils::hasText);
}

代码示例来源：origin: org.springframework.data/spring-data-gemfire

private Optional<String> configureWithRegionAttributes(ClientRegionFactory<K, V> clientRegionFactory) {
  AtomicReference<String> regionAttributesPoolName = new AtomicReference<>(null);
  Optional.ofNullable(getAttributes()).ifPresent(regionAttributes -> {
    regionAttributesPoolName.set(regionAttributes.getPoolName());
    stream(nullSafeArray(regionAttributes.getCacheListeners(), CacheListener.class))
      .forEach(clientRegionFactory::addCacheListener);
    clientRegionFactory.setCloningEnabled(regionAttributes.getCloningEnabled());
    clientRegionFactory.setCompressor(regionAttributes.getCompressor());
    clientRegionFactory.setConcurrencyChecksEnabled(regionAttributes.getConcurrencyChecksEnabled());
    clientRegionFactory.setConcurrencyLevel(regionAttributes.getConcurrencyLevel());
    clientRegionFactory.setCustomEntryIdleTimeout(regionAttributes.getCustomEntryIdleTimeout());
    clientRegionFactory.setCustomEntryTimeToLive(regionAttributes.getCustomEntryTimeToLive());
    clientRegionFactory.setDiskStoreName(regionAttributes.getDiskStoreName());
    clientRegionFactory.setDiskSynchronous(regionAttributes.isDiskSynchronous());
    clientRegionFactory.setEntryIdleTimeout(regionAttributes.getEntryIdleTimeout());
    clientRegionFactory.setEntryTimeToLive(regionAttributes.getEntryTimeToLive());
    clientRegionFactory.setEvictionAttributes(regionAttributes.getEvictionAttributes());
    clientRegionFactory.setInitialCapacity(regionAttributes.getInitialCapacity());
    clientRegionFactory.setKeyConstraint(regionAttributes.getKeyConstraint());
    clientRegionFactory.setLoadFactor(regionAttributes.getLoadFactor());
    clientRegionFactory.setRegionIdleTimeout(regionAttributes.getRegionIdleTimeout());
    clientRegionFactory.setRegionTimeToLive(regionAttributes.getRegionTimeToLive());
    clientRegionFactory.setStatisticsEnabled(regionAttributes.getStatisticsEnabled());
    clientRegionFactory.setValueConstraint(regionAttributes.getValueConstraint());
  });
  return Optional.ofNullable(regionAttributesPoolName.get()).filter(StringUtils::hasText);
}

内容来源于网络，如有侵权，请联系作者删除！

RegionAttributes

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    RegionAttributes类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com