You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@storm.apache.org by Junfeng Chen <k-...@hotmail.com> on 2014/10/16 04:37:14 UTC

DRPC return value problem

Hi, I am a newbie of 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