com.google.cloud.datastore.Entity.getLong()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(10.3k)|赞(0)|评价(0)|浏览(113)

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

Entity.getLong介绍

暂无

代码示例

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

private static Map<String, Object> getProperties(Entity entity)
  throws IOException, ClassNotFoundException {
 if (entity == null) {
  return null;
 }
 ImmutableMap.Builder<String, Object> builder = new ImmutableMap.Builder<>();
 for (String property : entity.getNames()) {
  // builder.put(property, entity.getValue(property));
  if (entity.getValue(property) instanceof StringValue) {
   builder.put(property, (String) entity.getString(property));
  } else if (entity.getValue(property) instanceof LongValue) {
   // This conversion is safe because of integer to long conversion above
   builder.put(property, new Long(entity.getLong(property)).intValue());
  } else if (entity.getValue(property) instanceof DoubleValue) {
   builder.put(property, (Double) entity.getDouble(property));
  } else if (entity.getValue(property) instanceof BooleanValue) {
   builder.put(property, (Boolean) entity.getBoolean(property));
  } else if (entity.getValue(property) instanceof TimestampValue) {
   builder.put(property, (Timestamp) entity.getTimestamp(property));
  } else {
   Blob blob = entity.getBlob(property);
   Object obj = null;
   try (ObjectInputStream in = new ObjectInputStream(blob.asInputStream())) {
    obj = in.readObject();
   }
   builder.put(property, obj); // BlobValue
  }
 }
 return builder.build();
}

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

"User '%s' email is '%s', phone is '%s'.%n", userKey.getName(), email, phone);
System.out.printf("User '%s' has %d comment[s].%n", userKey.getName(), user.getLong("count"));
int limit = 200;
Map<Timestamp, String> sortedComments = new TreeMap<>();

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

@Override
public void run(Transaction tx, Key userKey, String content) {
 Entity user = tx.get(userKey);
 if (user == null) {
  System.out.println("Adding a new user.");
  user = Entity.newBuilder(userKey).set("count", 1).build();
  tx.add(user);
 } else {
  user = Entity.newBuilder(user).set("count", user.getLong("count") + 1L).build();
  tx.update(user);
 }
 IncompleteKey commentKey = IncompleteKey.newBuilder(userKey, COMMENT_KIND).build();
 FullEntity<IncompleteKey> comment =
   FullEntity.newBuilder(commentKey)
     .set("content", content)
     .set("timestamp", Timestamp.now())
     .build();
 tx.addWithDeferredIdAllocation(comment);
 System.out.printf("Adding a comment to user '%s'.%n", userKey.getName());
}

代码示例来源：origin: spotify/styx

Map<Integer, Long> shardsForCounter(String counterId) throws IOException {
 final List<Key> shardKeys = IntStream.range(0, NUM_SHARDS).mapToObj(
   index -> datastore.newKeyFactory().setKind(KIND_COUNTER_SHARD).newKey(
     String.format("%s-%d", counterId, index)))
   .collect(toList());
 final Map<Integer, Long> fetchedShards = new HashMap<>();
 datastore.get(shardKeys, shard -> fetchedShards.put(
   (int) shard.getLong(PROPERTY_SHARD_INDEX),
   shard.getLong(PROPERTY_SHARD_VALUE)));
 return fetchedShards;
}

代码示例来源：origin: spotify/styx

long getLimitForCounter(String counterId) throws IOException {
 if (GLOBAL_RESOURCE_ID.equals(counterId)) {
  // missing global resource means free to go
  return config().globalConcurrency().orElse(Long.MAX_VALUE);
 }
 final Key limitKey = datastore.newKeyFactory().setKind(KIND_COUNTER_LIMIT).newKey(counterId);
 final Entity limitEntity = datastore.get(limitKey);
 if (limitEntity == null) {
  throw new IllegalArgumentException("No limit found in Datastore for " + counterId);
 } else {
  return limitEntity.getLong(PROPERTY_LIMIT);
 }
}

代码示例来源：origin: spotify/styx

private Resource entityToResource(Entity entity) {
 return Resource.create(entity.getKey().getName(), entity.getLong(PROPERTY_LIMIT));
}

代码示例来源：origin: spotify/styx

