You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by yz...@apache.org on 2015/05/20 17:24:39 UTC
[04/22] incubator-ignite git commit: Merge branches 'ignite-709_2'
and 'ignite-sprint-5' of
https://git-wip-us.apache.org/repos/asf/incubator-ignite into ignite-709_2
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-709_2
Commit: a902bc18545c8b578c8aaa0e294cc5aadbb79eaa
Parents: 7099c56 896b426
Author: Yakov Zhdanov <yz...@gridgain.com>
Authored: Fri May 15 10:36:28 2015 +0300
Committer: Yakov Zhdanov <yz...@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(-)
----------------------------------------------------------------------