com.google.cloud.Timestamp.getSeconds()方法的使用及代码示例

x33g5p2x  于2022-01-30 转载在 其他  
字(10.5k)|赞(0)|评价(0)|浏览(198)

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

Timestamp.getSeconds介绍

[英]Returns the number of seconds since January 1, 1970, 00:00:00 UTC. A negative value is the number of seconds before January 1, 1970, 00:00:00 UTC.
[中]返回自1970年1月1日00:00:00 UTC以来的秒数。负值是1970年1月1日00:00:00 UTC之前的秒数。

代码示例

代码示例来源：origin: googleapis/google-cloud-java

  1. @Test
  2. public void maxValue() {
  3.  TimeZone tz = TimeZone.getTimeZone("UTC");
  4.  GregorianCalendar calendar = new GregorianCalendar(tz);
  5.  calendar.set(9999, Calendar.DECEMBER, 31, 23, 59, 59);
  6.  java.sql.Timestamp expectedMin = new java.sql.Timestamp(calendar.getTimeInMillis());
  7.  expectedMin.setNanos(999999999);
  8.  assertThat(Timestamp.MAX_VALUE.getSeconds()).isEqualTo(calendar.getTimeInMillis() / 1000L);
  9.  assertThat(Timestamp.MAX_VALUE.getNanos()).isEqualTo(999999999);
  10. }

代码示例来源：origin: googleapis/google-cloud-java

  1. @Test
  2. public void ofDate() {
  3.  Timestamp timestamp = Timestamp.of(TEST_DATE);
  4.  Long expectedSeconds = TimeUnit.MILLISECONDS.toSeconds(TEST_TIME_MILLISECONDS);
  5.  Long expectedNanos =
  6.    TimeUnit.MILLISECONDS.toNanos(TEST_TIME_MILLISECONDS)
  7.      - TimeUnit.SECONDS.toNanos(expectedSeconds);
  8.  assertThat(timestamp.getSeconds()).isEqualTo(expectedSeconds);
  9.  assertThat(timestamp.getNanos()).isEqualTo(expectedNanos);
  10. }

代码示例来源：origin: googleapis/google-cloud-java

  1. @Test
  2. public void boundsSqlTimestampMax() {
  3.  expectedException.expect(IllegalArgumentException.class);
  4.  Timestamp.of(new java.sql.Timestamp((Timestamp.MAX_VALUE.getSeconds() + 1) * 1000));
  5. }

代码示例来源：origin: googleapis/google-cloud-java

  1. @Test
  2. public void boundsSqlTimestampMin() {
  3.  expectedException.expect(IllegalArgumentException.class);
  4.  Timestamp.of(new java.sql.Timestamp((Timestamp.MIN_VALUE.getSeconds() - 1) * 1000));
  5. }

代码示例来源：origin: googleapis/google-cloud-java

  1. @Test
  2. public void minValue() {
  3.  // MIN_VALUE is before the start of the Gregorian calendar... use magic value.
  4.  assertThat(Timestamp.MIN_VALUE.getSeconds()).isEqualTo(-62135596800L);
  5.  assertThat(Timestamp.MIN_VALUE.getNanos()).isEqualTo(0);
  6. }

代码示例来源：origin: googleapis/google-cloud-java

  1. @Test
  2. public void toFromSqlTimestamp() {
  3.  long seconds = TEST_TIME_SECONDS;
  4.  int nanos = 500000000;
  5.  java.sql.Timestamp sqlTs = new java.sql.Timestamp(seconds * 1000);
  6.  sqlTs.setNanos(nanos);
  7.  Timestamp ts = Timestamp.of(sqlTs);
  8.  assertThat(ts.getSeconds()).isEqualTo(seconds);
  9.  assertThat(ts.getNanos()).isEqualTo(nanos);
  10.  assertThat(ts.toSqlTimestamp()).isEqualTo(sqlTs);
  11. }

