# IGNITE-45 - Examples

examples/src/main/java/org/apache/ignite/examples/streaming/marketdata/CacheConfig.java

@@ -26,7 +26,7 @@ public class CacheConfig {
     /**
      * Configure streaming cache for market ticks.
      */
-    public static CacheConfiguration<String, MarketTick> marketTicksCache() {
+    public static CacheConfiguration<String, Double> marketTicksCache() {
         return new CacheConfiguration<>("marketTicks");
     }
 

examples/src/main/java/org/apache/ignite/examples/streaming/marketdata/Instrument.java

@@ -51,17 +51,17 @@ public class Instrument implements Serializable {
     }
 
     /**
-     * Updates this instrument based on the latest market tick.
+     * Updates this instrument based on the latest price.
      *
-     * @param tick Market tick.
+     * @param price Latest price.
      */
-    public void update(MarketTick tick) {
+    public void update(double price) {
         if (open == 0)
-            open = tick.price();
+            open = price;
 
-        high = Math.max(high, tick.price());
-        low = Math.min(low, tick.price());
-        this.latest = tick.price();
+        high = Math.max(high, price);
+        low = Math.min(low, price);
+        this.latest = price;
     }
 
     /**

examples/src/main/java/org/apache/ignite/examples/streaming/marketdata/StreamMarketData.java

@@ -38,9 +38,6 @@ public class StreamMarketData {
     /** Random number generator. */
     private static final Random RAND = new Random();
 
-    /** Count of total numbers to generate. */
-    private static final int CNT = 10000000;
-
     /** The list of instruments. */
     private static final String[] INSTRUMENTS = {"IBM", "GOOG", "MSFT", "GE", "EBAY", "YHOO", "ORCL", "CSCO", "AMZN", "RHT"};
 
@@ -56,17 +53,16 @@ public static void main(String[] args) throws Exception {
                 return;
 
             // The cache is configured with sliding window holding 1 second of the streaming data.
-            IgniteCache<String, MarketTick> mktCache = ignite.getOrCreateCache(CacheConfig.marketTicksCache());
+            IgniteCache<String, Double> mktCache = ignite.getOrCreateCache(CacheConfig.marketTicksCache());
             final IgniteCache<String, Instrument> instCache = ignite.getOrCreateCache(CacheConfig.instrumentCache());
 
-            try (IgniteDataStreamer<String, MarketTick> mktStmr = ignite.dataStreamer(mktCache.getName())) {
+            try (IgniteDataStreamer<String, Double> 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'.
-                mktStmr.receiver(new StreamVisitor<String, MarketTick>() {
-                    @Override
-                    public void apply(IgniteCache<String, MarketTick> cache, Map.Entry<String, MarketTick> e) {
+                mktStmr.receiver(new StreamVisitor<String, Double>() {
+                    @Override public void apply(IgniteCache<String, Double> cache, Map.Entry<String, Double> e) {
                         String symbol = e.getKey();
-                        MarketTick tick = e.getValue();
+                        Double tick = e.getValue();
 
                         Instrument inst = instCache.get(symbol);
 
@@ -88,9 +84,7 @@ public void apply(IgniteCache<String, MarketTick> cache, Map.Entry<String, Marke
                         // numbers closer to 0 have higher probability.
                         double price = round2(INITIAL_PRICES[j] + RAND.nextGaussian());
 
-                        MarketTick tick = new MarketTick(INSTRUMENTS[j], price);
-
-                        mktStmr.addData(tick.symbol(), tick);
+                        mktStmr.addData(INSTRUMENTS[j], price);
                     }
                 }
             }

examples/src/main/java8/org/apache/ignite/examples/java8/streaming/marketdata/CacheConfig.java

@@ -26,7 +26,7 @@ public class CacheConfig {
     /**
      * Configure streaming cache for market ticks.
      */
-    public static CacheConfiguration<String, MarketTick> marketTicksCache() {
+    public static CacheConfiguration<String, Double> marketTicksCache() {
         return new CacheConfiguration<>("marketTicks");
     }
 

examples/src/main/java8/org/apache/ignite/examples/java8/streaming/marketdata/Instrument.java

@@ -51,17 +51,17 @@ public class Instrument implements Serializable {
     }
 
     /**
-     * Updates this instrument based on the latest market tick.
+     * Updates this instrument based on the latest price.
      *
-     * @param tick Market tick.
+     * @param price Latest price.
      */
-    public void update(MarketTick tick) {
+    public void update(double price) {
         if (open == 0)
-            open = tick.price();
+            open = price;
 
-        high = Math.max(high, tick.price());
-        low = Math.min(low, tick.price());
-        this.latest = tick.price();
+        high = Math.max(high, price);
+        low = Math.min(low, price);
+        this.latest = price;
     }
 
     /**

examples/src/main/java8/org/apache/ignite/examples/java8/streaming/marketdata/StreamMarketData.java

@@ -53,15 +53,15 @@ public static void main(String[] args) throws Exception {
                 return;
 
             // The cache is configured with sliding window holding 1 second of the streaming data.
-            IgniteCache<String, MarketTick> mktCache = ignite.getOrCreateCache(CacheConfig.marketTicksCache());
+            IgniteCache<String, Double> mktCache = ignite.getOrCreateCache(CacheConfig.marketTicksCache());
             IgniteCache<String, Instrument> instCache = ignite.getOrCreateCache(CacheConfig.instrumentCache());
 
-            try (IgniteDataStreamer<String, MarketTick> mktStmr = ignite.dataStreamer(mktCache.getName())) {
+            try (IgniteDataStreamer<String, Double> 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'.
                 mktStmr.receiver(StreamVisitor.from((cache, e) -> {
                     String symbol = e.getKey();
-                    MarketTick tick = e.getValue();
+                    Double tick = e.getValue();
 
                     Instrument inst = instCache.get(symbol);
 
@@ -81,9 +81,7 @@ public static void main(String[] args) throws Exception {
                         // numbers closer to 0 have higher probability.
                         double price = round2(INITIAL_PRICES[j] + RAND.nextGaussian());
 
-                        MarketTick tick = new MarketTick(INSTRUMENTS[j], price);
-
-                        mktStmr.addData(tick.symbol(), tick);
+                        mktStmr.addData(INSTRUMENTS[j], price);
                     }
                 }
             }