org.joda.time.DateTime.plusSeconds()方法的使用及代码示例

x33g5p2x  于2022-01-17 转载在 其他  
字(18.6k)|赞(0)|评价(0)|浏览(239)

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

DateTime.plusSeconds介绍

[英]Returns a copy of this datetime plus the specified number of seconds.

The calculation will add a duration equivalent to the number of seconds expressed in milliseconds.

The following three lines are identical in effect:

DateTime added = dt.plusSeconds(6); 
DateTime added = dt.plus(Period.seconds(6)); 
DateTime added = dt.withFieldAdded(DurationFieldType.seconds(), 6);

This datetime instance is immutable and unaffected by this method call.
[中]返回此datetime加上指定秒数的副本。
计算将添加一个持续时间,该持续时间等于以毫秒表示的秒数。
以下三行实际上是相同的:

DateTime added = dt.plusSeconds(6); 
DateTime added = dt.plus(Period.seconds(6)); 
DateTime added = dt.withFieldAdded(DurationFieldType.seconds(), 6);

此datetime实例是不可变的,不受此方法调用的影响。

代码示例

代码示例来源:origin: apache/storm

public static DateTime ceil(DateTime dateTime, int sec) {
    long modValue = dateTime.getMillis() % (1000 * sec);
    return dateTime.minus(modValue).plusSeconds(sec);
  }
}

代码示例来源:origin: cloudfoundry/uaa

public Date resolve(String clientId) {
  Integer tokenValiditySeconds = ofNullable(
    clientTokenValidity.getValiditySeconds(clientId)
  ).orElse(
    clientTokenValidity.getZoneValiditySeconds()
  );
  if (tokenValiditySeconds == DEFAULT_TO_GLOBAL_POLICY) {
    tokenValiditySeconds = globalTokenValiditySeconds;
  }
  return new DateTime(timeService.getCurrentTimeMillis()).plusSeconds(tokenValiditySeconds).toDate();
}

代码示例来源:origin: apache/incubator-gobblin

/**
  * Returns a unique {@link Extract} instance.
  * Any two calls of this method from the same {@link ExtractFactory} instance guarantees to
  * return {@link Extract}s with different IDs.
  *
  * @param type {@link TableType}
  * @param namespace dot separated namespace path
  * @param table table name
  * @return a unique {@link Extract} instance
  */
 public synchronized Extract getUniqueExtract(TableType type, String namespace, String table) {
  Extract newExtract = new Extract(type, namespace, table);
  while (this.createdInstances.contains(newExtract)) {
   if (Strings.isNullOrEmpty(newExtract.getExtractId())) {
    newExtract.setExtractId(this.dtf.print(new DateTime()));
   } else {
    DateTime extractDateTime = this.dtf.parseDateTime(newExtract.getExtractId());
    newExtract.setExtractId(this.dtf.print(extractDateTime.plusSeconds(1)));
   }
  }
  this.createdInstances.add(newExtract);
  return newExtract;
 }
}

代码示例来源:origin: apache/incubator-gobblin

/**
 * Create a new properly populated {@link Extract} instance.
 *
 * <p>
 *   This method should always return a new unique {@link Extract} instance.
 * </p>
 *
 * @param type {@link org.apache.gobblin.source.workunit.Extract.TableType}
 * @param namespace namespace of the table this extract belongs to
 * @param table name of the table this extract belongs to
 * @return a new unique {@link Extract} instance
 *
 * @Deprecated Use {@link org.apache.gobblin.source.extractor.extract.AbstractSource#createExtract(
 *org.apache.gobblin.source.workunit.Extract.TableType, String, String)}
 */
@Deprecated
public synchronized Extract createExtract(Extract.TableType type, String namespace, String table) {
 Extract extract = new Extract(this, type, namespace, table);
 while (EXTRACT_SET.contains(extract)) {
  if (Strings.isNullOrEmpty(extract.getExtractId())) {
   extract.setExtractId(DTF.print(new DateTime()));
  } else {
   DateTime extractDateTime = DTF.parseDateTime(extract.getExtractId());
   extract.setExtractId(DTF.print(extractDateTime.plusSeconds(1)));
  }
 }
 EXTRACT_SET.add(extract);
 return extract;
}

