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 18:47:13 GMT
Repository: incubator-ignite
Updated Branches:
  refs/heads/ignite-45 b97bc6690 -> 7a68a0678


# 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/7a68a067
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/7a68a067
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/7a68a067

Branch: refs/heads/ignite-45
Commit: 7a68a06787d398089ff5a44f86112a967b8b7ab0
Parents: b97bc66
Author: Dmitiry Setrakyan <dsetrakyan@gridgain.com>
Authored: Sat Mar 21 11:47:09 2015 -0700
Committer: Dmitiry Setrakyan <dsetrakyan@gridgain.com>
Committed: Sat Mar 21 11:47:09 2015 -0700

----------------------------------------------------------------------
 .../java7/streaming/marketdata/CacheConfig.java        | 13 ++++++-------
 .../java8/streaming/marketdata/CacheConfig.java        | 13 ++++++-------
 2 files changed, 12 insertions(+), 14 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7a68a067/examples/src/main/java/org/apache/ignite/examples/java7/streaming/marketdata/CacheConfig.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/java7/streaming/marketdata/CacheConfig.java
b/examples/src/main/java/org/apache/ignite/examples/java7/streaming/marketdata/CacheConfig.java
index 9b1c096..3c00dcd 100644
--- a/examples/src/main/java/org/apache/ignite/examples/java7/streaming/marketdata/CacheConfig.java
+++ b/examples/src/main/java/org/apache/ignite/examples/java7/streaming/marketdata/CacheConfig.java
@@ -20,24 +20,23 @@ package org.apache.ignite.examples.java7.streaming.marketdata;
 import org.apache.ignite.configuration.*;
 
 /**
- * Configuration for the streaming cache to store the stream of random numbers.
- * This cache is configured with sliding window of 1 second, which means that
- * data older than 1 second will be automatically removed from the cache.
+ * Configuration for the streaming caches for market data and financial instruments.
  */
 public class CacheConfig {
-    /** Cache name. */
-    public static final String STREAM_NAME = "marketTicks";
-
     /**
-     * Configure streaming cache.
+     * Configure streaming cache for market ticks.
      */
     public static CacheConfiguration<String, MarketTick> marketTicksCache() {
         return new CacheConfiguration<>("marketTicks");
     }
 
+    /**
+     * Configure cache for financial instruments.
+     */
     public static CacheConfiguration<String, Instrument> instrumentCache() {
         CacheConfiguration<String, Instrument> instCache = new CacheConfiguration<>("instCache");
 
+        // Index some fields for querying portfolio positions.
         instCache.setIndexedTypes(String.class, Instrument.class);
 
         return instCache;

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7a68a067/examples/src/main/java8/org/apache/ignite/examples/java8/streaming/marketdata/CacheConfig.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java8/org/apache/ignite/examples/java8/streaming/marketdata/CacheConfig.java
b/examples/src/main/java8/org/apache/ignite/examples/java8/streaming/marketdata/CacheConfig.java
index 90bdcf1..592f5cc 100644
--- a/examples/src/main/java8/org/apache/ignite/examples/java8/streaming/marketdata/CacheConfig.java
+++ b/examples/src/main/java8/org/apache/ignite/examples/java8/streaming/marketdata/CacheConfig.java
@@ -20,24 +20,23 @@ package org.apache.ignite.examples.java8.streaming.marketdata;
 import org.apache.ignite.configuration.*;
 
 /**
- * Configuration for the streaming cache to store the stream of random numbers.
- * This cache is configured with sliding window of 1 second, which means that
- * data older than 1 second will be automatically removed from the cache.
+ * Configuration for the streaming caches for market data and financial instruments.
  */
 public class CacheConfig {
-    /** Cache name. */
-    public static final String STREAM_NAME = "marketTicks";
-
     /**
-     * Configure streaming cache.
+     * Configure streaming cache for market ticks.
      */
     public static CacheConfiguration<String, MarketTick> marketTicksCache() {
         return new CacheConfiguration<>("marketTicks");
     }
 
+    /**
+     * Configure cache for financial instruments.
+     */
     public static CacheConfiguration<String, Instrument> instrumentCache() {
         CacheConfiguration<String, Instrument> instCache = new CacheConfiguration<>("instCache");
 
+        // Index some fields for querying portfolio positions.
         instCache.setIndexedTypes(String.class, Instrument.class);
 
         return instCache;


Mime
View raw message