support compress

recommend-feature-produce/src/main/java/com/tzld/piaoquan/recommend/feature/produce/service/RedisService.java

@@ -6,7 +6,6 @@ import com.tzld.piaoquan.recommend.feature.produce.util.JSONUtils;
 import org.apache.commons.collections.CollectionUtils;
 import org.apache.commons.collections.MapUtils;
 import org.apache.commons.lang3.StringUtils;
-import org.apache.commons.lang3.tuple.Pair;
 import redis.clients.jedis.Jedis;
 import redis.clients.jedis.Pipeline;
 
@@ -37,24 +36,6 @@ public class RedisService implements Serializable {
         }
     }
 
-    private void mSetEx(Iterator<Pair<String, String>> keyValues, long expire, TimeUnit timeUnit) {
-        Jedis jedis = new Jedis(hostName, port);
-        jedis.auth(password);
-        Pipeline pipeline = jedis.pipelined();
-        while (keyValues.hasNext()) {
-            Pair<String, String> p = keyValues.next();
-            pipeline.setex(p.getLeft(), timeUnit.toSeconds(expire), p.getRight());
-        }
-        pipeline.sync();
-        jedis.close();
-    }
-
-    public void mSet(Iterator<Pair<String, String>> keyValues, DTSConfig config) {
-        long expire = config.getRedis().getExpire();
-        mSetEx(keyValues, expire, TimeUnit.SECONDS);
-    }
-
-
     public void mSetV2(Iterator<Map<String, String>> dataIte, DTSConfig config) {
         Map<String, String> batch = new HashMap<>();
         Jedis jedis = new Jedis(hostName, port);