ScanQuery setPartition chaining style fixed
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/4f500fdf Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/4f500fdf Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/4f500fdf Branch: refs/heads/ignite-gg-10411 Commit: 4f500fdf65275ef066578578493212433075a201 Parents: d36610f Author: agura <ag...@gridgain.com> Authored: Thu Jun 11 13:33:15 2015 +0300 Committer: agura <ag...@gridgain.com> Committed: Thu Jun 11 13:33:15 2015 +0300 ---------------------------------------------------------------------- .../src/main/java/org/apache/ignite/cache/query/ScanQuery.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4f500fdf/modules/core/src/main/java/org/apache/ignite/cache/query/ScanQuery.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/query/ScanQuery.java b/modules/core/src/main/java/org/apache/ignite/cache/query/ScanQuery.java index e6b69bc..11a8c84 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/query/ScanQuery.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/query/ScanQuery.java @@ -111,9 +111,12 @@ public final class ScanQuery<K, V> extends Query<Cache.Entry<K, V>> { * all partitions in the cache. Must be in the range [0, N) where N is partition number in the cache. * * @param part Partition number over which this query should iterate. + * @return {@code this} for chaining. */ - public void setPartition(@Nullable Integer part) { + public ScanQuery<K, V> setPartition(@Nullable Integer part) { this.part = part; + + return this; } /** {@inheritDoc} */
