# 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/ignite-release-test-no-mod Commit: 4ade1d1ffa9aced7a8ccff43a47f0481ec9a7704 Parents: 2fdb8c6 Author: Dmitiry Setrakyan <dsetrak...@gridgain.com> Authored: Tue Mar 24 02:15:03 2015 -0700 Committer: Dmitiry Setrakyan <dsetrak...@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.
