You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2015/05/15 10:50:40 UTC
[11/11] incubator-ignite git commit: Merge remote-tracking branch
'remotes/origin/ignite-sprint-5' into ignite-614
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 <iv...@gridgain.com>
Authored: Fri May 15 11:50:15 2015 +0300
Committer: ivasilinets <iv...@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(-)
----------------------------------------------------------------------