Repository: ignite Updated Branches: refs/heads/master f3b067271 -> ec9d47b19
minor - fixed javadoc Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/ec9d47b1 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/ec9d47b1 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/ec9d47b1 Branch: refs/heads/master Commit: ec9d47b197738459b7721d5b393f5be223cd76e0 Parents: f3b0672 Author: Yakov Zhdanov <[email protected]> Authored: Mon Jun 26 13:25:50 2017 +0300 Committer: Yakov Zhdanov <[email protected]> Committed: Mon Jun 26 13:25:50 2017 +0300 ---------------------------------------------------------------------- .../src/main/java/org/apache/ignite/IgniteDataStreamer.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/ec9d47b1/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 4e00d66..6665f59 100644 --- a/modules/core/src/main/java/org/apache/ignite/IgniteDataStreamer.java +++ b/modules/core/src/main/java/org/apache/ignite/IgniteDataStreamer.java @@ -31,6 +31,9 @@ import org.jetbrains.annotations.Nullable; * to make sure that there is the least amount of data movement possible and optimal * network and memory utilization. * <p> + * Note that data streamer is not transactional and therefore dishonours any active transaction + * when updating data. + * <p> * Note that streamer will stream data concurrently by multiple internal threads, so the * data may get to remote nodes in different order from which it was added to * the streamer. @@ -441,4 +444,4 @@ public interface IgniteDataStreamer<K, V> extends AutoCloseable { @Override public void close() throws CacheException, IgniteInterruptedException, IgniteDataStreamerTimeoutException; -} \ No newline at end of file +}
