You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@geode.apache.org by Dan Smith <ds...@pivotal.io> on 2016/08/17 17:41:16 UTC
Review Request 51187: GEODE-1760 Sending partial results to user's
ResultCollector
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/51187/
-----------------------------------------------------------
Review request for geode and Barry Oglesby.
Repository: geode
Description
-------
For non-HA functions on the client, results will now be passed to the
user's result collector, even if some nodes fail due to a bucket movement
or cache close.
Diffs
-----
geode-core/src/main/java/com/gemstone/gemfire/cache/client/internal/ExecuteRegionFunctionOp.java d1540204546604ff7ed3d3d490ac40d079ac2953
geode-core/src/main/java/com/gemstone/gemfire/cache/client/internal/ExecuteRegionFunctionSingleHopOp.java ce7c3f84092f59051e5a148a42cc6f06adc787fe
geode-core/src/main/java/com/gemstone/gemfire/cache/client/internal/SingleHopClientExecutor.java 30cac5bbf1f47652c3d951c26b76e1bb69b8a9b6
geode-core/src/main/java/com/gemstone/gemfire/internal/cache/PartitionedRegion.java 9ac95a1f9c0ab880d6cab8a350bd9c4842797d5d
geode-core/src/main/java/com/gemstone/gemfire/internal/cache/execute/AbstractExecution.java 2e981a85b91471a86538d113b5e16d2c67f8e9a7
geode-core/src/main/java/com/gemstone/gemfire/internal/cache/execute/FunctionStreamingResultCollector.java 7ed908ec8280318a9ad6a1c57780e23eabdaf896
geode-core/src/main/java/com/gemstone/gemfire/internal/cache/execute/LocalResultCollectorImpl.java 23eb70a787037d7cb5edefa8043aa07882b38677
geode-core/src/main/java/com/gemstone/gemfire/internal/cache/execute/PartitionedRegionFunctionResultSender.java d16e9b58fa333f2ef8176759f7d6687e40bc11b6
geode-core/src/main/java/com/gemstone/gemfire/internal/cache/execute/ServerToClientFunctionResultSender.java 9a3b5d8cdc38847c56f61716594d5f60f63efdfc
geode-core/src/main/java/com/gemstone/gemfire/internal/cache/execute/ServerToClientFunctionResultSender65.java 4cc80a39738bd8c79e72c9d2120b062a1e4cf9b4
geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/PRFunctionStreamingResultCollector.java 5fe869a36304f5f9d10029fdfef92bd8473c9dc3
geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteFunction70.java 528e462953b038737880a3f025c2cbc741ea9535
geode-core/src/test/java/com/gemstone/gemfire/internal/cache/functions/TestFunction.java d1b1aa519fa257fd65f9e420df33939f831d7dbe
Diff: https://reviews.apache.org/r/51187/diff/
Testing
-------
Thanks,
Dan Smith
Re: Review Request 51187: GEODE-1760 Sending partial results to user's
ResultCollector
Posted by Barry Oglesby <bo...@pivotal.io>.
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/51187/#review146032
-----------------------------------------------------------
Ship it!
Ship It!
- Barry Oglesby
On Aug. 17, 2016, 5:41 p.m., Dan Smith wrote:
>
> -----------------------------------------------------------
> This is an automatically generated e-mail. To reply, visit:
> https://reviews.apache.org/r/51187/
> -----------------------------------------------------------
>
> (Updated Aug. 17, 2016, 5:41 p.m.)
>
>
> Review request for geode and Barry Oglesby.
>
>
> Repository: geode
>
>
> Description
> -------
>
> For non-HA functions on the client, results will now be passed to the
> user's result collector, even if some nodes fail due to a bucket movement
> or cache close.
>
>
> Diffs
> -----
>
> geode-core/src/main/java/com/gemstone/gemfire/cache/client/internal/ExecuteRegionFunctionOp.java d1540204546604ff7ed3d3d490ac40d079ac2953
> geode-core/src/main/java/com/gemstone/gemfire/cache/client/internal/ExecuteRegionFunctionSingleHopOp.java ce7c3f84092f59051e5a148a42cc6f06adc787fe
> geode-core/src/main/java/com/gemstone/gemfire/cache/client/internal/SingleHopClientExecutor.java 30cac5bbf1f47652c3d951c26b76e1bb69b8a9b6
> geode-core/src/main/java/com/gemstone/gemfire/internal/cache/PartitionedRegion.java 9ac95a1f9c0ab880d6cab8a350bd9c4842797d5d
> geode-core/src/main/java/com/gemstone/gemfire/internal/cache/execute/AbstractExecution.java 2e981a85b91471a86538d113b5e16d2c67f8e9a7
> geode-core/src/main/java/com/gemstone/gemfire/internal/cache/execute/FunctionStreamingResultCollector.java 7ed908ec8280318a9ad6a1c57780e23eabdaf896
> geode-core/src/main/java/com/gemstone/gemfire/internal/cache/execute/LocalResultCollectorImpl.java 23eb70a787037d7cb5edefa8043aa07882b38677
> geode-core/src/main/java/com/gemstone/gemfire/internal/cache/execute/PartitionedRegionFunctionResultSender.java d16e9b58fa333f2ef8176759f7d6687e40bc11b6
> geode-core/src/main/java/com/gemstone/gemfire/internal/cache/execute/ServerToClientFunctionResultSender.java 9a3b5d8cdc38847c56f61716594d5f60f63efdfc
> geode-core/src/main/java/com/gemstone/gemfire/internal/cache/execute/ServerToClientFunctionResultSender65.java 4cc80a39738bd8c79e72c9d2120b062a1e4cf9b4
> geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/PRFunctionStreamingResultCollector.java 5fe869a36304f5f9d10029fdfef92bd8473c9dc3
> geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteFunction70.java 528e462953b038737880a3f025c2cbc741ea9535
> geode-core/src/test/java/com/gemstone/gemfire/internal/cache/functions/TestFunction.java d1b1aa519fa257fd65f9e420df33939f831d7dbe
>
> Diff: https://reviews.apache.org/r/51187/diff/
>
>
> Testing
> -------
>
>
> Thanks,
>
> Dan Smith
>
>