IGNITE-45 - Fixed java7 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/2df67c56 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/2df67c56 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/2df67c56 Branch: refs/heads/ignite-45 Commit: 2df67c567631819f105d3f8df82412522fdb9964 Parents: 46431f8 Author: Alexey Goncharuk <agoncha...@gridgain.com> Authored: Sat Mar 21 12:43:33 2015 -0700 Committer: Alexey Goncharuk <agoncha...@gridgain.com> Committed: Sat Mar 21 12:43:33 2015 -0700 ---------------------------------------------------------------------- .../ignite/examples/java7/ExamplesUtils.java | 54 ++++++++++++++++++++ .../marketdata/QueryTopInstruments.java | 2 +- .../streaming/marketdata/StreamMarketData.java | 5 +- .../streaming/numbers/QueryPopularNumbers.java | 2 +- .../streaming/numbers/StreamRandomNumbers.java | 2 +- 5 files changed, 60 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/2df67c56/examples/src/main/java/org/apache/ignite/examples/java7/ExamplesUtils.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/java7/ExamplesUtils.java b/examples/src/main/java/org/apache/ignite/examples/java7/ExamplesUtils.java index 3abb385..452979f 100644 --- a/examples/src/main/java/org/apache/ignite/examples/java7/ExamplesUtils.java +++ b/examples/src/main/java/org/apache/ignite/examples/java7/ExamplesUtils.java @@ -17,9 +17,11 @@ package org.apache.ignite.examples.java7; +import org.apache.ignite.Ignite; import org.apache.ignite.cluster.*; import java.net.*; +import java.util.List; /** * @@ -78,4 +80,56 @@ public class ExamplesUtils { return true; } + + + /** + * Checks if cluster has server nodes. + * + * @param ignite Ignite instance. + * @return {@code True} if cluster has server nodes, {@code false} otherwise. + */ + public static boolean hasServerNodes(Ignite ignite) { + if (ignite.cluster().forServers().nodes().isEmpty()) { + System.err.println("Server nodes not found (start data nodes with ExampleNodeStartup class)"); + + return false; + } + + return true; + } + + /** + * Convenience method for printing query results. + * + * @param res Query results. + */ + public static void printQueryResults(List<?> res) { + if (res == null || res.isEmpty()) + System.out.println("Query result set is empty."); + else { + for (Object row : res) { + if (row instanceof List) { + System.out.print("("); + + List<?> l = (List)row; + + for (int i = 0; i < l.size(); i++) { + Object o = l.get(i); + + if (o instanceof Double || o instanceof Float) + System.out.printf("%.2f", o); + else + System.out.print(l.get(i)); + + if (i + 1 != l.size()) + System.out.print(','); + } + + System.out.println(')'); + } + else + System.out.println(" " + row); + } + } + } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/2df67c56/examples/src/main/java/org/apache/ignite/examples/java7/streaming/marketdata/QueryTopInstruments.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/java7/streaming/marketdata/QueryTopInstruments.java b/examples/src/main/java/org/apache/ignite/examples/java7/streaming/marketdata/QueryTopInstruments.java index 87a1173..4b9eb00 100644 --- a/examples/src/main/java/org/apache/ignite/examples/java7/streaming/marketdata/QueryTopInstruments.java +++ b/examples/src/main/java/org/apache/ignite/examples/java7/streaming/marketdata/QueryTopInstruments.java @@ -19,7 +19,7 @@ package org.apache.ignite.examples.java7.streaming.marketdata; import org.apache.ignite.*; import org.apache.ignite.cache.query.*; -import org.apache.ignite.examples.java8.*; +import org.apache.ignite.examples.java7.*; import java.util.*; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/2df67c56/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 772c59d..513a2e1 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 @@ -18,7 +18,8 @@ package org.apache.ignite.examples.java7.streaming.marketdata; import org.apache.ignite.*; -import org.apache.ignite.examples.java8.*; +import org.apache.ignite.examples.streaming.numbers.ExamplesUtils; +import org.apache.ignite.examples.java7.*; import org.apache.ignite.lang.*; import org.apache.ignite.stream.*; @@ -58,7 +59,7 @@ public class StreamMarketData { // The cache is configured with sliding window holding 1 second of the streaming data. IgniteCache<String, MarketTick> mktCache = ignite.getOrCreateCache(CacheConfig.marketTicksCache()); - IgniteCache<String, Instrument> instCache = ignite.getOrCreateCache(CacheConfig.instrumentCache()); + final IgniteCache<String, Instrument> instCache = ignite.getOrCreateCache(CacheConfig.instrumentCache()); try (IgniteDataStreamer<String, MarketTick> mktStmr = ignite.dataStreamer(mktCache.getName())) { // Note that we receive market data, but do not populate 'mktCache' (it remains empty). http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/2df67c56/examples/src/main/java/org/apache/ignite/examples/java7/streaming/numbers/QueryPopularNumbers.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/java7/streaming/numbers/QueryPopularNumbers.java b/examples/src/main/java/org/apache/ignite/examples/java7/streaming/numbers/QueryPopularNumbers.java index 399f916..8b7d6c7 100644 --- a/examples/src/main/java/org/apache/ignite/examples/java7/streaming/numbers/QueryPopularNumbers.java +++ b/examples/src/main/java/org/apache/ignite/examples/java7/streaming/numbers/QueryPopularNumbers.java @@ -19,7 +19,7 @@ package org.apache.ignite.examples.java7.streaming.numbers; import org.apache.ignite.*; import org.apache.ignite.cache.query.*; -import org.apache.ignite.examples.java8.*; +import org.apache.ignite.examples.java7.*; import java.util.*; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/2df67c56/examples/src/main/java/org/apache/ignite/examples/java7/streaming/numbers/StreamRandomNumbers.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/java7/streaming/numbers/StreamRandomNumbers.java b/examples/src/main/java/org/apache/ignite/examples/java7/streaming/numbers/StreamRandomNumbers.java index bbac4d4..1fe3da7 100644 --- a/examples/src/main/java/org/apache/ignite/examples/java7/streaming/numbers/StreamRandomNumbers.java +++ b/examples/src/main/java/org/apache/ignite/examples/java7/streaming/numbers/StreamRandomNumbers.java @@ -19,7 +19,7 @@ package org.apache.ignite.examples.java7.streaming.numbers; import org.apache.ignite.*; import org.apache.ignite.cache.*; -import org.apache.ignite.examples.java8.*; +import org.apache.ignite.examples.java7.*; import org.apache.ignite.stream.*; import javax.cache.processor.*;
