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

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

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

Timestamp.now介绍

[英]Creates an instance with current time.
[中]使用当前时间创建实例。

代码示例

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

  1. /**
  2.  * Returns the current count of all documents, including the changes from the current changeMap.
  3.  */
  4. private int currentSize() {
  5.  ChangeSet changeSet = extractChanges(Timestamp.now());
  6.  return documentSet.size() + changeSet.adds.size() - changeSet.deletes.size();
  7. }

代码示例来源：origin: google/data-transfer-project

  1. private Entity createEntity(Key key, Map<String, Object> data) throws IOException {
  2.  Entity.Builder builder = Entity.newBuilder(key).set(CREATED_FIELD, Timestamp.now());
  3.  for (Entry<String, Object> entry : data.entrySet()) {
  4.   if (entry.getValue() instanceof String) {
  5.    builder.set(entry.getKey(), (String) entry.getValue()); // StringValue
  6.   } else if (entry.getValue() instanceof Integer) {
  7.    builder.set(entry.getKey(), (Integer) entry.getValue()); // LongValue
  8.   } else if (entry.getValue() instanceof Double) {
  9.    builder.set(entry.getKey(), (Double) entry.getValue()); // DoubleValue
  10.   } else if (entry.getValue() instanceof Boolean) {
  11.    builder.set(entry.getKey(), (Boolean) entry.getValue()); // BooleanValue
  12.   } else if (entry.getValue() instanceof Timestamp) {
  13.    builder.set(entry.getKey(), (Timestamp) entry.getValue()); // TimestampValue
  14.   } else {
  15.    ByteArrayOutputStream bos = new ByteArrayOutputStream();
  16.    try (ObjectOutputStream out = new ObjectOutputStream(bos)) {
  17.     out.writeObject(entry.getValue());
  18.    }
  19.    builder.set(entry.getKey(), Blob.copyFrom(bos.toByteArray())); // BlobValue
  20.   }
  21.  }
  22.  return builder.build();
  23. }

代码示例来源：origin: google/data-transfer-project

  1. @Override
  2. public <T extends DataModel> void create(UUID jobId, String key, T model) throws IOException {
  3.  Preconditions.checkNotNull(jobId);
  4.  Transaction transaction = datastore.newTransaction();
  5.  Key fullKey = getDataKey(jobId, key);
  6.  Entity shouldNotExist = transaction.get(fullKey);
  7.  if (shouldNotExist != null) {
  8.   transaction.rollback();
  9.   throw new IOException(
  10.     "Record already exists for key: " + fullKey.getName() + ". Record: " + shouldNotExist);
  11.  }
  12.  String serialized = objectMapper.writeValueAsString(model);
  13.  Entity entity = Entity.newBuilder(fullKey)
  14.    .set(CREATED_FIELD, Timestamp.now())
  15.    .set(model.getClass().getName(), serialized)
  16.    .build();
  17.  try {
  18.   transaction.put(entity);
  19.  } catch (DatastoreException e) {
  20.   throw new IOException(
  21.     "Could not create initial record for jobID: " + jobId + ". Record: " + entity, e);
  22.  }
  23.  transaction.commit();
  24. }

