hi Junfeng, http://storm.apache.org/documentation/Distributed-RPC.html is useful for you to understand how DRPC works.
LocalDRPC is generated from clj code https://github.com/apache/storm/blob/master/storm-core/src/clj/backtype/storm/LocalDRPC.clj . On Mon, Oct 20, 2014 at 2:14 PM, Junfeng Chen <[email protected]> wrote: > Hi, I am a newbie for the Storm. Now I meet a problem about DRPC. > > > > In the BasicDRPCTopology of sample code, drpc.execute("exclamation", word) > return a String as the result. I don’t understand how the DRPC return the > emitted value in ExclaimBolt as it declares two Tuples as output format, > while it just return "result" field. I tried to discover the source code > but no source file of the class “LocalDRPC” can be found in > storm-core\src\jvm\backtype\storm path. Could somebody explain for me? > Thanks a lot. > > > > Regard, > > Junfeng Chen > > > -- Best Regards! Kang Xiao,<[email protected]> Distributed Software Engineer
