com.aerospike.client.Value.toLong()方法的使用及代码示例

x33g5p2x  于2022-02-01 转载在 其他  
字(4.5k)|赞(0)|评价(0)|浏览(75)

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

Value.toLong介绍

[英]Return value as a long.
[中]

代码示例

代码示例来源:origin: spring-projects/spring-data-aerospike

public Long convert(Bin source) {
    return source.value.toLong();
  }
}

代码示例来源:origin: com.spikeify/core

private K prepareKey(Key key){
    switch (keyType) {
      case KEY:
        return (K) key;
      case LONG:
        return (K) (Long) key.userKey.toLong();
      case STRING:
        return (K) key.userKey.toString();
      default:
        throw new IllegalStateException("Error: unsupported key type. Must be one of: Key, Long or String"); // should not happen
    }
  }
}

代码示例来源:origin: aerospike/aerospike-client-java

private Filter collectionRange(IndexCollectionType collectionType) {
  return Filter.range(getField(), collectionType, getValue1().toLong(), getValue2().toLong());
}

代码示例来源:origin: aerospike/aerospike-client-java

private Filter collectionContains(IndexCollectionType collectionType) {
  Value val = getValue1();
  int valType = val.getType();
  switch (valType) {
    case ParticleType.INTEGER:
      return Filter.contains(getField(), collectionType, val.toLong());
    case ParticleType.STRING:
      return Filter.contains(getField(), collectionType, val.toString());
  }
  return null;
}

代码示例来源:origin: com.spikeify/core

break;
case LONG:
  Long longKey = key.userKey.toLong();
  result.put((K) longKey, object);
  break;

代码示例来源:origin: com.spikeify/core

/**
   * Performs common mapping task when loading an entity ... used in loaders
   * see {@link com.spikeify.commands.SingleLoader} {@link com.spikeify.commands.MultiLoader} {@link com.spikeify.commands.ScanLoader}
   * @param mapper to be used
   * @param key record key
   * @param record record value
   * @param object object holding data
   */
  public static void map(ClassMapper mapper, Key key, Record record, Object object) {
    // set UserKey field
    switch (key.userKey.getType()) {
      case ParticleType.STRING:
        mapper.setUserKey(object, key.userKey.toString());
        break;
      case ParticleType.INTEGER:
        mapper.setUserKey(object, key.userKey.toLong());
        break;
    }

    // set meta-fields on the entity: @Namespace, @SetName, @Expiration..
    mapper.setMetaFieldValues(object, key.namespace, key.setName, record.generation, record.expiration);

    // set field values
    mapper.setFieldValues(object, record.bins);
  }
}

代码示例来源:origin: aerospike/aerospike-client-java

private PredExp[] valToPredExp(Value val) throws PredExpException {
  int valType = val.getType();
  switch (valType) {
    case ParticleType.INTEGER:
      return new PredExp[]{
          getFieldExpr(valType),
          PredExp.integerValue(val.toLong())};
    case ParticleType.STRING:
      return new PredExp[]{
          getFieldExpr(valType),
          PredExp.stringValue(val.toString())};
    case ParticleType.GEOJSON:
      return new PredExp[]{
          getFieldExpr(valType),
          PredExp.geoJSONValue(val.toString())};
    default:
      throw new PredExpException("PredExp Unsupported Particle Type: " + val.getType());
  }
}

代码示例来源:origin: aerospike/aerospike-client-java

case EQ:
  if (getValue1().getType() == ParticleType.INTEGER)
    return Filter.equal(getField(), getValue1().toLong());
  else
    return Filter.equal(getField(), getValue1().toString());
case GTEQ:
case BETWEEN:
  return Filter.range(getField(), getValue1().toLong(), getValue2()==null?Long.MAX_VALUE:getValue2().toLong());
case GT:
  return Filter.range(getField(), getValue1().toLong()+1, getValue2()==null?Long.MAX_VALUE:getValue2().toLong());
case LT:
  return Filter.range(getField(), Long.MIN_VALUE, getValue1().toLong()-1);
case LTEQ:
  return Filter.range(getField(),  Long.MIN_VALUE, getValue1().toLong()+1);
case LIST_CONTAINS:
  return collectionContains(IndexCollectionType.LIST);

代码示例来源:origin: aerospike/aerospike-client-java

case ParticleType.INTEGER:
  rs.add(getFieldExpr(valType));
  rs.add(PredExp.integerValue(val.toLong()));
  rs.add(PredExp.integerEqual());
  break;

代码示例来源:origin: com.spikeify/core

private T getObject() {
  Record record = recordSet.getRecord();
  Key key = recordSet.getKey();
  // construct the entity object via provided ClassConstructor
  T object = classConstructor.construct(mapper.getType());
  // save record hash into cache - used later for differential updating
  recordsCache.insert(key, record.bins);
  // set UserKey field
  switch (key.userKey.getType()) {
    case ParticleType.STRING:
      mapper.setUserKey(object, key.userKey.toString());
      break;
    case ParticleType.INTEGER:
      mapper.setUserKey(object, key.userKey.toLong());
      break;
  }
  // set meta-fields on the entity: @Namespace, @SetName, @Expiration..
  mapper.setMetaFieldValues(object, key.namespace, key.setName, record.generation, record.expiration);
  // set field values
  mapper.setFieldValues(object, record.bins);
  // set LDT fields
  mapper.setBigDatatypeFields(object, asynClient, key);
  return object;
}

代码示例来源:origin: com.spikeify/core

break;
case ParticleType.INTEGER:
  existingRec.userKeyLong = key.userKey.toLong();
  break;

相关文章

微信公众号

最新文章

更多