代码示例来源:origin: gocd/gocd

private void complete(JobInstance job, DateTime fiveMinsForNow) {
  job.completing(JobResult.Passed, fiveMinsForNow.toDate());
  job.completed(fiveMinsForNow.plusSeconds(10).toDate());
  assignIdsToAllTransitions(job);
}

代码示例来源:origin: kairosdb/kairosdb

break;
case SECONDS:
  ret = new org.joda.time.Duration(dt, dt.plusSeconds((int) sampling.getValue())).getMillis();
  break;
case MILLISECONDS:

代码示例来源:origin: apache/incubator-gobblin

/**
 * Get low water mark
 *
 * @param watermarkType Watermark type
 * @param previousWatermark Previous water mark
 * @param deltaForNextWatermark delta number for next water mark
 * @return Previous watermark (fallback to {@link ConfigurationKeys#SOURCE_QUERYBASED_START_VALUE} iff previous watermark is unavailable)
 */
private long getAppendLowWatermark(WatermarkType watermarkType, long previousWatermark, int deltaForNextWatermark) {
 LOG.debug("Getting append low water mark");
 String timeZone = this.state.getProp(ConfigurationKeys.SOURCE_TIMEZONE);
 if (isPreviousWatermarkExists(previousWatermark)) {
  if (isSimpleWatermark(watermarkType)) {
   return previousWatermark + deltaForNextWatermark;
  }
  DateTime wm =
    Utils.toDateTime(previousWatermark, WATERMARKTIMEFORMAT, timeZone).plusSeconds(deltaForNextWatermark);
  return Long.parseLong(Utils.dateTimeToString(wm, WATERMARKTIMEFORMAT, timeZone));
 }
 LOG.info("Overriding low water mark with start value: " + ConfigurationKeys.SOURCE_QUERYBASED_START_VALUE);
 return Utils.getLongWithCurrentDate(this.state.getProp(ConfigurationKeys.SOURCE_QUERYBASED_START_VALUE), timeZone);
}

代码示例来源:origin: cloudfoundry/uaa

Date notAfter = new DateTime(issueDate).plusSeconds((int) validForSeconds).toDate();
X509v3CertificateBuilder certGen = new JcaX509v3CertificateBuilder(builder.build(),
    serial, issueDate, notAfter, builder.build(), keyPair.getPublic());

代码示例来源:origin: apache/incubator-gobblin

/**
 * Get low water mark
 *
 * @param watermarkType Watermark type
 * @param previousWatermark Previous water mark
 * @param deltaForNextWatermark delta number for next water mark
 * @return Previous watermark (fallback to {@link ConfigurationKeys#SOURCE_QUERYBASED_START_VALUE} iff previous watermark is unavailable)
 */
private long getSnapshotLowWatermark(WatermarkType watermarkType, long previousWatermark, int deltaForNextWatermark) {
 LOG.debug("Getting snapshot low water mark");
 String timeZone = this.state.getProp(ConfigurationKeys.SOURCE_TIMEZONE, ConfigurationKeys.DEFAULT_SOURCE_TIMEZONE);
 if (isPreviousWatermarkExists(previousWatermark)) {
  if (isSimpleWatermark(watermarkType)) {
   return previousWatermark + deltaForNextWatermark - this.state
     .getPropAsInt(ConfigurationKeys.SOURCE_QUERYBASED_LOW_WATERMARK_BACKUP_SECS, 0);
  }
  DateTime wm = Utils.toDateTime(previousWatermark, WATERMARKTIMEFORMAT, timeZone).plusSeconds(
    (deltaForNextWatermark - this.state
      .getPropAsInt(ConfigurationKeys.SOURCE_QUERYBASED_LOW_WATERMARK_BACKUP_SECS, 0)));
  return Long.parseLong(Utils.dateTimeToString(wm, WATERMARKTIMEFORMAT, timeZone));
 }
 // If previous watermark is not found, override with the start value
 // (irrespective of source.is.watermark.override flag)
 long startValue =
   Utils.getLongWithCurrentDate(this.state.getProp(ConfigurationKeys.SOURCE_QUERYBASED_START_VALUE), timeZone);
 LOG.info("Overriding low water mark with the given start value: " + startValue);
 return startValue;
}