代码示例来源：origin: googleapis/google-cloud-java

  1. @Test
  2. public void boundsSecondsMin() {
  3.  expectedException.expect(IllegalArgumentException.class);
  4.  Timestamp.ofTimeSecondsAndNanos(Timestamp.MIN_VALUE.getSeconds() - 1, 999999999);
  5. }

代码示例来源：origin: googleapis/google-cloud-java

  1. @Test
  2. public void boundsSecondsMax() {
  3.  expectedException.expect(IllegalArgumentException.class);
  4.  Timestamp.ofTimeSecondsAndNanos(Timestamp.MAX_VALUE.getSeconds() + 1, 0);
  5. }

代码示例来源：origin: googleapis/google-cloud-java

  1. @Test
  2. public void ofMicroseconds() {
  3.  Timestamp timestamp = Timestamp.ofTimeMicroseconds(TEST_TIME_MICROSECONDS);
  4.  assertThat(timestamp.getSeconds()).isEqualTo(TEST_TIME_MICROSECONDS / 1000000L);
  5.  assertThat(timestamp.getNanos()).isEqualTo(TEST_TIME_MICROSECONDS % 1000000L * 1000);
  6. }

代码示例来源：origin: googleapis/google-cloud-java

  1. @Test
  2. public void fromProto() {
  3.  com.google.protobuf.Timestamp proto =
  4.    com.google.protobuf.Timestamp.newBuilder().setSeconds(1234).setNanos(567).build();
  5.  Timestamp timestamp = Timestamp.fromProto(proto);
  6.  assertThat(timestamp.getSeconds()).isEqualTo(1234);
  7.  assertThat(timestamp.getNanos()).isEqualTo(567);
  8. }

代码示例来源：origin: googleapis/google-cloud-java

  1. @Test
  2. public void testFlushLevelConfigUpdatesLoggingFlushSeverity() {
  3.  LogEntry logEntry =
  4.    LogEntry.newBuilder(StringPayload.of("this is a test"))
  5.      .setTimestamp(100000L)
  6.      .setSeverity(Severity.WARNING)
  7.      .setLabels(
  8.        new ImmutableMap.Builder<String, String>()
  9.          .put("levelName", "WARN")
  10.          .put("levelValue", String.valueOf(30000L))
  11.          .build())
  12.      .build();
  13.  logging.setFlushSeverity(Severity.WARNING);
  14.  Capture<Iterable<LogEntry>> capturedArgument = Capture.newInstance();
  15.  logging.write(capture(capturedArgument), (WriteOption) anyObject(), (WriteOption) anyObject());
  16.  replay(logging);
  17.  Timestamp timestamp = Timestamp.ofTimeSecondsAndNanos(100000, 0);
  18.  LoggingEvent loggingEvent = createLoggingEvent(Level.WARN, timestamp.getSeconds());
  19.  // error is the default, updating to warn for test
  20.  loggingAppender.setFlushLevel(Level.WARN);
  21.  loggingAppender.start();
  22.  loggingAppender.doAppend(loggingEvent);
  23.  verify(logging);
  24.  assertThat(capturedArgument.getValue().iterator().hasNext()).isTrue();
  25.  assertThat(capturedArgument.getValue().iterator().next()).isEqualTo(logEntry);
  26. }

