我正在尝试在Clojure项目中使用Apache和Redis。我的project.clj看起来是这样的： :description "FIXME: write description"/storm-core "0.9.5"]Redis</e
浏览 1提问于2015-09-11得票数 1
回答已采纳
2回答
我当前的java螺栓和导入是：import backtype.storm.Config;import storm.external.storm-redis.org.apache.storm.redis.commo
浏览 4提问于2015-11-17得票数 1
回答已采纳
我已经创建了一个Storm拓扑，它使用Jedis库连接到Redis集群。Storm组件总是期望Redis已经启动并运行，只有这样它才能连接到Redis并订阅events.Currently，我们使用Redis的发布子策略。listener.start();一旦Redis死亡并恢复在线，Storm预计
浏览 1提问于2018-06-18得票数 9
1回答
用于流应用的时间序列窗口
、、、、
我们正在使用Kafka，storm和redis开发数据管道应用程序。来自不同系统的实时事件将发布到Kafka，storm根据配置的规则进行事件处理。状态是用redis管理的。我们需要根据规则改变wait_timeredis是否支持驱逐回调？有没有更好的方法来处理storm和redis？
浏览 0提问于2017-07-05得票数 1
1回答
;import org.apache.storm.redis.common.config.JedisClusterConfig;import org.apache.storm.redis.common.mapper.RedisD
浏览 3提问于2016-01-28得票数 0
回答已采纳
1回答
我接收流数据，用Kafka和Storm处理，最后写到Redis。现在，我想将Redis中存储的所有数据再次推送/拉取到Storm中，以便进行进一步的计算。问题是，这必须每分钟重复一次。因此，每分钟都必须拉取/推送和计算来自Redis的所有值。我不知道这是否是解决问题的正确方法，但我需要一种缓存。你有什么建议吗？问候
浏览 16提问于2016-07-15得票数 0
;import org.apache.storm.redis.common.config.JedisClusterConfig;import org.apache.storm.redis.common.mapper.RedisD
浏览 9提问于2016-01-28得票数 0
回答已采纳
1回答
我有一个Storm拓扑，需要从Redis实例中流它的数据，我尝试运行从单个Redis实例读取的拓扑，但是似乎没有从Redis读取任何数据，而且当我检查返回的队列时，它是空的。这是我的RedisQueueSpout，它是一个spout，它将使用指定的模式(又名键)将您的拓扑插入到Redis中，每次Storm轮询它时，它都会在该模式下查找输入数据。package storm.starter.spout;
import java
浏览 2提问于2016-05-04得票数 1
回答已采纳
1回答
我尝试将端口更改为2080，而不是ZooKeeper "zoo.cfg“文件和kafka "server.properties”中的默认端口2181。但我还是犯了同样的错误。任何帮助都将不胜感激。:219) ~[storm-core-1.0.1.jar:1.0.1]
at org.apache.storm.zookeeper$mk_inprocess_zookeeper.doInvokeat org.apache.storm.command.dev_zookeeper.main(Unknown
浏览 5提问于2016-08-19得票数 2
回答已采纳
我已经设置了storm拓扑(1 worker)，其中spout(在java中)从redis出队(使用blpop)事件并传输到bolts。(ns event-processor java.util.UUIDstorm_jedis.RedisQueueSpout (:use [backtype.storm clojure config])
(:
浏览 10提问于2018-09-05得票数 1
回答已采纳
1回答
我正在使用redis从我的Storm拓扑中提取数据，我一直在阅读它，并找到了一些例子。正如我目前所理解的(如果我错了请纠正我)，redis是一个数据库，如mongoDB、非SQL和使用字段检索键。我有个暗示，但不起作用。我在一行编译时出错了，它被注释了。;import org.apache.storm.redis.commo
浏览 1提问于2016-01-11得票数 0
回答已采纳
我的Storm类使用Redis queue来收集数据。我试着用我的Storm jar但我得到了以下异常： Caused by: java.lang.ClassNotFoundException: redis.clients.jedis.JedisClassL
浏览 0提问于2014-09-03得票数 0
1回答
高速流传输数据的可视化
、、、
我正在使用Twitter Storm对高速/大数据进行实时分析。现在，我不知道如何在浏览器上以有效的方式可视化数据。我的意思是，Storm的处理速度真的非常快，storm正在集群上工作。我偶然发现了Node.js和D3.js的组合来解决这个显示问题。因为我不是UI或javascript世界的人，所以我只是想知道我的方向是对的吗？有没有人能简单地解释一下这个组合能为我提供什么？
浏览 1提问于2013-07-04得票数 2
回答已采纳
1回答
比较内存中的集群计算系统
、、、
在我的研究中，我了解了一些其他的内存系统，如Redis，Memcachedb等。如果有人能给我一个SPARK和REDIS (以及MEMCACHEDB)的比较，那就太好了。
浏览 4提问于2013-05-22得票数 10
回答已采纳
import ***.redis.PipelineHelper;import **.redis.R2mClusterClient;import org.apache.storm.task.OutputCollector;impor
浏览 0提问于2017-10-17得票数 0
1回答
应用程序如下 * Hello world!public static void main( String[] args ) RedisPubSubSpout spout = RedisPubSubSpout("redis;
import org.apa
浏览 3提问于2015-01-29得票数 0
回答已采纳
1回答
我试图在我们的系统中扩展一个组件，并考虑在Storm(三叉戟)和Spark之间应该使用什么更好的方法。为了解决上述问题，我们希望探索一些分布式计算框架(即Storm和</em
浏览 0提问于2017-01-13得票数 0
private static Redis instance = null; if (instance == null) {) { instance.init(conf); } at com.mapbar.flash.core.bo
浏览 21提问于2017-01-21得票数 0
回答已采纳
我希望看到向我的动物园管理员集群发出的所有命令，类似于MySQL中的一般日志或Redis中的“监视器”命令。这是如何做到的呢？目的是了解Storm是如何使用(用于州管理和攻击)的，一个很好的方法是运行一个示例拓扑并查看Storm发出的所有命令。
我尝试为启用调试日志，但这是不够的，有很大的噪音。
浏览 2提问于2018-02-27得票数 0
回答已采纳
1回答
我使用Storm Bolt中的Jedis将记录插入到Redis中。但是Redis突然多次刷新了我所有的数据。
浏览 29提问于2020-03-03得票数 0
回答已采纳
云服务器
ICP备案
云点播
对象存储
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号