代码示例来源:origin: cloudfoundry/uaa

private void buildAssertionConditions(Assertion assertion, int assertionTtlSeconds, String audienceURI) {
  @SuppressWarnings("unchecked")
  SAMLObjectBuilder<Conditions> conditionsBuilder = (SAMLObjectBuilder<Conditions>) builderFactory
      .getBuilder(Conditions.DEFAULT_ELEMENT_NAME);
  Conditions conditions = conditionsBuilder.buildObject();
  conditions.setNotBefore(new DateTime());
  conditions.setNotOnOrAfter(new DateTime().plusSeconds(assertionTtlSeconds));
  @SuppressWarnings("unchecked")
  SAMLObjectBuilder<AudienceRestriction> audienceRestrictionBuilder = (SAMLObjectBuilder<AudienceRestriction>) builderFactory
      .getBuilder(AudienceRestriction.DEFAULT_ELEMENT_NAME);
  AudienceRestriction audienceRestriction = audienceRestrictionBuilder.buildObject();
  @SuppressWarnings("unchecked")
  SAMLObjectBuilder<Audience> audienceBuilder = (SAMLObjectBuilder<Audience>) builderFactory
      .getBuilder(Audience.DEFAULT_ELEMENT_NAME);
  Audience audience = audienceBuilder.buildObject();
  audience.setAudienceURI(audienceURI);
  audienceRestriction.getAudiences().add(audience);
  conditions.getAudienceRestrictions().add(audienceRestriction);
  assertion.setConditions(conditions);
}

代码示例来源:origin: killbill/killbill

@Override
  public Object execute() throws Throwable {
    Assert.assertEquals(subscriptionDao.getSubscriptionBundleForAccount(accountId, internalCallContext).size(), 0);
    Mockito.verify(dbiSpy, Mockito.times(0)).open();
    Mockito.verify(roDbiSpy, Mockito.times(1)).open();
    Assert.assertEquals(subscriptionDao.getSubscriptionBundleForAccount(accountId, internalCallContext).size(), 0);
    Mockito.verify(dbiSpy, Mockito.times(0)).open();
    Mockito.verify(roDbiSpy, Mockito.times(2)).open();
    final String externalKey = UUID.randomUUID().toString();
    final DateTime startDate = clock.getUTCNow();
    final DateTime createdDate = startDate.plusSeconds(10);
    final DefaultSubscriptionBaseBundle bundleDef = new DefaultSubscriptionBaseBundle(externalKey, accountId, startDate, startDate, createdDate, createdDate);
    final SubscriptionBaseBundle bundle = subscriptionDao.createSubscriptionBundle(bundleDef, catalog, false, internalCallContext);
    Mockito.verify(dbiSpy, Mockito.times(1)).open();
    Mockito.verify(roDbiSpy, Mockito.times(2)).open();
    Assert.assertEquals(subscriptionDao.getSubscriptionBundleForAccount(accountId, internalCallContext).size(), 1);
    Mockito.verify(dbiSpy, Mockito.times(2)).open();
    Mockito.verify(roDbiSpy, Mockito.times(2)).open();
    Assert.assertEquals(subscriptionDao.getSubscriptionBundleForAccount(accountId, internalCallContext).size(), 1);
    Mockito.verify(dbiSpy, Mockito.times(3)).open();
    Mockito.verify(roDbiSpy, Mockito.times(2)).open();
    return null;
  }
});

代码示例来源:origin: killbill/killbill

