ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sevdoki...@apache.org
Subject [30/50] incubator-ignite git commit: # ignite-45 - javadoc fix.
Date Tue, 24 Mar 2015 13:55:54 GMT
# ignite-45 - javadoc fix.


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

Branch: refs/heads/sprint-2
Commit: 4ade1d1ffa9aced7a8ccff43a47f0481ec9a7704
Parents: 2fdb8c6
Author: Dmitiry Setrakyan <dsetrakyan@gridgain.com>
Authored: Tue Mar 24 02:15:03 2015 -0700
Committer: Dmitiry Setrakyan <dsetrakyan@gridgain.com>
Committed: Tue Mar 24 02:15:03 2015 -0700

----------------------------------------------------------------------
 .../org/apache/ignite/IgniteDataStreamer.java   | 24 ++++++++++++--------
 1 file changed, 15 insertions(+), 9 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4ade1d1f/modules/core/src/main/java/org/apache/ignite/IgniteDataStreamer.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/IgniteDataStreamer.java b/modules/core/src/main/java/org/apache/ignite/IgniteDataStreamer.java
index 4dcb2b8..aad4574 100644
--- a/modules/core/src/main/java/org/apache/ignite/IgniteDataStreamer.java
+++ b/modules/core/src/main/java/org/apache/ignite/IgniteDataStreamer.java
@@ -71,8 +71,8 @@ import java.util.*;
  *      changing), but it won't be lost anyway. Disabled by default (default value is {@code
0}).
  *  </li>
  *  <li>
- *      {@link #allowOverwrite(boolean)} - defines if data streamer will assume that there
are no other concurrent
- *      updates and allow data streamer choose most optimal concurrent implementation.
+ *      {@link #allowOverwrite(boolean)} - Sets flag enabling overwriting existing values
in cache.
+ *      Data streamer will perform better if this flag is disabled, which is the default
setting.
  *  </li>
  *  <li>
  *      {@link #receiver(StreamReceiver)} - defines how cache will be updated with added
entries.
@@ -103,19 +103,25 @@ public interface IgniteDataStreamer<K, V> extends AutoCloseable
{
     public String cacheName();
 
     /**
-     * Gets flag value indicating that this data streamer assumes that
-     * there are no other concurrent updates to the cache.
-     * Default is {@code false}.
+     * Gets flag enabling overwriting existing values in cache.
+     * Data streamer will perform better if this flag is disabled.
+     * <p>
+     * This flag is disabled by default (default is {@code false}).
      *
-     * @return Flag value.
+     * @return {@code True} if overwriting is allowed, {@code false} otherwise..
      */
     public boolean allowOverwrite();
 
     /**
-     * Sets flag indicating that this data streamer should assume
-     * that there are no other concurrent updates to the cache.
+     * Sets flag enabling overwriting existing values in cache.
+     * Data streamer will perform better if this flag is disabled.
+     * <p>
      * Should not be used when custom cache receiver set using {@link #receiver(StreamReceiver)}
method.
-     * Default is {@code false}. When this flag is set, updates will not be propagated to
the cache store.
+     * <p>
+     * Note that when this flag is {@code false}, updates will not be propagated to the cache
store
+     * (i.e. {@link #skipStore()} flag will be set to {@code true} implicitly).
+     * <p>
+     * This flag is disabled by default (default is {@code false}).
      *
      * @param allowOverwrite Flag value.
      * @throws CacheException If failed.


Mime
View raw message