JStorm和DRPC

DRPC 客户端将要执行的函数名以及相应的参数发送给DRPC server 。实现了这个函数的topology使用 DRPCSpout来接收从DRPC server传来的函数的远程调用流,从而来执行该函数。每一次函数的远程调用都被DRPC server附上了一个唯一的id。接下来topology计算结果,在最后topology中的bolt调用ReturnResults来连接DRPC server并
相关文章
相关标签/搜索