You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ak...@apache.org on 2015/09/02 04:00:42 UTC
[14/29] ignite git commit: Platforms: reworked
PlatformCacheEntryFilter interface.
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-843
Commit: 980a934eb26adeaae1a358d5f9e1c6faccfcaf4a
Parents: 6d0aff4
Author: vozerov-gridgain <vo...@gridgain.com>
Authored: Tue Sep 1 11:31:08 2015 +0300
Committer: vozerov-gridgain <vo...@gridgain.com>
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();