# sprint-3 - Updated streaming examples.

Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/eadb5d5c
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/eadb5d5c
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/eadb5d5c

Branch: refs/heads/ignite-tests-todo
Commit: eadb5d5c2b53ba4ae374258e950ac137e713c650
Parents: dcd24e0
Author: Dmitiry Setrakyan <dsetrak...@gridgain.com>
Authored: Tue Apr 7 00:57:00 2015 -0700
Committer: Dmitiry Setrakyan <dsetrak...@gridgain.com>
Committed: Tue Apr 7 00:57:00 2015 -0700

----------------------------------------------------------------------
 .../org/apache/ignite/examples/streaming/StreamVisitorExample.java | 2 +-
 .../ignite/examples/java8/streaming/StreamVisitorExample.java      | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/eadb5d5c/examples/src/main/java/org/apache/ignite/examples/streaming/StreamVisitorExample.java
----------------------------------------------------------------------
diff --git 
a/examples/src/main/java/org/apache/ignite/examples/streaming/StreamVisitorExample.java
 
b/examples/src/main/java/org/apache/ignite/examples/streaming/StreamVisitorExample.java
index 47e5538..16fbf3d 100644
--- 
a/examples/src/main/java/org/apache/ignite/examples/streaming/StreamVisitorExample.java
+++ 
b/examples/src/main/java/org/apache/ignite/examples/streaming/StreamVisitorExample.java
@@ -56,7 +56,7 @@ public class StreamVisitorExample {
                 return;
 
             // Market data cache with default configuration.
-            CacheConfiguration<String, Double> mktDataCfg = new 
CacheConfiguration<String, Double>("marketTicks");
+            CacheConfiguration<String, Double> mktDataCfg = new 
CacheConfiguration<>("marketTicks");
 
             // Financial instrument cache configuration.
             CacheConfiguration<String, Instrument> instCfg = new 
CacheConfiguration<>("instCache");

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/eadb5d5c/examples/src/main/java8/org/apache/ignite/examples/java8/streaming/StreamVisitorExample.java
----------------------------------------------------------------------
diff --git 
a/examples/src/main/java8/org/apache/ignite/examples/java8/streaming/StreamVisitorExample.java
 
b/examples/src/main/java8/org/apache/ignite/examples/java8/streaming/StreamVisitorExample.java
index 2fa7f16..704c249 100644
--- 
a/examples/src/main/java8/org/apache/ignite/examples/java8/streaming/StreamVisitorExample.java
+++ 
b/examples/src/main/java8/org/apache/ignite/examples/java8/streaming/StreamVisitorExample.java
@@ -56,7 +56,7 @@ public class StreamVisitorExample {
                 return;
 
             // Market data cache with default configuration.
-            CacheConfiguration<String, Double> mktDataCfg = new 
CacheConfiguration<String, Double>("marketTicks");
+            CacheConfiguration<String, Double> mktDataCfg = new 
CacheConfiguration<>("marketTicks");
 
             // Financial instrument cache configuration.
             CacheConfiguration<String, Instrument> instCfg = new 
CacheConfiguration<>("instCache");

Reply via email to