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 <dsetrak...@gridgain.com> Authored: Sat Mar 21 11:47:09 2015 -0700 Committer: Dmitiry Setrakyan <dsetrak...@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;