@Test(groups = "slow")
public void testBasic() throws Exception {
  DateTime now = clock.getUTCNow();
  final DateTime initialBootTime1 = clock.getUTCNow().minusDays(1);
  final NodeInfoModelDao node1 = new NodeInfoModelDao(-1L, "node1", initialBootTime1, now, "nodeInfo", true);
  nodeInfoDao.create(node1);
  List<NodeInfoModelDao> all = nodeInfoDao.getAll();
  assertEquals(all.size(), 1);
  assertEquals(all.get(0), node1);
  final DateTime secondBootTime1 = clock.getUTCNow();
  now = clock.getUTCNow().plusSeconds(1);
  final NodeInfoModelDao newNode1 = new NodeInfoModelDao(-1L, "node1", secondBootTime1, now, "nodeInfo", true);
  nodeInfoDao.create(newNode1);
  all = nodeInfoDao.getAll();
  assertEquals(all.size(), 1);
  assertEquals(all.get(0), newNode1);
  final DateTime initialBootTime2 = clock.getUTCNow();
  final NodeInfoModelDao node2 = new NodeInfoModelDao(-1L, "node2", initialBootTime2, now, "nodeInfo", true);
  nodeInfoDao.create(node2);
  all = nodeInfoDao.getAll();
  assertEquals(all.size(), 2);
  assertEquals(all.get(0), newNode1);
  assertEquals(all.get(1), node2);
  final NodeInfoModelDao newNode2 = new NodeInfoModelDao(-1L, "node2", initialBootTime2, now, "nodeInfo2", true);
  nodeInfoDao.updateNodeInfo(newNode2.getNodeName(), newNode2.getNodeInfo());
  all = nodeInfoDao.getAll();
  assertEquals(all.size(), 2);
  assertEquals(all.get(0), newNode1);
  assertEquals(all.get(1), newNode2);
}

代码示例来源:origin: killbill/killbill

@Test(groups = "slow")
public void testChangePlanRightAfterCreate() throws SubscriptionBaseApiException {
  final DefaultSubscriptionBase subscription = testUtil.createSubscription(bundle, "Shotgun", BillingPeriod.MONTHLY, PriceListSet.DEFAULT_PRICELIST_NAME);
  clock.setTime(clock.getUTCNow().plusSeconds(1));
  // CHANGE PLAN ALMOST IMMEDIATELY
  testListener.pushExpectedEvent(NextEvent.CHANGE);
  final PlanPhaseSpecifier planPhaseSpecifier = new PlanPhaseSpecifier("Pistol", BillingPeriod.MONTHLY, PriceListSet.DEFAULT_PRICELIST_NAME);
  subscription.changePlan(new DefaultEntitlementSpecifier(planPhaseSpecifier), callContext);
  assertListenerStatus();
  checkChangePlan(subscription, "Pistol", ProductCategory.BASE, BillingPeriod.MONTHLY, PhaseType.TRIAL);
  final SubscriptionBase refreshedSubscription = subscriptionInternalApi.getSubscriptionFromId(subscription.getId(), internalCallContext);
  assertEquals(refreshedSubscription.getAllTransitions().size(), 3);
  assertEquals(refreshedSubscription.getAllTransitions().get(0).getTransitionType(), SubscriptionBaseTransitionType.CREATE);
  assertEquals(refreshedSubscription.getAllTransitions().get(1).getTransitionType(), SubscriptionBaseTransitionType.CHANGE);
  assertEquals(refreshedSubscription.getAllTransitions().get(2).getTransitionType(), SubscriptionBaseTransitionType.PHASE);
}

代码示例来源:origin: spotify/helios

DateTime.now().plusSeconds(10).toDate());

代码示例来源:origin: killbill/killbill

final DateTime createdDate = startDate.plusSeconds(10);

代码示例来源:origin: killbill/killbill

