Fixes after merge.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/869db216 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/869db216 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/869db216 Branch: refs/heads/ignite-1232-1 Commit: 869db21602c22a5340206016b64369d9eb3e4efa Parents: 84fddee Author: vozerov-gridgain <[email protected]> Authored: Tue Jul 19 17:09:19 2016 +0300 Committer: vozerov-gridgain <[email protected]> Committed: Tue Jul 19 17:09:19 2016 +0300 ---------------------------------------------------------------------- .../processors/cache/GridCacheAdapter.java | 46 -------------------- 1 file changed, 46 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/869db216/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java index 8bada9f..90669e0 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java @@ -5709,52 +5709,6 @@ public abstract class GridCacheAdapter<K, V> implements IgniteInternalCache<K, V } /** - * Internal callable for partition size calculation. - */ - @GridInternal - private static class PartitionSizeLongJob extends TopologyVersionAwareJob { - /** */ - private static final long serialVersionUID = 0L; - - /** Partition. */ - private final int partition; - - /** Peek modes. */ - private final CachePeekMode[] peekModes; - - /** - * @param cacheName Cache name. - * @param topVer Affinity topology version. - * @param peekModes Cache peek modes. - * @param partition partition. - */ - private PartitionSizeLongJob(String cacheName, AffinityTopologyVersion topVer, CachePeekMode[] peekModes, int partition) { - super(cacheName, topVer); - - this.peekModes = peekModes; - this.partition = partition; - } - - /** {@inheritDoc} */ - @Nullable @Override public Object localExecute(@Nullable IgniteInternalCache cache) { - if (cache == null) - return 0; - - try { - return cache.localSizeLong(partition, peekModes); - } - catch (IgniteCheckedException e) { - throw U.convertException(e); - } - } - - /** {@inheritDoc} */ - public String toString() { - return S.toString(PartitionSizeLongJob.class, this); - } - } - - /** * Internal callable for global size calculation. */ @GridInternal
