fix - pipeline sort

This commit is contained in:
mindwind
2013-07-08 16:26:13 +08:00
parent d57bfb94a9
commit fffd119c63
3 changed files with 12 additions and 12 deletions

View File

@@ -39,9 +39,9 @@ public interface MultiKeyBinaryRedisPipeline {
Response<Long> smove(byte[] srckey, byte[] dstkey, byte[] member); Response<Long> smove(byte[] srckey, byte[] dstkey, byte[] member);
Response<List<byte[]>> sort(byte[] key, SortingParams sortingParameters, byte[] dstkey); Response<Long> sort(byte[] key, SortingParams sortingParameters, byte[] dstkey);
Response<List<byte[]>> sort(byte[] key, byte[] dstkey); Response<Long> sort(byte[] key, byte[] dstkey);
Response<Set<byte[]>> sunion(byte[]... keys); Response<Set<byte[]>> sunion(byte[]... keys);

View File

@@ -39,9 +39,9 @@ public interface MultiKeyCommandsPipeline {
Response<Long> smove(String srckey, String dstkey, String member); Response<Long> smove(String srckey, String dstkey, String member);
Response<List<String>> sort(String key, SortingParams sortingParameters, String dstkey); Response<Long> sort(String key, SortingParams sortingParameters, String dstkey);
Response<List<String>> sort(String key, String dstkey); Response<Long> sort(String key, String dstkey);
Response<Set<String>> sunion(String... keys); Response<Set<String>> sunion(String... keys);

View File

@@ -191,26 +191,26 @@ abstract class MultiKeyPipelineBase extends PipelineBase implements
return getResponse(BuilderFactory.LONG); return getResponse(BuilderFactory.LONG);
} }
public Response<List<String>> sort(String key, public Response<Long> sort(String key,
SortingParams sortingParameters, String dstkey) { SortingParams sortingParameters, String dstkey) {
client.sort(key, sortingParameters, dstkey); client.sort(key, sortingParameters, dstkey);
return getResponse(BuilderFactory.STRING_LIST); return getResponse(BuilderFactory.LONG);
} }
public Response<List<byte[]>> sort(byte[] key, public Response<Long> sort(byte[] key,
SortingParams sortingParameters, byte[] dstkey) { SortingParams sortingParameters, byte[] dstkey) {
client.sort(key, sortingParameters, dstkey); client.sort(key, sortingParameters, dstkey);
return getResponse(BuilderFactory.BYTE_ARRAY_LIST); return getResponse(BuilderFactory.LONG);
} }
public Response<List<String>> sort(String key, String dstkey) { public Response<Long> sort(String key, String dstkey) {
client.sort(key, dstkey); client.sort(key, dstkey);
return getResponse(BuilderFactory.STRING_LIST); return getResponse(BuilderFactory.LONG);
} }
public Response<List<byte[]>> sort(byte[] key, byte[] dstkey) { public Response<Long> sort(byte[] key, byte[] dstkey) {
client.sort(key, dstkey); client.sort(key, dstkey);
return getResponse(BuilderFactory.BYTE_ARRAY_LIST); return getResponse(BuilderFactory.LONG);
} }
public Response<Set<String>> sunion(String... keys) { public Response<Set<String>> sunion(String... keys) {