@Test(groups = "slow")
public void testUndoChangePlan() throws SubscriptionBaseApiException {
  final DefaultSubscriptionBase subscription = testUtil.createSubscription(bundle, "Shotgun", BillingPeriod.MONTHLY, PriceListSet.DEFAULT_PRICELIST_NAME);
  clock.setTime(clock.getUTCNow().plusSeconds(1));
  // Change plan in the future
  final DateTime targetDate = clock.getUTCNow().plusDays(3);
  final PlanPhaseSpecifier planPhaseSpecifier = new PlanPhaseSpecifier("Pistol", BillingPeriod.MONTHLY, PriceListSet.DEFAULT_PRICELIST_NAME);
  subscription.changePlanWithDate(new DefaultEntitlementSpecifier(planPhaseSpecifier), targetDate, callContext);assertListenerStatus();
  DefaultSubscriptionBase refreshedSubscription = (DefaultSubscriptionBase) subscriptionInternalApi.getSubscriptionFromId(subscription.getId(), internalCallContext);
  assertEquals(refreshedSubscription.getAllTransitions().size(), 3);
  assertEquals(refreshedSubscription.getAllTransitions().get(0).getTransitionType(), SubscriptionBaseTransitionType.CREATE);
  assertEquals(refreshedSubscription.getAllTransitions().get(1).getTransitionType(), SubscriptionBaseTransitionType.CHANGE);
  assertEquals(refreshedSubscription.getAllTransitions().get(2).getTransitionType(), SubscriptionBaseTransitionType.PHASE);
  clock.addDays(1);
  testListener.pushExpectedEvent(NextEvent.UNDO_CHANGE);
  subscription.undoChangePlan(callContext);
  assertListenerStatus();
  // No CHANGE_PLAN
  clock.addDays(3);
  assertListenerStatus();
  // Verify PHASE event for Shotgun is active
  testListener.pushExpectedEvent(NextEvent.PHASE);
  clock.addDays(26);
  assertListenerStatus();
  refreshedSubscription = (DefaultSubscriptionBase) subscriptionInternalApi.getSubscriptionFromId(subscription.getId(), internalCallContext);
  assertEquals(refreshedSubscription.getAllTransitions().size(), 2);
  assertEquals(refreshedSubscription.getAllTransitions().get(0).getTransitionType(), SubscriptionBaseTransitionType.CREATE);
  assertEquals(refreshedSubscription.getAllTransitions().get(1).getTransitionType(), SubscriptionBaseTransitionType.PHASE);
}

代码示例来源:origin: killbill/killbill

final DateTime createdDate = startDate.plusSeconds(10);

代码示例来源:origin: cloudfoundry/uaa

SubjectConfirmationData subjectConfirmationData = subjectConfirmationDataBuilder.buildObject();
subjectConfirmationData.setNotOnOrAfter(new DateTime().plusSeconds(assertionTtlSeconds));
subjectConfirmationData.setInResponseTo(authnRequest.getID());
subjectConfirmationData.setRecipient(authnRequest.getAssertionConsumerServiceURL());

代码示例来源:origin: prestodb/presto