代码示例来源：origin: googleapis/google-cloud-java

  1. @Test
  2. public void testEnhancersAddCorrectLabelsToLogEntries() {
  3.  LogEntry logEntry =
  4.    LogEntry.newBuilder(StringPayload.of("this is a test"))
  5.      .setTimestamp(100000L)
  6.      .setSeverity(Severity.WARNING)
  7.      .setLabels(
  8.        new ImmutableMap.Builder<String, String>()
  9.          .put("levelName", "WARN")
  10.          .put("levelValue", String.valueOf(30000L))
  11.          .put("test-label-1", "test-value-1")
  12.          .put("test-label-2", "test-value-2")
  13.          .build())
  14.      .build();
  15.  logging.setFlushSeverity(Severity.ERROR);
  16.  Capture<Iterable<LogEntry>> capturedArgument = Capture.newInstance();
  17.  logging.write(capture(capturedArgument), (WriteOption) anyObject(), (WriteOption) anyObject());
  18.  expectLastCall().once();
  19.  replay(logging);
  20.  loggingAppender.addEnhancer("com.example.enhancers.TestLoggingEnhancer");
  21.  loggingAppender.addEnhancer("com.example.enhancers.AnotherTestLoggingEnhancer");
  22.  loggingAppender.start();
  23.  Timestamp timestamp = Timestamp.ofTimeSecondsAndNanos(100000, 0);
  24.  LoggingEvent loggingEvent = createLoggingEvent(Level.WARN, timestamp.getSeconds());
  25.  loggingAppender.doAppend(loggingEvent);
  26.  verify(logging);
  27.  assertThat(capturedArgument.getValue().iterator().hasNext()).isTrue();
  28.  assertThat(capturedArgument.getValue().iterator().next()).isEqualTo(logEntry);
  29. }

代码示例来源：origin: googleapis/google-cloud-java

  1. replay(logging);
  2. Timestamp timestamp = Timestamp.ofTimeSecondsAndNanos(100000, 0);
  3. LoggingEvent loggingEvent1 = createLoggingEvent(Level.INFO, timestamp.getSeconds());
  4. ThresholdFilter thresholdFilter = new ThresholdFilter();
  5. thresholdFilter.setLevel("ERROR");
  6. LoggingEvent loggingEvent2 = createLoggingEvent(Level.ERROR, timestamp.getSeconds());

代码示例来源：origin: googleapis/google-cloud-java

  1. @Test
  2. public void writeAtLeastOnce() throws ParseException {
  3.  String timestampString = "2015-10-01T10:54:20.021Z";
  4.  ArgumentCaptor<CommitRequest> commit = ArgumentCaptor.forClass(CommitRequest.class);
  5.  CommitResponse response =
  6.    CommitResponse.newBuilder().setCommitTimestamp(Timestamps.parse(timestampString)).build();
  7.  Mockito.when(rpc.commit(commit.capture(), Mockito.eq(options))).thenReturn(response);
  8.  Timestamp timestamp =
  9.    session.writeAtLeastOnce(
  10.      Arrays.asList(Mutation.newInsertBuilder("T").set("C").to("x").build()));
  11.  assertThat(timestamp.getSeconds())
  12.    .isEqualTo(utcTimeSeconds(2015, Calendar.OCTOBER, 1, 10, 54, 20));
  13.  assertThat(timestamp.getNanos()).isEqualTo(TimeUnit.MILLISECONDS.toNanos(21));
  14.  CommitRequest request = commit.getValue();
  15.  assertThat(request.getSingleUseTransaction()).isNotNull();
  16.  assertThat(request.getSingleUseTransaction().getReadWrite()).isNotNull();
  17.  com.google.spanner.v1.Mutation mutation =
  18.    com.google.spanner.v1.Mutation.newBuilder()
  19.      .setInsert(
  20.        Write.newBuilder()
  21.          .setTable("T")
  22.          .addColumns("C")
  23.          .addValues(
  24.            ListValue.newBuilder()
  25.              .addValues(com.google.protobuf.Value.newBuilder().setStringValue("x"))))
  26.      .build();
  27.  assertThat(request.getMutationsList()).containsExactly(mutation);
  28. }

