Merge remote-tracking branch 'remotes/origin/ignite-sprint-5' into ignite-614
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/419798bb Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/419798bb Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/419798bb Branch: refs/heads/ignite-614 Commit: 419798bb971bea989acd5a24fff2546e1be7f9d9 Parents: 0440869 896b426 Author: ivasilinets <ivasilin...@gridgain.com> Authored: Fri May 15 11:50:15 2015 +0300 Committer: ivasilinets <ivasilin...@gridgain.com> Committed: Fri May 15 11:50:15 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 ++ .../ignite/internal/GridInternalWrapper.java | 30 ++ .../closure/GridClosureProcessor.java | 25 +- .../internal/processors/igfs/IgfsJobImpl.java | 10 +- .../processors/resource/GridResourceIoc.java | 36 +-- .../resource/GridResourceProcessor.java | 8 +- .../processors/resource/GridResourceUtils.java | 15 + .../processors/resource/InjectRecursively.java | 30 -- .../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 ++ .../resources/META-INF/classnames.properties | 1 - .../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 + 31 files changed, 1441 insertions(+), 80 deletions(-) ----------------------------------------------------------------------
