Repository: incubator-ignite Updated Branches: refs/heads/ignite-545 96f0956d6 -> 58c19aa97
ignite-545: KeyCacheObjectImpl no longer implements Comparable Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/58c19aa9 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/58c19aa9 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/58c19aa9 Branch: refs/heads/ignite-545 Commit: 58c19aa97def0f82730e2c4e0c686a2fac749a97 Parents: 96f0956 Author: Denis Magda <dma...@gridgain.com> Authored: Tue Jun 9 11:19:27 2015 +0300 Committer: Denis Magda <dma...@gridgain.com> Committed: Tue Jun 9 11:19:27 2015 +0300 ---------------------------------------------------------------------- .../internal/processors/cache/KeyCacheObjectImpl.java | 11 +---------- .../datastreamer/DataStreamerCacheUpdaters.java | 2 +- 2 files changed, 2 insertions(+), 11 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/58c19aa9/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/KeyCacheObjectImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/KeyCacheObjectImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/KeyCacheObjectImpl.java index 61ca882..e5fa891 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/KeyCacheObjectImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/KeyCacheObjectImpl.java @@ -23,7 +23,7 @@ import org.jetbrains.annotations.*; /** * */ -public class KeyCacheObjectImpl extends CacheObjectAdapter implements KeyCacheObject, Comparable<KeyCacheObjectImpl> { +public class KeyCacheObjectImpl extends CacheObjectAdapter implements KeyCacheObject { /** */ private static final long serialVersionUID = 0L; @@ -46,15 +46,6 @@ public class KeyCacheObjectImpl extends CacheObjectAdapter implements KeyCacheOb } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") - @Override public int compareTo(KeyCacheObjectImpl other) { - assert val instanceof Comparable : val; - assert other.val instanceof Comparable : val; - - return ((Comparable)val).compareTo(other.val); - } - - /** {@inheritDoc} */ @Override public byte[] valueBytes(CacheObjectContext ctx) throws IgniteCheckedException { if (valBytes == null) valBytes = ctx.processor().marshal(ctx, val); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/58c19aa9/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerCacheUpdaters.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerCacheUpdaters.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerCacheUpdaters.java index 50e9ab9..dc9d025 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerCacheUpdaters.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerCacheUpdaters.java @@ -160,7 +160,7 @@ public class DataStreamerCacheUpdaters { /** * Batched updater. Updates cache using batch operations thus is dead lock prone. */ - private static class BatchedSorted<K, V> implements StreamReceiver<K, V>, InternalUpdater { + private static class BatchedSorted<K, V> implements StreamReceiver<K, V> { /** */ private static final long serialVersionUID = 0L;
