我正在尝试从spark写入redis。但是我收到一个编译时错误，提示“无法在redis.clients.jedis.Jedis中访问类BinaryJedis中的变量管道”。我的代码如下(部分展示):importorg.sedis._importredis.clients.jedis._...valmyRDD=KafkaUtils.createStream(ssc,zkQuorum,group,topic).map(_._2).window(Seconds(300),Seconds(10))myRDD.foreachRDD(rdd=>{rdd.foreachPartition(it=>{

我正在设置键和值对，然后尝试通过键获取值。这是我的代码:BinaryJedisbinaryJedis=newBinaryJedis(redisUrl,redisPort,60000);byte[]data=newbyte[dataSize];ByteBufferbyteBuffer=ByteBuffer.allocate(4);byteBuffer.putInt(newRandom().nextInt());booleanflag1=binaryJedis.set(byteBuffer.array(),data).equals("OK");byte[]values=binaryJedi

我正在浏览BinaryJedis和BinaryJedisCluster文档here.对于get操作，描述为“获取指定键的值。如果键不存在，则返回特殊值‘nil’。如果键中存储的值不是字符串，则返回错误，因为GET只能处理字符串值。”对于binaryjedis，如果key不存在，返回的字节数组是否包含字符串“nil”的字节表示，还是字节数组为空？从文档中看不是很清楚。 最佳答案 如果key不存在，BinaryJedis和BinaryJedisCluster的get操作返回(byte[])null。