Minor fix for StreamTransformer (JavaDoc)
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/9f7286e2 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/9f7286e2 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/9f7286e2 Branch: refs/heads/ignite-direct-marsh-opt Commit: 9f7286e2d41e6bd91106b317c3b25a47292666aa Parents: 569dd21 Author: Valentin Kulichenko <valentin.kuliche...@gmail.com> Authored: Tue Nov 10 17:47:19 2015 -0800 Committer: Valentin Kulichenko <valentin.kuliche...@gmail.com> Committed: Tue Nov 10 17:47:19 2015 -0800 ---------------------------------------------------------------------- .../main/java/org/apache/ignite/stream/StreamTransformer.java | 5 +++++ 1 file changed, 5 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/9f7286e2/modules/core/src/main/java/org/apache/ignite/stream/StreamTransformer.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/stream/StreamTransformer.java b/modules/core/src/main/java/org/apache/ignite/stream/StreamTransformer.java index 4435c0a..176973e 100644 --- a/modules/core/src/main/java/org/apache/ignite/stream/StreamTransformer.java +++ b/modules/core/src/main/java/org/apache/ignite/stream/StreamTransformer.java @@ -29,6 +29,11 @@ import org.apache.ignite.cache.CacheEntryProcessor; /** * Convenience adapter to transform update existing values in streaming cache * based on the previously cached value. + * <p> + * This transformer implement {@link EntryProcessor} and internally will call + * {@link IgniteCache#invoke(Object, EntryProcessor, Object...)} method. Note + * that the value received from the data streamer will be passed to the entry + * processor as an argument. */ public abstract class StreamTransformer<K, V> implements StreamReceiver<K, V>, EntryProcessor<K, V, Object> { /** */