@Override
public Optional<Shard> shard(String counterId, int shardIndex) throws IOException {
 // TODO there's no need for this to be transactional
 final Key shardKey = tx.getDatastore().newKeyFactory().setKind(KIND_COUNTER_SHARD)
   .newKey(counterId + "-" + shardIndex);
 Entity shardEntity = tx.get(shardKey);
 if (shardEntity == null) {
  return Optional.empty();
 }
 return Optional.of(Shard.create(counterId, shardIndex,
                 (int) tx.get(shardKey).getLong(PROPERTY_SHARD_VALUE)));
}

代码示例来源：origin: sai-pullabhotla/catatumbo

/**
 * Increments the version property of the given entity by one.
 * 
 * @param nativeEntity
 *          the target entity
 * @param versionMetadata
 *          the metadata of the version property
 * @return a new entity (copy of the given), but with the incremented version.
 */
static Entity incrementVersion(Entity nativeEntity, PropertyMetadata versionMetadata) {
 String versionPropertyName = versionMetadata.getMappedName();
 long version = nativeEntity.getLong(versionPropertyName);
 return Entity.newBuilder(nativeEntity).set(versionPropertyName, ++version).build();
}

代码示例来源：origin: sai-pullabhotla/catatumbo

long version = nativeEntities[i].getLong(versionPropertyName) - 1;
Entity storedNativeEntity = storedNativeEntities.get(i);
if (storedNativeEntity == null) {
   String.format("Entity does not exist: %s", nativeKeys[i]));
