本文整理了Java中redis.clients.jedis.Tuple.<init>()方法的一些代码示例，展示了Tuple.<init>()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Tuple.<init>()方法的具体详情如下：
包路径：redis.clients.jedis.Tuple
类名称：Tuple
方法名：<init>

Tuple.<init>介绍

暂无

代码示例

代码示例来源：origin: Netflix/conductor

private Set<Tuple> toTupleSet(Set<ZsetPair> pairs) {
  Set<Tuple> set = new HashSet<Tuple>();
  for (ZsetPair pair : pairs) {
    set.add(new Tuple(pair.member, pair.score));
  }
  return set;
}

代码示例来源：origin: sohutv/cachecloud

@Override
@SuppressWarnings("unchecked")
public Set<Tuple> build(Object data) {
 if (null == data) {
  return null;
 }
 List<byte[]> l = (List<byte[]>) data;
 final Set<Tuple> result = new LinkedHashSet<Tuple>(l.size());
 Iterator<byte[]> iterator = l.iterator();
 while (iterator.hasNext()) {
  result.add(new Tuple(iterator.next(), Double.valueOf(SafeEncoder.encode(iterator.next()))));
 }
 return result;
}

代码示例来源：origin: sohutv/cachecloud

@Override
@SuppressWarnings("unchecked")
public Set<Tuple> build(Object data) {
 if (null == data) {
  return null;
 }
 List<byte[]> l = (List<byte[]>) data;
 final Set<Tuple> result = new LinkedHashSet<Tuple>(l.size());
 Iterator<byte[]> iterator = l.iterator();
 while (iterator.hasNext()) {
  result.add(new Tuple(SafeEncoder.encode(iterator.next()), Double.valueOf(SafeEncoder
    .encode(iterator.next()))));
 }
 return result;
}

代码示例来源：origin: sohutv/cachecloud

private Set<Tuple> getBinaryTupledSet() {
 checkIsInMultiOrPipeline();
 List<byte[]> membersWithScores = client.getBinaryMultiBulkReply();
 if (membersWithScores.size() == 0) {
  return Collections.emptySet();
 }
 Set<Tuple> set = new LinkedHashSet<Tuple>(membersWithScores.size() / 2, 1.0f);
 Iterator<byte[]> iterator = membersWithScores.iterator();
 while (iterator.hasNext()) {
  set.add(new Tuple(iterator.next(), Double.valueOf(SafeEncoder.encode(iterator.next()))));
 }
 return set;
}

代码示例来源：origin: sohutv/cachecloud

private Set<Tuple> getTupledSet() {
 checkIsInMultiOrPipeline();
 List<String> membersWithScores = client.getMultiBulkReply();
 if (membersWithScores == null) {
  return null;
 }
 if (membersWithScores.size() == 0) {
  return Collections.emptySet();
 }
 Set<Tuple> set = new LinkedHashSet<Tuple>(membersWithScores.size() / 2, 1.0f);
 Iterator<String> iterator = membersWithScores.iterator();
 while (iterator.hasNext()) {
  set.add(new Tuple(iterator.next(), Double.valueOf(iterator.next())));
 }
 return set;
}

代码示例来源：origin: Netflix/conductor

public ScanResult<Tuple> zscan(final String key, final String cursor) {
  try {
    org.rarefiedredis.redis.ScanResult<Set<ZsetPair>> sr = redis.zscan(key, Long.valueOf(cursor), "count", "1000000");
    List<ZsetPair> list = sr.results.stream().collect(Collectors.toList());
    List<Tuple> tl = new LinkedList<Tuple>();
    list.forEach(p -> tl.add(new Tuple(p.member, p.score)));
    ScanResult<Tuple> result = new ScanResult<Tuple>("0", tl);
    return result;
  }
  catch (Exception e) {
    throw new JedisException(e);
  }
}

代码示例来源：origin: sohutv/cachecloud

