ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vkuliche...@apache.org
Subject [1/2] incubator-ignite git commit: # IGNITE-143 - Minor
Date Fri, 13 Feb 2015 02:10:51 GMT
Repository: incubator-ignite
Updated Branches:
  refs/heads/ignite-143 155ebc0f6 -> 8230c8c74


# IGNITE-143 - Minor


Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/8178340d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/8178340d
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/8178340d

Branch: refs/heads/ignite-143
Commit: 8178340deb2ce6eb6338a9909c7627cd3e2ccdb6
Parents: 155ebc0
Author: Valentin Kulichenko <vkulichenko@gridgain.com>
Authored: Thu Feb 12 17:38:31 2015 -0800
Committer: Valentin Kulichenko <vkulichenko@gridgain.com>
Committed: Thu Feb 12 17:38:31 2015 -0800

----------------------------------------------------------------------
 .../cache/query/continuous/CacheContinuousQueryEntry.java      | 2 +-
 .../cache/query/continuous/CacheContinuousQueryHandler.java    | 2 +-
 .../cache/query/continuous/CacheContinuousQueryListener.java   | 6 +++++-
 3 files changed, 7 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8178340d/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryEntry.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryEntry.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryEntry.java
index 72269c8..aa4ce54 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryEntry.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryEntry.java
@@ -30,7 +30,7 @@ import java.io.*;
 import static org.apache.ignite.internal.processors.cache.GridCacheValueBytes.*;
 
 /**
- * Continuous query event.
+ * Continuous query entry.
  */
 class CacheContinuousQueryEntry<K, V> implements GridCacheDeployable, Externalizable
{
     /** */

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8178340d/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java
index ece5a01..4ad664a 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java
@@ -39,7 +39,7 @@ import static org.apache.ignite.events.EventType.*;
 /**
  * Continuous query handler.
  */
-public class CacheContinuousQueryHandler<K, V> implements GridContinuousHandler {
+class CacheContinuousQueryHandler<K, V> implements GridContinuousHandler {
     /** */
     private static final long serialVersionUID = 0L;
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8178340d/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryListener.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryListener.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryListener.java
index 21c45f9..3695bad 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryListener.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryListener.java
@@ -29,7 +29,8 @@ interface CacheContinuousQueryListener<K, V> {
     /**
      * Entry update callback.
      *
-     * @param e Entry.
+     * @param evt Event
+     * @param primary Primary flag.
      * @param recordIgniteEvt Whether to record event.
      */
     public void onEntryUpdated(CacheContinuousQueryEvent<K, V> evt, boolean primary,
boolean recordIgniteEvt);
@@ -39,5 +40,8 @@ interface CacheContinuousQueryListener<K, V> {
      */
     public void onUnregister();
 
+    /**
+     * @return Whether old value is required.
+     */
     public boolean oldValueRequired();
 }


Mime
View raw message