本文整理了Java中com.aerospike.client.Value.toLong()
方法的一些代码示例,展示了Value.toLong()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Value.toLong()
方法的具体详情如下:
包路径:com.aerospike.client.Value
类名称: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;
内容来源于网络,如有侵权,请联系作者删除!