Merge remote-tracking branch 'origin/ignite-45' into ignite-45
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/d5f29b23 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/d5f29b23 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/d5f29b23 Branch: refs/heads/ignite-501 Commit: d5f29b238adeff428b35a61d7196ee19c3d20825 Parents: a88eff9 d49f9c8 Author: Alexey Goncharuk <agoncha...@gridgain.com> Authored: Wed Mar 18 22:47:21 2015 -0700 Committer: Alexey Goncharuk <agoncha...@gridgain.com> Committed: Wed Mar 18 22:47:21 2015 -0700 ---------------------------------------------------------------------- examples/config/example-streamer.xml | 18 +-- .../datagrid/CachePopularNumbersExample.java | 7 +- .../StreamingPopularNumbersExample.java | 113 +++++-------- .../apache/ignite/examples/ComputeExample.java | 57 ------- .../ignite/examples/MessagingExample.java | 162 ------------------- .../ignite/examples/java8/ComputeExample.java | 56 +++++++ .../examples/java8/ExampleNodeStartup.java | 35 ++++ .../ignite/examples/java8/ExamplesUtils.java | 129 +++++++++++++++ .../ignite/examples/java8/MessagingExample.java | 162 +++++++++++++++++++ .../java8/streaming/numbers/CacheConfig.java | 33 ++++ .../streaming/numbers/QueryPopularNumbers.java | 67 ++++++++ .../streaming/numbers/StreamRandomNumbers.java | 79 +++++++++ .../examples/ScalarCacheAffinityExample.scala | 2 +- .../scalar/examples/ScalarCacheExample.scala | 2 +- .../ScalarCachePopularNumbersExample.scala | 23 +-- .../examples/ScalarCacheQueryExample.scala | 9 +- .../examples/ScalarSnowflakeSchemaExample.scala | 10 +- .../examples/MessagingExamplesSelfTest.java | 2 +- .../org/apache/ignite/IgniteDataStreamer.java | 32 +--- .../processors/cache/GridCacheAdapter.java | 5 +- .../GridDistributedCacheAdapter.java | 2 +- .../datastreamer/DataStreamProcessor.java | 3 +- .../datastreamer/DataStreamerCacheUpdaters.java | 25 +-- .../datastreamer/DataStreamerImpl.java | 33 ++-- .../datastreamer/DataStreamerRequest.java | 2 +- .../datastreamer/DataStreamerUpdateJob.java | 17 +- .../dr/IgniteDrDataStreamerCacheUpdater.java | 9 +- .../processors/igfs/IgfsDataManager.java | 3 +- .../apache/ignite/stream/StreamReceiver.java | 42 +++++ .../apache/ignite/stream/StreamTransformer.java | 48 ++++++ ...cheAbstractFullApiMultithreadedSelfTest.java | 2 +- .../cache/GridCacheAbstractFullApiSelfTest.java | 4 +- ...idCachePartitionedHitsAndMissesSelfTest.java | 7 +- .../DataStreamProcessorSelfTest.java | 12 +- .../IgniteDataStreamerPerformanceTest.java | 2 +- .../ignite/loadtests/streamer/IndexUpdater.java | 2 +- .../tests/p2p/GridExternalAffinityFunction.java | 2 +- 37 files changed, 806 insertions(+), 412 deletions(-) ----------------------------------------------------------------------