代码示例来源：origin: googleapis/google-cloud-java

  1. @Test
  2. public void testDefaultWriteOptionsHasExpectedDefaults() {
  3.  logging.setFlushSeverity(Severity.ERROR);
  4.  Capture<WriteOption> logNameArg = Capture.newInstance();
  5.  Capture<WriteOption> resourceArg = Capture.newInstance();
  6.  logging.write((Iterable<LogEntry>) anyObject(), capture(logNameArg), capture(resourceArg));
  7.  expectLastCall().once();
  8.  replay(logging);
  9.  loggingAppender.start();
  10.  Timestamp timestamp = Timestamp.ofTimeSecondsAndNanos(100000, 0);
  11.  LoggingEvent loggingEvent = createLoggingEvent(Level.ERROR, timestamp.getSeconds());
  12.  loggingAppender.doAppend(loggingEvent);
  13.  assertThat(logNameArg.getValue()).isEqualTo(defaultWriteOptions[0]);
  14.  // TODO(chingor): Fix this test to work on GCE and locally
  15.  // assertThat(resourceArg.getValue()).isEqualTo(defaultWriteOptions[1]);
  16. }

代码示例来源：origin: googleapis/google-cloud-java

  1. @Test
  2. public void deleteDocument() throws Exception {
  3.  randomDoc.delete().get();
  4.  WriteResult writeResult = randomDoc.set(ALL_SUPPORTED_TYPES_MAP).get();
  5.  try {
  6.   randomDoc.delete(Precondition.updatedAt(Timestamp.ofTimeSecondsAndNanos(1, 0))).get();
  7.   fail();
  8.  } catch (ExecutionException e) {
  9.   assertTrue(e.getMessage().contains("FAILED_PRECONDITION"));
  10.  }
  11.  writeResult = randomDoc.delete(Precondition.updatedAt(writeResult.getUpdateTime())).get();
  12.  DocumentSnapshot documentSnapshot = randomDoc.get().get();
  13.  assertFalse(documentSnapshot.exists());
  14.  assertTrue(writeResult.getUpdateTime().getSeconds() > 0);
  15. }

代码示例来源：origin: GoogleCloudPlatform/java-docs-samples

  1. @Override
  2.  public MutationGroup apply(String userId) {
  3.   // Immediately block the user.
  4.   Mutation userMutation = Mutation.newUpdateBuilder("Users")
  5.     .set("id").to(userId)
  6.     .set("state").to("BLOCKED")
  7.     .build();
  8.   long generatedId = Hashing.sha1().newHasher()
  9.     .putString(userId, Charsets.UTF_8)
  10.     .putLong(timestamp.getSeconds())
  11.     .putLong(timestamp.getNanos())
  12.     .hash()
  13.     .asLong();
  14.   // Add an entry to pending review requests.
  15.   Mutation pendingReview = Mutation.newInsertOrUpdateBuilder("PendingReviews")
  16.     .set("id").to(generatedId)  // Must be deterministically generated.
  17.     .set("userId").to(userId)
  18.     .set("action").to("REVIEW ACCOUNT")
  19.     .set("note").to("Suspicious activity detected.")
  20.     .build();
  21.   return MutationGroup.create(userMutation, pendingReview);
  22.  }
  23. }));

代码示例来源：origin: spring-cloud/spring-cloud-gcp

  1. @Nullable
  2.   @Override
  3.   public Instant convert(Timestamp timestamp) {
  4.     return Instant.ofEpochSecond(timestamp.getSeconds(), timestamp.getNanos());
  5.   }
  6. };

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

  1. @Nullable
  2.   @Override
  3.   public Instant convert(Timestamp timestamp) {
  4.     return Instant.ofEpochSecond(timestamp.getSeconds(), timestamp.getNanos());
  5.   }
  6. };

代码示例来源：origin: org.apache.beam/beam-sdks-java-io-google-cloud-platform

  1. private void writeTimestamp(OrderedCode orderedCode, KeyPart part, Timestamp v) {
  2.  if (part.isDesc()) {
  3.   orderedCode.writeNumDecreasing(v.getSeconds());
  4.   orderedCode.writeNumDecreasing(v.getNanos());
  5.  } else {
  6.   orderedCode.writeNumIncreasing(v.getSeconds());
  7.   orderedCode.writeNumIncreasing(v.getNanos());
  8.  }
  9. }

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

timestamp

相关文章

    查看更多

    热门标签

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

    最新文章

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