public ScanResult<Tuple> zscan(final byte[] key, final byte[] cursor, final ScanParams params) {
 checkIsInMultiOrPipeline();
 client.zscan(key, cursor, params);
 List<Object> result = client.getObjectMultiBulkReply();
 byte[] newcursor = (byte[]) result.get(0);
 List<Tuple> results = new ArrayList<Tuple>();
 List<byte[]> rawResults = (List<byte[]>) result.get(1);
 Iterator<byte[]> iterator = rawResults.iterator();
 while (iterator.hasNext()) {
  results.add(new Tuple(iterator.next(), Double.valueOf(SafeEncoder.encode(iterator.next()))));
 }
 return new ScanResult<Tuple>(newcursor, results);
}

代码示例来源：origin: sohutv/cachecloud

@Override
public ScanResult<Tuple> zscan(final String key, final String cursor, final ScanParams params) {
 checkIsInMultiOrPipeline();
 client.zscan(key, cursor, params);
 List<Object> result = client.getObjectMultiBulkReply();
 String newcursor = new String((byte[]) result.get(0));
 List<Tuple> results = new ArrayList<Tuple>();
 List<byte[]> rawResults = (List<byte[]>) result.get(1);
 Iterator<byte[]> iterator = rawResults.iterator();
 while (iterator.hasNext()) {
  results.add(new Tuple(SafeEncoder.encode(iterator.next()), Double.valueOf(SafeEncoder
    .encode(iterator.next()))));
 }
 return new ScanResult<Tuple>(newcursor, results);
}

代码示例来源：origin: Netflix/conductor

private Set<Tuple> toTupleSet(Set<ZsetPair> pairs) {
  Set<Tuple> set = new HashSet<Tuple>();
  for (ZsetPair pair : pairs) {
    set.add(new Tuple(pair.member, pair.score));
  }
  return set;
}

代码示例来源：origin: Netflix/conductor

public ScanResult<Tuple> zscan(final String key, final String cursor) {
  try {
    org.rarefiedredis.redis.ScanResult<Set<ZsetPair>> sr = redis.zscan(key, Long.valueOf(cursor), "count", "1000000");
    List<ZsetPair> list = sr.results.stream().collect(Collectors.toList());
    List<Tuple> tl = new LinkedList<Tuple>();
    list.forEach(p -> tl.add(new Tuple(p.member, p.score)));
    ScanResult<Tuple> result = new ScanResult<Tuple>("0", tl);
    return result;
  }
  catch (Exception e) {
    throw new JedisException(e);
  }
}

代码示例来源：origin: com.netflix.conductor/conductor-redis-persistence

private Set<Tuple> toTupleSet(Set<ZsetPair> pairs) {
  Set<Tuple> set = new HashSet<Tuple>();
  for (ZsetPair pair : pairs) {
    set.add(new Tuple(pair.member, pair.score));
  }
  return set;
}

代码示例来源：origin: io.leopard/leopard-biz

@Override
public Set<Tuple> listAll() {
  Set<Entry<String, Double>> set = data.entrySet();
  if (set == null || set.isEmpty()) {
    return null;
  }
  Set<Tuple> result = new HashSet<Tuple>();
  for (Entry<String, Double> entry : set) {
    Tuple tuple = new Tuple(entry.getKey(), entry.getValue());
    result.add(tuple);
  }
  return result;
}

代码示例来源：origin: apache/servicemix-bundles

@Override
@SuppressWarnings("unchecked")
public Set<Tuple> build(Object data) {
 if (null == data) {
  return null;
 }
 List<byte[]> l = (List<byte[]>) data;
 final Set<Tuple> result = new LinkedHashSet<Tuple>(l.size()/2, 1);
 Iterator<byte[]> iterator = l.iterator();
 while (iterator.hasNext()) {
  result.add(new Tuple(iterator.next(), DOUBLE.build(iterator.next())));
 }
 return result;
}

代码示例来源：origin: apache/servicemix-bundles

protected Set<Tuple> getTupledSet() {
 List<byte[]> membersWithScores = client.getBinaryMultiBulkReply();
 if (membersWithScores.isEmpty()) {
  return Collections.emptySet();
 }
 Set<Tuple> set = new LinkedHashSet<Tuple>(membersWithScores.size() / 2, 1.0f);
 Iterator<byte[]> iterator = membersWithScores.iterator();
 while (iterator.hasNext()) {
  set.add(new Tuple(iterator.next(), BuilderFactory.DOUBLE.build(iterator.next())));
 }
 return set;
}

