ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dsetrak...@apache.org
Subject incubator-ignite git commit: # ignite-45 - copied streaming to java7.
Date Sat, 21 Mar 2015 19:23:24 GMT
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 <dsetrakyan@gridgain.com>
Authored: Sat Mar 21 12:23:21 2015 -0700
Committer: Dmitiry Setrakyan <dsetrakyan@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);
                     }
                 }
             }


Mime
View raw message