From 7a602818fd161a5cb1b31fbf5826f416f9b02974 Mon Sep 17 00:00:00 2001 From: sazzad16 Date: Mon, 28 Oct 2019 12:46:19 +0600 Subject: [PATCH] format, re-order BuilderFactory --- .../redis/clients/jedis/BuilderFactory.java | 190 +++++++++--------- 1 file changed, 92 insertions(+), 98 deletions(-) diff --git a/src/main/java/redis/clients/jedis/BuilderFactory.java b/src/main/java/redis/clients/jedis/BuilderFactory.java index 6f5e1566b9..410f2bec0e 100644 --- a/src/main/java/redis/clients/jedis/BuilderFactory.java +++ b/src/main/java/redis/clients/jedis/BuilderFactory.java @@ -13,6 +13,7 @@ import redis.clients.jedis.util.SafeEncoder; public final class BuilderFactory { + public static final Builder DOUBLE = new Builder() { @Override public Double build(Object data) { @@ -32,6 +33,7 @@ public String toString() { return "double"; } }; + public static final Builder BOOLEAN = new Builder() { @Override public Boolean build(Object data) { @@ -43,10 +45,11 @@ public String toString() { return "boolean"; } }; + public static final Builder BYTE_ARRAY = new Builder() { @Override public byte[] build(Object data) { - return ((byte[]) data); // deleted == 1 + return (byte[]) data; } @Override @@ -65,8 +68,24 @@ public Long build(Object data) { public String toString() { return "long"; } + }; + public static final Builder> LONG_LIST = new Builder>() { + @Override + @SuppressWarnings("unchecked") + public List build(Object data) { + if (null == data) { + return null; + } + return (List) data; + } + + @Override + public String toString() { + return "List"; + } }; + public static final Builder STRING = new Builder() { @Override public String build(Object data) { @@ -77,8 +96,8 @@ public String build(Object data) { public String toString() { return "string"; } - }; + public static final Builder> STRING_LIST = new Builder>() { @Override @SuppressWarnings("unchecked") @@ -102,52 +121,34 @@ public List build(Object data) { public String toString() { return "List"; } - }; - public static final Builder> STRING_MAP = new Builder>() { - @Override - @SuppressWarnings("unchecked") - public Map build(Object data) { - final List flatHash = (List) data; - final Map hash = new HashMap<>(flatHash.size()/2, 1); - final Iterator iterator = flatHash.iterator(); - while (iterator.hasNext()) { - hash.put(SafeEncoder.encode(iterator.next()), SafeEncoder.encode(iterator.next())); - } - return hash; - } - - @Override - public String toString() { - return "Map"; - } - - }; - - public static final Builder> PUBSUB_NUMSUB_MAP = new Builder>() { + public static final Builder> STRING_SET = new Builder>() { @Override @SuppressWarnings("unchecked") - public Map build(Object data) { - final List flatHash = (List) data; - final Map hash = new HashMap<>(flatHash.size()/2, 1); - final Iterator iterator = flatHash.iterator(); - while (iterator.hasNext()) { - hash.put(SafeEncoder.encode((byte[]) iterator.next()), - String.valueOf((Long) iterator.next())); + public Set build(Object data) { + if (null == data) { + return null; } - - return hash; + List l = (List) data; + final Set result = new HashSet(l.size(), 1); + for (final byte[] barray : l) { + if (barray == null) { + result.add(null); + } else { + result.add(SafeEncoder.encode(barray)); + } + } + return result; } @Override public String toString() { - return "PUBSUB_NUMSUB_MAP"; + return "Set"; } - }; - public static final Builder> STRING_SET = new Builder>() { + public static final Builder> STRING_ZSET = new Builder>() { @Override @SuppressWarnings("unchecked") public Set build(Object data) { @@ -155,7 +156,7 @@ public Set build(Object data) { return null; } List l = (List) data; - final Set result = new HashSet<>(l.size(), 1); + final Set result = new LinkedHashSet(l.size(), 1); for (final byte[] barray : l) { if (barray == null) { result.add(null); @@ -168,9 +169,28 @@ public Set build(Object data) { @Override public String toString() { - return "Set"; + return "ZSet"; + } + }; + + public static final Builder> STRING_MAP = new Builder>() { + @Override + @SuppressWarnings("unchecked") + public Map build(Object data) { + final List flatHash = (List) data; + final Map hash = new HashMap(flatHash.size()/2, 1); + final Iterator iterator = flatHash.iterator(); + while (iterator.hasNext()) { + hash.put(SafeEncoder.encode(iterator.next()), SafeEncoder.encode(iterator.next())); + } + + return hash; } + @Override + public String toString() { + return "Map"; + } }; public static final Builder> BYTE_ARRAY_LIST = new Builder>() { @@ -236,47 +256,23 @@ public String toString() { }; - public static final Builder> STRING_ZSET = new Builder>() { - @Override - @SuppressWarnings("unchecked") - public Set build(Object data) { - if (null == data) { - return null; - } - List l = (List) data; - final Set result = new LinkedHashSet<>(l.size(), 1); - for (final byte[] barray : l) { - if (barray == null) { - result.add(null); - } else { - result.add(SafeEncoder.encode(barray)); - } - } - return result; - } - - @Override - public String toString() { - return "ZSet"; - } - - }; - public static final Builder TUPLE = new Builder() { @Override @SuppressWarnings("unchecked") public Tuple build(Object data) { - if (null == data) return null; + if (null == data) { // *Never* null. Still it doesn't hurt to be safe for future. + return null; + } List l = (List) data; - if (l.isEmpty()) return null; - return new Tuple(l.get(0), DOUBLE.build(l.get(1))); + Iterator i = l.iterator(); + if (i.hasNext()) return new Tuple(i.next(), DOUBLE.build(i.next())); + return null; } @Override public String toString() { return "Tuple"; } - }; public static final Builder> TUPLE_ZSET = new Builder>() { @@ -299,7 +295,27 @@ public Set build(Object data) { public String toString() { return "ZSet"; } + }; + public static final Builder> PUBSUB_NUMSUB_MAP = new Builder>() { + @Override + @SuppressWarnings("unchecked") + public Map build(Object data) { + final List flatHash = (List) data; + final Map hash = new HashMap(flatHash.size()/2, 1); + final Iterator iterator = flatHash.iterator(); + while (iterator.hasNext()) { + hash.put(SafeEncoder.encode((byte[]) iterator.next()), + String.valueOf((Long) iterator.next())); + } + + return hash; + } + + @Override + public String toString() { + return "PUBSUB_NUMSUB_MAP"; + } }; public static final Builder EVAL_RESULT = new Builder() { @@ -366,16 +382,8 @@ public List build(Object data) { if (null == data) { return null; } - return interpretGeoposResult((List) data); - } - - @Override - public String toString() { - return "List"; - } - - private List interpretGeoposResult(List responses) { - List responseCoordinate = new ArrayList<>(responses.size()); + List responses = (List) data; + List responseCoordinate = new ArrayList(responses.size()); for (Object response : responses) { if (response == null) { responseCoordinate.add(null); @@ -388,6 +396,11 @@ private List interpretGeoposResult(List responses) { } return responseCoordinate; } + + @Override + public String toString() { + return "List"; + } }; public static final Builder> GEORADIUS_WITH_PARAMS_RESULT = new Builder>() { @@ -441,7 +454,7 @@ public List build(Object data) { @Override public String toString() { - return "GeoRadiusWithParamsResult"; + return "List"; } }; @@ -474,23 +487,6 @@ public String toString() { } }; - public static final Builder> LONG_LIST = new Builder>() { - @Override - @SuppressWarnings("unchecked") - public List build(Object data) { - if (null == data) { - return null; - } - return (List) data; - } - - @Override - public String toString() { - return "List"; - } - - }; - public static final Builder STREAM_ENTRY_ID = new Builder() { @Override @SuppressWarnings("unchecked") @@ -583,8 +579,6 @@ public String toString() { } }; - - private BuilderFactory() { throw new InstantiationError( "Must not instantiate this class" ); }