IGNITE-1370 Refactor StreamTupleExtractor API for 0..1 and 0..n extraction.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/421a5234 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/421a5234 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/421a5234 Branch: refs/heads/ignite-257 Commit: 421a5234b5a7e56e36952a4c1976b3118310073e Parents: eae4df1 b80b171 Author: Raul Kripalani <ra...@apache.org> Authored: Mon Sep 21 16:28:12 2015 +0100 Committer: Raul Kripalani <ra...@apache.org> Committed: Mon Sep 21 16:28:12 2015 +0100 ---------------------------------------------------------------------- .../socket/WordsSocketStreamerServer.java | 5 +- .../org/apache/ignite/stream/StreamAdapter.java | 104 +++++++++++++++-- .../stream/StreamMultipleTupleExtractor.java | 38 +++++++ .../stream/StreamSingleTupleExtractor.java | 40 +++++++ .../ignite/stream/StreamTupleExtractor.java | 20 ++-- .../ignite/stream/socket/SocketStreamer.java | 3 +- .../stream/socket/SocketStreamerSelfTest.java | 112 ++++++++++++++----- 7 files changed, 270 insertions(+), 52 deletions(-) ----------------------------------------------------------------------