Platforms: reworked PlatformCacheEntryFilter interface.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/980a934e Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/980a934e Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/980a934e Branch: refs/heads/ignite-1093-2 Commit: 980a934eb26adeaae1a358d5f9e1c6faccfcaf4a Parents: 6d0aff4 Author: vozerov-gridgain <[email protected]> Authored: Tue Sep 1 11:31:08 2015 +0300 Committer: vozerov-gridgain <[email protected]> Committed: Tue Sep 1 11:31:08 2015 +0300 ---------------------------------------------------------------------- .../processors/platform/cache/PlatformCacheEntryFilter.java | 2 +- .../processors/platform/cache/PlatformCacheEntryFilterImpl.java | 5 ++--- 2 files changed, 3 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/980a934e/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/PlatformCacheEntryFilter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/PlatformCacheEntryFilter.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/PlatformCacheEntryFilter.java index 94de2bc..4063c60 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/PlatformCacheEntryFilter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/PlatformCacheEntryFilter.java @@ -22,7 +22,7 @@ import org.apache.ignite.lang.IgniteBiPredicate; /** * Platform cache entry filter interface. */ -public interface PlatformCacheEntryFilter<K, V> extends IgniteBiPredicate<K, V> { +public interface PlatformCacheEntryFilter extends IgniteBiPredicate { /** * Callback invoked when filter is no longer needed. */ http://git-wip-us.apache.org/repos/asf/ignite/blob/980a934e/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/cache/PlatformCacheEntryFilterImpl.java ---------------------------------------------------------------------- diff --git a/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/cache/PlatformCacheEntryFilterImpl.java b/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/cache/PlatformCacheEntryFilterImpl.java index e2d44ad..5f8ec8f 100644 --- a/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/cache/PlatformCacheEntryFilterImpl.java +++ b/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/cache/PlatformCacheEntryFilterImpl.java @@ -29,8 +29,7 @@ import org.apache.ignite.resources.IgniteInstanceResource; /** * Interop filter. Delegates apply to native platform. */ -public class PlatformCacheEntryFilterImpl<K, V> extends PlatformAbstractPredicate - implements PlatformCacheEntryFilter<K, V> { +public class PlatformCacheEntryFilterImpl extends PlatformAbstractPredicate implements PlatformCacheEntryFilter { /** */ private static final long serialVersionUID = 0L; @@ -55,7 +54,7 @@ public class PlatformCacheEntryFilterImpl<K, V> extends PlatformAbstractPredicat } /** {@inheritDoc} */ - @Override public boolean apply(K k, V v) { + @Override public boolean apply(Object k, Object v) { try (PlatformMemory mem = ctx.memory().allocate()) { PlatformOutputStream out = mem.output();
