FunctionService - Class Diagram Function ResultSender ResultCollector FunctionContext Execution RegionFunctionContext AbstractExecution DistributedRegionFunctionExecutor MemberFunctionExecutor PartitionedRegionFunctionExecutor ServerFunctionExecutor PartitionedRegionFunctionResultSender DistributedRegionFunctionResultSender MemberFunctionResultSender ServerToClientResultSender FunctionContextImpl RegionFunctionContextImpl  

 

 

  PartionRegion Function Execution peer peer FnService FnService FnServiceManager FnServiceManager AbstractExecution AbstractExecution PRFnExecutor PRFnExecutor PR PR PRFnResultWaiter PRFnResultWaiter PRFnStreamingResultCollector PRFnStreamingResultCollector DM DM PartitionMessage PartitionMessage PRFnStreamingMessage PRFnStreamingMessage PRDataStore PRDataStore Fn Fn PRFnResultSender PRFnResultSender onRegion onRegion() constructor Execution Execution execute() executeFn() executeFn() executeOnAllBuckets() getFailedNodes() (If retry) setExecutionNodes createsPRFnResultSenderFnRemoteContext getPartitionedDataFrom() createsPRFnStreamingResultCollectorfor processing response constructor putOutgoing(PRFnStreamingMessage) operateOnPR() executeOnDataStore() createsRegionFunctionContextImplPRFnResultSender execute() sendResult() sendReplyForOneResult() putOutgoing results ResultCollector

  • No labels