@Test
public void testAddFieldToTimestamp()
{
  assertFunction("date_add('millisecond', 3, " + TIMESTAMP_LITERAL + ")", TimestampType.TIMESTAMP, sqlTimestampOf(TIMESTAMP.plusMillis(3), session));
  assertFunction("date_add('second', 3, " + TIMESTAMP_LITERAL + ")", TimestampType.TIMESTAMP, sqlTimestampOf(TIMESTAMP.plusSeconds(3), session));
  assertFunction("date_add('minute', 3, " + TIMESTAMP_LITERAL + ")", TimestampType.TIMESTAMP, sqlTimestampOf(TIMESTAMP.plusMinutes(3), session));
  assertFunction("date_add('hour', 3, " + TIMESTAMP_LITERAL + ")", TimestampType.TIMESTAMP, sqlTimestampOf(TIMESTAMP.plusHours(3), session));
  assertFunction("date_add('hour', 23, " + TIMESTAMP_LITERAL + ")", TimestampType.TIMESTAMP, sqlTimestampOf(TIMESTAMP.plusHours(23), session));
  assertFunction("date_add('hour', -4, " + TIMESTAMP_LITERAL + ")", TimestampType.TIMESTAMP, sqlTimestampOf(TIMESTAMP.minusHours(4), session));
  assertFunction("date_add('hour', -23, " + TIMESTAMP_LITERAL + ")", TimestampType.TIMESTAMP, sqlTimestampOf(TIMESTAMP.minusHours(23), session));
  assertFunction("date_add('day', 3, " + TIMESTAMP_LITERAL + ")", TimestampType.TIMESTAMP, sqlTimestampOf(TIMESTAMP.plusDays(3), session));
  assertFunction("date_add('week', 3, " + TIMESTAMP_LITERAL + ")", TimestampType.TIMESTAMP, sqlTimestampOf(TIMESTAMP.plusWeeks(3), session));
  assertFunction("date_add('month', 3, " + TIMESTAMP_LITERAL + ")", TimestampType.TIMESTAMP, sqlTimestampOf(TIMESTAMP.plusMonths(3), session));
  assertFunction("date_add('quarter', 3, " + TIMESTAMP_LITERAL + ")", TimestampType.TIMESTAMP, sqlTimestampOf(TIMESTAMP.plusMonths(3 * 3), session));
  assertFunction("date_add('year', 3, " + TIMESTAMP_LITERAL + ")", TimestampType.TIMESTAMP, sqlTimestampOf(TIMESTAMP.plusYears(3), session));
  assertFunction("date_add('millisecond', 3, " + WEIRD_TIMESTAMP_LITERAL + ")", TIMESTAMP_WITH_TIME_ZONE, toTimestampWithTimeZone(WEIRD_TIMESTAMP.plusMillis(3)));
  assertFunction("date_add('second', 3, " + WEIRD_TIMESTAMP_LITERAL + ")", TIMESTAMP_WITH_TIME_ZONE, toTimestampWithTimeZone(WEIRD_TIMESTAMP.plusSeconds(3)));
  assertFunction("date_add('minute', 3, " + WEIRD_TIMESTAMP_LITERAL + ")", TIMESTAMP_WITH_TIME_ZONE, toTimestampWithTimeZone(WEIRD_TIMESTAMP.plusMinutes(3)));
  assertFunction("date_add('hour', 3, " + WEIRD_TIMESTAMP_LITERAL + ")", TIMESTAMP_WITH_TIME_ZONE, toTimestampWithTimeZone(WEIRD_TIMESTAMP.plusHours(3)));
  assertFunction("date_add('day', 3, " + WEIRD_TIMESTAMP_LITERAL + ")", TIMESTAMP_WITH_TIME_ZONE, toTimestampWithTimeZone(WEIRD_TIMESTAMP.plusDays(3)));
  assertFunction("date_add('week', 3, " + WEIRD_TIMESTAMP_LITERAL + ")", TIMESTAMP_WITH_TIME_ZONE, toTimestampWithTimeZone(WEIRD_TIMESTAMP.plusWeeks(3)));
  assertFunction("date_add('month', 3, " + WEIRD_TIMESTAMP_LITERAL + ")", TIMESTAMP_WITH_TIME_ZONE, toTimestampWithTimeZone(WEIRD_TIMESTAMP.plusMonths(3)));
  assertFunction("date_add('quarter', 3, " + WEIRD_TIMESTAMP_LITERAL + ")", TIMESTAMP_WITH_TIME_ZONE, toTimestampWithTimeZone(WEIRD_TIMESTAMP.plusMonths(3 * 3)));
  assertFunction("date_add('year', 3, " + WEIRD_TIMESTAMP_LITERAL + ")", TIMESTAMP_WITH_TIME_ZONE, toTimestampWithTimeZone(WEIRD_TIMESTAMP.plusYears(3)));
}

代码示例来源:origin: dlew/joda-time-android

assertEquals("in 30 seconds, 12:35", DateUtils.getRelativeDateTimeString(ctx, mNow.plusSeconds(30), null, 0));
assertEquals("30 seconds ago, 12:34", DateUtils.getRelativeDateTimeString(ctx, mNow.minusSeconds(30), null, 0));
assertEquals("in 30 minutes, 13:05", DateUtils.getRelativeDateTimeString(ctx, mNow.plusMinutes(30), null, 0));
  DateUtils.getRelativeDateTimeString(ctx, mNow.plusSeconds(30), null, DateUtils.FORMAT_ABBREV_RELATIVE));
assertEquals("30 secs ago, 12:34",
  DateUtils.getRelativeDateTimeString(ctx, mNow.minusSeconds(30), null, DateUtils.FORMAT_ABBREV_RELATIVE));
assertEquals("Oct 24, 1995, 12:35", DateUtils.getRelativeDateTimeString(ctx, dt.plusSeconds(1), Days.TWO, 0));
assertEquals("in 2 days, 12:35", DateUtils.getRelativeDateTimeString(ctx, dt, Days.THREE, 0));

相关文章

DateTime类方法