Merge branches 'ignite-709_2' and 'ignite-sprint-5' of https://git-wip-us.apache.org/repos/asf/incubator-ignite into ignite-709_2
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/a902bc18 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/a902bc18 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/a902bc18 Branch: refs/heads/ignite-23 Commit: a902bc18545c8b578c8aaa0e294cc5aadbb79eaa Parents: 7099c56 896b426 Author: Yakov Zhdanov <yzhda...@gridgain.com> Authored: Fri May 15 10:36:28 2015 +0300 Committer: Yakov Zhdanov <yzhda...@gridgain.com> Committed: Fri May 15 10:36:28 2015 +0300 ---------------------------------------------------------------------- .../streaming/StreamTransformerExample.java | 4 +- .../streaming/StreamVisitorExample.java | 4 +- .../ignite/examples/streaming/package-info.java | 1 - .../streaming/wordcount/CacheConfig.java | 2 +- .../streaming/wordcount/QueryWords.java | 12 +- .../streaming/wordcount/StreamWords.java | 12 +- .../streaming/wordcount/package-info.java | 1 - .../socket/WordsSocketStreamerClient.java | 82 +++++ .../socket/WordsSocketStreamerServer.java | 124 ++++++++ .../wordcount/socket/package-info.java | 21 ++ .../internal/util/nio/GridBufferedParser.java | 4 - .../internal/util/nio/GridDelimitedParser.java | 91 ++++++ .../util/nio/GridNioDelimitedBuffer.java | 106 +++++++ .../org/apache/ignite/stream/StreamAdapter.java | 111 +++++++ .../ignite/stream/StreamTupleExtractor.java | 33 ++ .../stream/socket/SocketMessageConverter.java | 31 ++ .../ignite/stream/socket/SocketStreamer.java | 218 +++++++++++++ .../ignite/stream/socket/package-info.java | 21 ++ .../util/nio/GridNioDelimitedBufferTest.java | 112 +++++++ .../stream/socket/SocketStreamerSelfTest.java | 315 +++++++++++++++++++ .../ignite/stream/socket/package-info.java | 21 ++ .../testsuites/IgniteStreamTestSuite.java | 39 +++ .../testsuites/IgniteUtilSelfTestSuite.java | 1 + 23 files changed, 1345 insertions(+), 21 deletions(-) ----------------------------------------------------------------------
