Merge remote-tracking branch 'origin/ignite-430' into ignite-430
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/f6738850 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/f6738850 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/f6738850 Branch: refs/heads/ignite-430 Commit: f673885025743e59899967c442fcb126af3b830d Parents: 8028559 a9f96d6 Author: Yakov Zhdanov <yzhda...@gridgain.com> Authored: Thu May 14 16:04:17 2015 +0300 Committer: Yakov Zhdanov <yzhda...@gridgain.com> Committed: Thu May 14 16:04:17 2015 +0300 ---------------------------------------------------------------------- .../ignite/examples/streaming/package-info.java | 1 - .../streaming/socket/SocketStreamerExample.java | 128 -------- .../socket/WordsSocketStreamerClient.java | 86 +++++ .../socket/WordsSocketStreamerServer.java | 93 ++++++ .../socket/ZStringsSocketStreamerExample.java | 141 --------- .../socket/ZWordsSocketStreamerClient.java | 81 +++++ .../socket/ZWordsSocketStreamerServer.java | 111 +++++++ .../examples/streaming/socket/package-info.java | 3 +- .../streaming/wordcount/CacheConfig.java | 2 +- .../streaming/wordcount/QueryWords.java | 2 +- .../streaming/wordcount/StreamWords.java | 2 +- .../streaming/wordcount/package-info.java | 1 - .../org/apache/ignite/stream/StreamAdapter.java | 111 +++++++ .../ignite/stream/StreamTupleExtractor.java | 33 ++ .../ignite/stream/adapters/StreamAdapter.java | 111 ------- .../stream/adapters/StreamTupleExtractor.java | 33 -- .../ignite/stream/adapters/package-info.java | 21 -- .../stream/socket/IgniteSocketStreamer.java | 217 ------------- .../ignite/stream/socket/SocketStreamer.java | 218 +++++++++++++ .../socket/IgniteSocketStreamerSelfTest.java | 315 ------------------- .../stream/socket/SocketStreamerSelfTest.java | 315 +++++++++++++++++++ .../testsuites/IgniteStreamTestSuite.java | 2 +- 22 files changed, 1053 insertions(+), 974 deletions(-) ----------------------------------------------------------------------