代码示例来源：origin: io.leopard/leopard-redis

@Override
public Set<Tuple> zrevrangeWithScores(String key, long start, long end) {
  Set<Tuple> set = new LinkedHashSet<Tuple>();
  List<Entry<String, Double>> list = this.revlist(key);
  long index = 0;
  for (Entry<String, Double> entry : list) {
    System.out.println("key:" + entry.getKey() + " value:" + entry.getValue());
    if (this.checkIndex(start, end, index)) {
      Tuple tuple = new Tuple(entry.getKey(), entry.getValue());
      set.add(tuple);
    }
    index++;
  }
  return set;
}

代码示例来源：origin: com.netflix.conductor/conductor-redis-persistence

public ScanResult<Tuple> zscan(final String key, final String cursor) {
  try {
    org.rarefiedredis.redis.ScanResult<Set<ZsetPair>> sr = redis.zscan(key, Long.valueOf(cursor), "count", "1000000");
    List<ZsetPair> list = sr.results.stream().collect(Collectors.toList());
    List<Tuple> tl = new LinkedList<Tuple>();
    list.forEach(p -> tl.add(new Tuple(p.member, p.score)));
    ScanResult<Tuple> result = new ScanResult<Tuple>("0", tl);
    return result;
  }
  catch (Exception e) {
    throw new JedisException(e);
  }
}

代码示例来源：origin: apache/servicemix-bundles

@Override
public ScanResult<Tuple> zscan(final String key, final String cursor, final ScanParams params) {
 checkIsInMultiOrPipeline();
 client.zscan(key, cursor, params);
 List<Object> result = client.getObjectMultiBulkReply();
 String newcursor = new String((byte[]) result.get(0));
 List<Tuple> results = new ArrayList<Tuple>();
 List<byte[]> rawResults = (List<byte[]>) result.get(1);
 Iterator<byte[]> iterator = rawResults.iterator();
 while (iterator.hasNext()) {
  results.add(new Tuple(iterator.next(), BuilderFactory.DOUBLE.build(iterator.next())));
 }
 return new ScanResult<Tuple>(newcursor, results);
}

代码示例来源：origin: apache/servicemix-bundles

@Override
public ScanResult<Tuple> zscan(final byte[] key, final byte[] cursor, final ScanParams params) {
 checkIsInMultiOrPipeline();
 client.zscan(key, cursor, params);
 List<Object> result = client.getObjectMultiBulkReply();
 byte[] newcursor = (byte[]) result.get(0);
 List<Tuple> results = new ArrayList<Tuple>();
 List<byte[]> rawResults = (List<byte[]>) result.get(1);
 Iterator<byte[]> iterator = rawResults.iterator();
 while (iterator.hasNext()) {
  results.add(new Tuple(iterator.next(), BuilderFactory.DOUBLE.build(iterator.next())));
 }
 return new ScanResult<Tuple>(newcursor, results);
}

代码示例来源：origin: Netflix/dyno-queues

private Set<Tuple> toTupleSet(Set<ZsetPair> pairs) {
  Set<Tuple> set = new HashSet<Tuple>();
  for (ZsetPair pair : pairs) {
    set.add(new Tuple(pair.member, pair.score));
  }
  return set;
}

代码示例来源：origin: Netflix/dyno-queues

public ScanResult<Tuple> zscan(final String key, final String cursor) {
    try {
      org.rarefiedredis.redis.ScanResult<Set<ZsetPair>> sr = redis.zscan(key, Long.valueOf(cursor), "count", "1000000");
      List<ZsetPair> list = sr.results.stream().collect(Collectors.toList());
      List<Tuple> tl = new LinkedList<Tuple>();
      list.forEach(p -> tl.add(new Tuple(p.member, p.score)));
      ScanResult<Tuple> result = new ScanResult<Tuple>("0", tl);
      return result;
    } catch (Exception e) {
      throw new JedisException(e);
    }
  }
}