Fix TDIGEST.CREATE

Author: dengliming

redisbloom/src/main/java/io/github/dengliming/redismodule/redisbloom/TDigest.java

@@ -28,6 +28,7 @@
 import java.util.ArrayList;
 import java.util.List;
 
+import static io.github.dengliming.redismodule.redisbloom.protocol.Keywords.COMPRESSION;
 import static io.github.dengliming.redismodule.redisbloom.protocol.RedisCommands.TDIGEST_ADD;
 import static io.github.dengliming.redismodule.redisbloom.protocol.RedisCommands.TDIGEST_CDF;
 import static io.github.dengliming.redismodule.redisbloom.protocol.RedisCommands.TDIGEST_CREATE;
@@ -61,7 +62,7 @@ public boolean create(long compression) {
     }
 
     public RFuture<Boolean> createAsync(long compression) {
-        return commandExecutor.writeAsync(getName(), codec, TDIGEST_CREATE, getName(), compression);
+        return commandExecutor.writeAsync(getName(), codec, TDIGEST_CREATE, getName(), COMPRESSION, compression);
     }
 
     /**

redisbloom/src/main/java/io/github/dengliming/redismodule/redisbloom/protocol/Keywords.java

@@ -21,5 +21,5 @@
  */
 public enum Keywords {
     CAPACITY, ERROR, EXPANSION, NOCREATE, NONSCALING, ITEMS, WEIGHTS,
-    BUCKETSIZE, MAXITERATIONS;
+    BUCKETSIZE, MAXITERATIONS, COMPRESSION
 }

redisbloom/src/main/java/io/github/dengliming/redismodule/redisbloom/protocol/decoder/TDigestDecoder.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2021 dengliming.
+ * Copyright 2021-2022 dengliming.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -28,6 +28,6 @@ public class TDigestDecoder implements MultiDecoder<TDigestInfo> {
     public TDigestInfo decode(List<Object> parts, State state) {
         return new TDigestInfo((Long) parts.get(1), (Long) parts.get(3), (Long) parts.get(5), (Long) parts.get(7),
                 Double.parseDouble(String.valueOf(parts.get(9))), Double.parseDouble(String.valueOf(parts.get(11))),
-                (Long) parts.get(13));
+                Long.valueOf(String.valueOf(parts.get(13))));
     }
 }