long storedVersion = storedNativeEntities.get(i).getLong(versionPropertyName);
if (version != storedVersion) {
 throw new OptimisticLockException(

代码示例来源：origin: sai-pullabhotla/catatumbo

@Override
@SuppressWarnings("unchecked")
protected <E> E updateWithOptimisticLockingInternal(E entity, PropertyMetadata versionMetadata) {
 try {
  entityManager.executeEntityListeners(CallbackType.PRE_UPDATE, entity);
  Entity nativeEntity = (Entity) Marshaller.marshal(entityManager, entity, Intent.UPDATE);
  Entity storedNativeEntity = nativeTransaction.get(nativeEntity.getKey());
  if (storedNativeEntity == null) {
   throw new OptimisticLockException(
     String.format("Entity does not exist: %s", nativeEntity.getKey()));
  }
  String versionPropertyName = versionMetadata.getMappedName();
  long version = nativeEntity.getLong(versionPropertyName) - 1;
  long storedVersion = storedNativeEntity.getLong(versionPropertyName);
  if (version != storedVersion) {
   throw new OptimisticLockException(
     String.format("Expecting version %d, but found %d", version, storedVersion));
  }
  nativeTransaction.update(nativeEntity);
  E updatedEntity = (E) Unmarshaller.unmarshal(nativeEntity, entity.getClass());
  entityManager.executeEntityListeners(CallbackType.POST_UPDATE, updatedEntity);
  return updatedEntity;
 } catch (DatastoreException exp) {
  throw DatastoreUtils.wrap(exp);
 }
}

代码示例来源：origin: sai-pullabhotla/catatumbo

long version = nativeEntities[i].getLong(versionPropertyName) - 1;
Entity storedNativeEntity = storedNativeEntities.get(i);
if (storedNativeEntity == null) {
   String.format("Entity does not exist: %s", nativeKeys[i]));
long storedVersion = storedNativeEntities.get(i).getLong(versionPropertyName);
if (version != storedVersion) {
 throw new OptimisticLockException(

代码示例来源：origin: spotify/styx

static RunState entityToRunState(Entity entity, WorkflowInstance instance)
  throws IOException {
 final long counter = entity.getLong(PROPERTY_COUNTER);
 final State state = State.valueOf(entity.getString(PROPERTY_STATE));
 final long timestamp = entity.getLong(PROPERTY_STATE_TIMESTAMP);
 final StateData data = StateData.newBuilder()
   .tries((int) entity.getLong(PROPERTY_STATE_TRIES))
   .consecutiveFailures((int) entity.getLong(PROPERTY_STATE_CONSECUTIVE_FAILURES))
   .retryCost(entity.getDouble(PROPERTY_STATE_RETRY_COST))
   .trigger(DatastoreStorage.<String>readOpt(entity, PROPERTY_STATE_TRIGGER_TYPE).map(type ->
     TriggerUtil.trigger(type, entity.getString(PROPERTY_STATE_TRIGGER_ID))))
   .messages(OBJECT_MAPPER.<List<Message>>readValue(entity.getString(PROPERTY_STATE_MESSAGES),
     new TypeReference<List<Message>>() { }))
   .retryDelayMillis(readOpt(entity, PROPERTY_STATE_RETRY_DELAY_MILLIS))
   .lastExit(DatastoreStorage.<Long>readOpt(entity, PROPERTY_STATE_LAST_EXIT).map(Long::intValue))
   .executionId(readOpt(entity, PROPERTY_STATE_EXECUTION_ID))
   .executionDescription(readOptJson(entity, PROPERTY_STATE_EXECUTION_DESCRIPTION,
     ExecutionDescription.class))
   .resourceIds(readOptJson(entity, PROPERTY_STATE_RESOURCE_IDS,
     new TypeReference<Set<String>>() { }))
   .triggerParameters(readOptJson(entity, PROPERTY_STATE_TRIGGER_PARAMETERS, TriggerParameters.class))
   .build();
 return RunState.create(instance, state, data, Instant.ofEpochMilli(timestamp), counter);
}

代码示例来源：origin: org.eclipse.jetty.gcloud/jetty-gcloud-session-manager

String contextPath = entity.getString(_model.getContextPath());
String vhost = entity.getString(_model.getVhost());
long accessed = entity.getLong(_model.getAccessed());
long lastAccessed = entity.getLong(_model.getLastAccessed());
long createTime = entity.getLong(_model.getCreateTime());
long cookieSet = entity.getLong(_model.getCookieSetTime());
String lastNode = entity.getString(_model.getLastNode());
  lastSaved = entity.getLong(_model.getLastSaved());
long expiry = entity.getLong(_model.getExpiry());
long maxInactive = entity.getLong(_model.getMaxInactive());
Blob blob = (Blob) entity.getBlob(_model.getAttributes());

代码示例来源：origin: sai-pullabhotla/catatumbo

long version = nativeEntity.getLong(versionPropertyName) - 1;
long storedVersion = storedNativeEntity.getLong(versionPropertyName);
if (version != storedVersion) {
 throw new OptimisticLockException(

代码示例来源：origin: org.eclipse.jetty.gcloud/jetty-gcloud-session-manager

info.add(new ExpiryInfo(entity.getString(_model.getId()),entity.getString(_model.getLastNode()), entity.getLong(_model.getExpiry())));

代码示例来源：origin: org.eclipse.jetty.gcloud/jetty-gcloud-session-manager

return !isExpired(entity.getLong(_model.getExpiry()));

代码示例来源：origin: spotify/styx

static Backfill entityToBackfill(Entity entity) throws IOException {
 final WorkflowId workflowId = WorkflowId.create(entity.getString(PROPERTY_COMPONENT),
                         entity.getString(PROPERTY_WORKFLOW));
 final BackfillBuilder builder = Backfill.newBuilder()
   .id(entity.getKey().getName())
   .start(timestampToInstant(entity.getTimestamp(PROPERTY_START)))
   .end(timestampToInstant(entity.getTimestamp(PROPERTY_END)))
   .workflowId(workflowId)
   .concurrency((int) entity.getLong(PROPERTY_CONCURRENCY))
   .nextTrigger(timestampToInstant(entity.getTimestamp(PROPERTY_NEXT_TRIGGER)))
   .schedule(Schedule.parse(entity.getString(PROPERTY_SCHEDULE)))
   .allTriggered(entity.getBoolean(PROPERTY_ALL_TRIGGERED))
   .halted(entity.getBoolean(PROPERTY_HALTED))
   .reverse(read(entity, PROPERTY_REVERSE, Boolean.FALSE));
 if (entity.contains(PROPERTY_DESCRIPTION)) {
  builder.description(entity.getString(PROPERTY_DESCRIPTION));
 }
 if (entity.contains(PROPERTY_TRIGGER_PARAMETERS)) {
  builder.triggerParameters(OBJECT_MAPPER.readValue(
    entity.getString(PROPERTY_TRIGGER_PARAMETERS), TriggerParameters.class));
 }
 return builder.build();
}

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

Entity

相关文章

    查看更多

    热门标签

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

    最新文章

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