Toggle navigation
Home
org.redisson.client.protocol.decoder.ScanObjectEntry to java.lang.Object
No. of Instances - 60
No. of Commits - 1
No. of Projects - {'redisson'}
Hierarchy/Composition: Composition
Primitive Info: -
NameSpace: Internal -> Jdk
Mapping:
Cascading Type Change (Different)
RFuture<ListScanResult<ScanObjectEntry>>
to
RFuture<ListScanResult<Object>>
RFuture<MapScanResult<ScanObjectEntry,ScanObjectEntry>>
to
RFuture<MapScanResult<Object,Object>>
FutureListener<MapCacheScanResult<ScanObjectEntry,ScanObjectEntry>>
to
FutureListener<MapCacheScanResult<Object,Object>>
Cascading Type Change (Similar)
RFuture<MapScanResult<ScanObjectEntry,ScanObjectEntry>>
to
RFuture<MapScanResult<Object,Object>>
Other
new ScanCodec(codec)
to
codec
new MapScanCodec(codec)
to
codec
new ScanCodec(codec)
to
codec
new ScanCodec(codec)
to
codec
Rename Method invocation
e.getValue().getObj()
to
e.getValue()
Update Anonymous class
{ @Override public void operationComplete( Future<MapCacheScanResult<ScanObjectEntry,ScanObjectEntry>> future) throws Exception { if (future.isSuccess()) { MapCacheScanResult<ScanObjectEntry,ScanObjectEntry> res=future.getNow(); if (res.getIdleKeys().isEmpty()) { return; } List<Object> args=new ArrayList<Object>(res.getIdleKeys().size() + 1); args.add(System.currentTimeMillis()); encodeMapKeys(args,res.getIdleKeys()); commandExecutor.evalWriteAsync(name,codec,new RedisCommand<Map<Object,Object>>("EVAL",new MapGetAllDecoder(args,1),ValueType.MAP_VALUE),"local currentTime = tonumber(table.remove(ARGV, 1)); " + "local map = redis.call('hmget', KEYS[1], unpack(ARGV)); " + "for i = #map, 1, -1 do "+ "local value = map[i]; "+ "if value ~= false then "+ "local key = ARGV[i]; "+ "local t, val = struct.unpack('dLc0', value); "+ "if t ~= 0 then "+ "local expireIdle = redis.call('zscore', KEYS[2], key); "+ "if expireIdle ~= false then "+ "if tonumber(expireIdle) > currentTime then "+ "redis.call('zadd', KEYS[2], t + currentTime, key); "+ "end; "+ "end; "+ "end; "+ "end; "+ "end; ",Arrays.<Object>asList(name,getIdleSetName(name)),args.toArray()); } } }
to
{ @Override public void operationComplete( Future<MapCacheScanResult<Object,Object>> future) throws Exception { if (future.isSuccess()) { MapCacheScanResult<Object,Object> res=future.getNow(); if (res.getIdleKeys().isEmpty()) { return; } List<Object> args=new ArrayList<Object>(res.getIdleKeys().size() + 1); args.add(System.currentTimeMillis()); encodeMapKeys(args,res.getIdleKeys()); commandExecutor.evalWriteAsync(name,codec,new RedisCommand<Map<Object,Object>>("EVAL",new MapGetAllDecoder(args,1),ValueType.MAP_VALUE),"local currentTime = tonumber(table.remove(ARGV, 1)); " + "local map = redis.call('hmget', KEYS[1], unpack(ARGV)); " + "for i = #map, 1, -1 do "+ "local value = map[i]; "+ "if value ~= false then "+ "local key = ARGV[i]; "+ "local t, val = struct.unpack('dLc0', value); "+ "if t ~= 0 then "+ "local expireIdle = redis.call('zscore', KEYS[2], key); "+ "if expireIdle ~= false then "+ "if tonumber(expireIdle) > currentTime then "+ "redis.call('zadd', KEYS[2], t + currentTime, key); "+ "end; "+ "end; "+ "end; "+ "end; "+ "end; ",Arrays.<Object>asList(name,getIdleSetName(name)),args.toArray()); } } }