Spark streaming 做实时数据处理的问题

问题描述

现在基于sparkstreaming做在线查询，按照我看完资料的认识，streamingcontext启动后，就不能再添加新的streaming计算或操作进去，这样一来，如果我想要实时做多种查询，是否意味着必须反复重启streamingContext才能实现？因为对storm不是很了解，不知道storm这方面是否有实现的方法？希望有经验的朋友能解答一下。

解决方案

解决方案二：
对查询条件做逻辑判断，根据你传入的查询类型，调用不同的计算
解决方案三：
引用1楼dlh13061201的回复:

对查询条件做逻辑判断，根据你传入的查询类型，调用不同的计算

foreachrdd里解析出每条数据，然后在foreachrdd里写rdd的逻辑，不用写Dstream的逻辑