Repository: incubator-ignite Updated Branches: refs/heads/ignite-45 9b3b2bdb0 -> 46431f8ed
# ignite-45 - copied streaming to java7. Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/46431f8e Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/46431f8e Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/46431f8e Branch: refs/heads/ignite-45 Commit: 46431f8ed2f77c34e237e270f459bd785b0fc8e5 Parents: 9b3b2bd Author: Dmitiry Setrakyan <dsetrak...@gridgain.com> Authored: Sat Mar 21 12:23:21 2015 -0700 Committer: Dmitiry Setrakyan <dsetrak...@gridgain.com> Committed: Sat Mar 21 12:23:21 2015 -0700 ---------------------------------------------------------------------- .../examples/java7/streaming/marketdata/StreamMarketData.java | 6 +++--- .../examples/java8/streaming/marketdata/StreamMarketData.java | 6 +++--- 2 files changed, 6 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/46431f8e/examples/src/main/java/org/apache/ignite/examples/java7/streaming/marketdata/StreamMarketData.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/java7/streaming/marketdata/StreamMarketData.java b/examples/src/main/java/org/apache/ignite/examples/java7/streaming/marketdata/StreamMarketData.java index dd4c069..772c59d 100644 --- a/examples/src/main/java/org/apache/ignite/examples/java7/streaming/marketdata/StreamMarketData.java +++ b/examples/src/main/java/org/apache/ignite/examples/java7/streaming/marketdata/StreamMarketData.java @@ -60,10 +60,10 @@ public class StreamMarketData { IgniteCache<String, MarketTick> mktCache = ignite.getOrCreateCache(CacheConfig.marketTicksCache()); IgniteCache<String, Instrument> instCache = ignite.getOrCreateCache(CacheConfig.instrumentCache()); - try (IgniteDataStreamer<String, MarketTick> stmr = ignite.dataStreamer(mktCache.getName())) { + try (IgniteDataStreamer<String, MarketTick> mktStmr = ignite.dataStreamer(mktCache.getName())) { // Note that we receive market data, but do not populate 'mktCache' (it remains empty). // Instead we update the instruments in the 'instCache'. - stmr.receiver(new StreamVisitor<>(new IgniteBiInClosure<IgniteCache<String, MarketTick>, Map.Entry<String, MarketTick>>() { + mktStmr.receiver(new StreamVisitor<>(new IgniteBiInClosure<IgniteCache<String, MarketTick>, Map.Entry<String, MarketTick>>() { @Override public void apply(IgniteCache<String, MarketTick> mktCache, Map.Entry<String, MarketTick> e) { String symbol = e.getKey(); @@ -91,7 +91,7 @@ public class StreamMarketData { MarketTick tick = new MarketTick(INSTRUMENTS[j], price); - stmr.addData(tick.symbol(), tick); + mktStmr.addData(tick.symbol(), tick); } } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/46431f8e/examples/src/main/java8/org/apache/ignite/examples/java8/streaming/marketdata/StreamMarketData.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java8/org/apache/ignite/examples/java8/streaming/marketdata/StreamMarketData.java b/examples/src/main/java8/org/apache/ignite/examples/java8/streaming/marketdata/StreamMarketData.java index 5b7f91f..ccec740 100644 --- a/examples/src/main/java8/org/apache/ignite/examples/java8/streaming/marketdata/StreamMarketData.java +++ b/examples/src/main/java8/org/apache/ignite/examples/java8/streaming/marketdata/StreamMarketData.java @@ -59,10 +59,10 @@ public class StreamMarketData { IgniteCache<String, MarketTick> mktCache = ignite.getOrCreateCache(CacheConfig.marketTicksCache()); IgniteCache<String, Instrument> instCache = ignite.getOrCreateCache(CacheConfig.instrumentCache()); - try (IgniteDataStreamer<String, MarketTick> stmr = ignite.dataStreamer(mktCache.getName())) { + try (IgniteDataStreamer<String, MarketTick> mktStmr = ignite.dataStreamer(mktCache.getName())) { // Note that we receive market data, but do not populate 'mktCache' (it remains empty). // Instead we update the instruments in the 'instCache'. - stmr.receiver(new StreamVisitor<>((cache, e) -> { + mktStmr.receiver(new StreamVisitor<>((cache, e) -> { String symbol = e.getKey(); MarketTick tick = e.getValue(); @@ -87,7 +87,7 @@ public class StreamMarketData { MarketTick tick = new MarketTick(INSTRUMENTS[j], price); - stmr.addData(tick.symbol(), tick); + mktStmr.addData(tick.symbol(), tick); } } }