代码示例来源：origin: google/data-transfer-project

  1. @Override
  2. public <T extends DataModel> void update(UUID jobId, String key, T model) {
  3.  Transaction transaction = datastore.newTransaction();
  4.  Key entityKey = getDataKey(jobId, key);
  5.  try {
  6.   Entity previousEntity = transaction.get(entityKey);
  7.   if (previousEntity == null) {
  8.    throw new IOException("Could not find record for data key: " + entityKey.getName());
  9.   }
  10.   String serialized = objectMapper.writeValueAsString(model);
  11.   Entity entity = Entity.newBuilder(entityKey)
  12.     .set(CREATED_FIELD, Timestamp.now())
  13.     .set(model.getClass().getName(), serialized)
  14.     .build();
  15.   transaction.put(entity);
  16.   transaction.commit();
  17.  } catch (IOException t) {
  18.   transaction.rollback();
  19.   throw new RuntimeException("Failed atomic update of key: " + key, t);
  20.  }
  21. }

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

  1. public static void main(String... args) {
  2.   Datastore datastore = DatastoreOptions.getDefaultInstance().getService();
  3.   KeyFactory keyFactory = datastore.newKeyFactory().setKind("keyKind");
  4.   Key key = keyFactory.newKey("keyName");
  5.   Entity entity = datastore.get(key);
  6.   if (entity != null) {
  7.    System.out.println("Updating access_time for " + entity.getString("name"));
  8.    entity = Entity.newBuilder(entity).set("access_time", Timestamp.now()).build();
  9.    datastore.update(entity);
  10.   }
  11.  }
  12. }

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

  1. @Test
  2. public void serialization() throws Exception {
  3.  reserializeAndAssert(TimestampBound.strong());
  4.  reserializeAndAssert(TimestampBound.ofExactStaleness(10, TimeUnit.NANOSECONDS));
  5.  reserializeAndAssert(TimestampBound.ofMaxStaleness(100, TimeUnit.DAYS));
  6.  reserializeAndAssert(TimestampBound.ofMinReadTimestamp(Timestamp.now()));
  7.  reserializeAndAssert(TimestampBound.ofReadTimestamp(Timestamp.now()));
  8. }

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

  1. public static void main(String... args) {
  2.   Datastore datastore = DatastoreOptions.getDefaultInstance().getService();
  3.   KeyFactory keyFactory = datastore.newKeyFactory().setKind("keyKind");
  4.   Key key = keyFactory.newKey("keyName");
  5.   Entity entity =
  6.     Entity.newBuilder(key)
  7.       .set("name", "John Doe")
  8.       .set("age", 30)
  9.       .set("access_time", Timestamp.now())
  10.       .build();
  11.   datastore.put(entity);
  12.  }
  13. }

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

  1. @Override
  2. public void run(Transaction tx, Key userKey, String content) {
  3.  Entity user = tx.get(userKey);
  4.  if (user == null) {
  5.   System.out.println("Adding a new user.");
  6.   user = Entity.newBuilder(userKey).set("count", 1).build();
  7.   tx.add(user);
  8.  } else {
  9.   user = Entity.newBuilder(user).set("count", user.getLong("count") + 1L).build();
  10.   tx.update(user);
  11.  }
  12.  IncompleteKey commentKey = IncompleteKey.newBuilder(userKey, COMMENT_KIND).build();
  13.  FullEntity<IncompleteKey> comment =
  14.    FullEntity.newBuilder(commentKey)
  15.      .set("content", content)
  16.      .set("timestamp", Timestamp.now())
  17.      .build();
  18.  tx.addWithDeferredIdAllocation(comment);
  19.  System.out.printf("Adding a comment to user '%s'.%n", userKey.getName());
  20. }

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

  1. @Before
  2. public void setUp() {
  3.  builder = new Builder();
  4.  builder.set("blob", BLOB).set("boolean", true).set("timestamp", TIMESTAMP);
  5.  builder.set("double", 1.25).set("key", KEY).set("string", "hello world");
  6.  builder.set("long", 125).setNull("null").set("entity", ENTITY).set("latLng", LAT_LNG);
  7.  builder.set("partialEntity", PARTIAL_ENTITY).set("stringValue", StringValue.of("bla"));
  8.  builder.set("list1", NullValue.of(), StringValue.of("foo"), LatLngValue.of(LAT_LNG));
  9.  builder.set("list2", ImmutableList.of(LongValue.of(10), DoubleValue.of(2)));
  10.  builder.set("list3", Collections.singletonList(BooleanValue.of(true)));
  11.  builder.set(
  12.    "blobList", BLOB, Blob.copyFrom(new byte[] {3, 4}), Blob.copyFrom(new byte[] {5, 6}));
  13.  builder.set("booleanList", true, false, true);
  14.  builder.set("timestampList", Timestamp.now(), Timestamp.now(), Timestamp.now());
  15.  builder.set("doubleList", 12.3, 4.56, .789);
  16.  builder.set(
  17.    "keyList",
  18.    KEY,
  19.    Key.newBuilder("ds2", "k2", "n2").build(),
  20.    Key.newBuilder("ds3", "k3", "n3").build());
  21.  builder.set("entityList", ENTITY, PARTIAL_ENTITY);
  22.  builder.set("stringList", "s1", "s2", "s3");
  23.  builder.set("longList", 1, 23, 456);
  24.  builder.set("latLngList", LAT_LNG, LAT_LNG);
  25. }

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

  1. tester.addEqualityGroup(
  2.   Value.timestamp(Value.COMMIT_TIMESTAMP), Value.timestamp(Value.COMMIT_TIMESTAMP));
  3. Timestamp now = Timestamp.now();
  4. tester.addEqualityGroup(Value.timestamp(now), Value.timestamp(now));
  5. tester.addEqualityGroup(Value.timestamp(Timestamp.ofTimeMicroseconds(0)));

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

  1. reserializeAndAssert(Value.timestamp(Timestamp.now()));
  2. reserializeAndAssert(Value.timestampArray(Arrays.asList(null, Timestamp.now())));

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

  1. /**
  2.  * Adds a task entity to the Datastore.
  3.  *
  4.  * @param description The task description
  5.  * @return The {@link Key} of the entity
  6.  * @throws DatastoreException if the ID allocation or put fails
  7.  */
  8. Key addTask(String description) {
  9.  Key key = datastore.allocateId(keyFactory.newKey());
  10.  Entity task = Entity.newBuilder(key)
  11.    .set("description", StringValue.newBuilder(description).setExcludeFromIndexes(true).build())
  12.    .set("created", Timestamp.now())
  13.    .set("done", false)
  14.    .build();
  15.  datastore.put(task);
  16.  return key;
  17. }
  18. // [END datastore_add_entity]

代码示例来源：origin: com.google.cloud/google-cloud-firestore

  1. /**
  2.  * Returns the current count of all documents, including the changes from the current changeMap.
  3.  */
  4. private int currentSize() {
  5.  ChangeSet changeSet = extractChanges(Timestamp.now());
  6.  return documentSet.size() + changeSet.adds.size() - changeSet.deletes.size();
  7. }

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

  1. final Timestamp timestamp = Timestamp.now();

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

  1. .withInstanceId("123")
  2. .withDatabaseId("aaa")
  3. .withTimestamp(Timestamp.now())
  4. .withTable("users")
  5. .withColumns("id", "name")

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

  1. @Test
  2. public void dates() throws Exception {
  3.  Mutation timestamp =
  4.    Mutation.newInsertOrUpdateBuilder("test").set("one").to(Timestamp.now()).build();
  5.  Mutation nullTimestamp =
  6.    Mutation.newInsertOrUpdateBuilder("test").set("one").to((Timestamp) null).build();
  7.    Mutation.newInsertOrUpdateBuilder("test")
  8.      .set("one")
  9.      .toTimestampArray(Arrays.asList(Timestamp.now(), null))
  10.      .build();
  11.  Mutation dateArray =

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

timestamp

相关文章

    查看更多

    热门标签

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

    最新文章

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