ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From anovi...@apache.org
Subject [12/15] incubator-ignite git commit: # ignite-45 - Example fixes.
Date Mon, 23 Mar 2015 05:27:33 GMT
# ignite-45 - Example fixes.


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

Branch: refs/heads/ignite-45-330
Commit: 235da8956721133e108f1b2c86c7d8c3338b6fec
Parents: a628cb9
Author: Dmitiry Setrakyan <dsetrakyan@gridgain.com>
Authored: Sun Mar 22 22:03:55 2015 -0700
Committer: Dmitiry Setrakyan <dsetrakyan@gridgain.com>
Committed: Sun Mar 22 22:03:55 2015 -0700

----------------------------------------------------------------------
 .../datagrid/CacheDataStreamerExample.java      |  16 +-
 .../datagrid/CachePopularNumbersExample.java    | 172 -------------------
 2 files changed, 8 insertions(+), 180 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/235da895/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheDataStreamerExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheDataStreamerExample.java
b/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheDataStreamerExample.java
index 6de1402..d4bbde9 100644
--- a/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheDataStreamerExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheDataStreamerExample.java
@@ -66,25 +66,25 @@ public class CacheDataStreamerExample {
                 System.out.println();
                 System.out.println(">>> Cache clear finished.");
 
-                try (IgniteDataStreamer<Integer, String> ldr = ignite.dataStreamer(CACHE_NAME))
{
-                    long start = System.currentTimeMillis();
+                long start = System.currentTimeMillis();
 
+                try (IgniteDataStreamer<Integer, String> stmr = ignite.dataStreamer(CACHE_NAME))
{
                     // Configure loader.
-                    ldr.perNodeBufferSize(1024);
-                    ldr.perNodeParallelOperations(8);
+                    stmr.perNodeBufferSize(1024);
+                    stmr.perNodeParallelOperations(8);
 
                     for (int i = 0; i < ENTRY_COUNT; i++) {
-                        ldr.addData(i, Integer.toString(i));
+                        stmr.addData(i, Integer.toString(i));
 
                         // Print out progress while loading cache.
                         if (i > 0 && i % 10000 == 0)
                             System.out.println("Loaded " + i + " keys.");
                     }
+                }
 
-                    long end = System.currentTimeMillis();
+                long end = System.currentTimeMillis();
 
-                    System.out.println(">>> Loaded " + ENTRY_COUNT + " keys in "
+ (end - start) + "ms.");
-                }
+                System.out.println(">>> Loaded " + ENTRY_COUNT + " keys in " + (end
- start) + "ms.");
             }
         }
     }

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/235da895/examples/src/main/java/org/apache/ignite/examples/datagrid/CachePopularNumbersExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/CachePopularNumbersExample.java
b/examples/src/main/java/org/apache/ignite/examples/datagrid/CachePopularNumbersExample.java
deleted file mode 100644
index b1cc6d8..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/datagrid/CachePopularNumbersExample.java
+++ /dev/null
@@ -1,172 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.examples.datagrid;
-
-import org.apache.ignite.*;
-import org.apache.ignite.cache.*;
-import org.apache.ignite.cache.query.*;
-import org.apache.ignite.cluster.*;
-import org.apache.ignite.configuration.*;
-import org.apache.ignite.examples.*;
-import org.apache.ignite.stream.*;
-
-import javax.cache.processor.*;
-import java.util.*;
-
-/**
- * Real time popular numbers counter.
- * <p>
- * Remote nodes should always be started with special configuration file which
- * enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-ignite.xml'}.
- * <p>
- * Alternatively you can run {@link ExampleNodeStartup} in another JVM which will
- * start node with {@code examples/config/example-ignite.xml} configuration.
- */
-public class CachePopularNumbersExample {
-    /** Cache name. */
-    private static final String CACHE_NAME = CachePopularNumbersExample.class.getSimpleName();
-
-    /** Count of most popular numbers to retrieve from cluster. */
-    private static final int POPULAR_NUMBERS_CNT = 10;
-
-    /** Random number generator. */
-    private static final Random RAND = new Random();
-
-    /** Range within which to generate numbers. */
-    private static final int RANGE = 1000;
-
-    /** Count of total numbers to generate. */
-    private static final int CNT = 1000000;
-
-    /**
-     * Executes example.
-     *
-     * @param args Command line arguments, none required.
-     * @throws IgniteException If example execution failed.
-     */
-    public static void main(String[] args) throws IgniteException {
-        Timer popularNumbersQryTimer = new Timer("numbers-query-worker");
-
-        try (Ignite ignite = Ignition.start("examples/config/example-ignite.xml")) {
-            System.out.println();
-            System.out.println(">>> Cache popular numbers example started.");
-
-            CacheConfiguration<Integer, Long> cfg = new CacheConfiguration<>();
-
-            cfg.setCacheMode(CacheMode.PARTITIONED);
-            cfg.setName(CACHE_NAME);
-            cfg.setIndexedTypes(
-                Integer.class, Long.class
-            );
-
-            try (IgniteCache<Integer, Long> cache = ignite.createCache(cfg)) {
-                ClusterGroup prj = ignite.cluster().forCacheNodes(CACHE_NAME);
-
-                if (prj.nodes().isEmpty()) {
-                    System.out.println("Ignite does not have cache configured: " + CACHE_NAME);
-
-                    return;
-                }
-
-                TimerTask task = scheduleQuery(ignite, popularNumbersQryTimer, POPULAR_NUMBERS_CNT);
-
-                streamData(ignite);
-
-                // Force one more run to get final counts.
-                task.run();
-
-                popularNumbersQryTimer.cancel();
-            }
-        }
-    }
-
-    /**
-     * Populates cache in real time with numbers and keeps count for every number.
-     *
-     * @param ignite Ignite.
-     * @throws IgniteException If failed.
-     */
-    private static void streamData(final Ignite ignite) throws IgniteException {
-        try (IgniteDataStreamer<Integer, Long> stmr = ignite.dataStreamer(CACHE_NAME))
{
-            // Set larger per-node buffer size since our state is relatively small.
-            stmr.perNodeBufferSize(2048);
-
-            stmr.receiver(new IncrementingUpdater());
-
-            for (int i = 0; i < CNT; i++)
-                stmr.addData(RAND.nextInt(RANGE), 1L);
-        }
-    }
-
-    /**
-     * Schedules our popular numbers query to run every 3 seconds.
-     *
-     * @param ignite Ignite.
-     * @param timer Timer.
-     * @param cnt Number of popular numbers to return.
-     * @return Scheduled task.
-     */
-    private static TimerTask scheduleQuery(final Ignite ignite, Timer timer, final int cnt)
{
-        TimerTask task = new TimerTask() {
-            @Override public void run() {
-                // Get reference to cache.
-                IgniteCache<Integer, Long> cache = ignite.jcache(CACHE_NAME);
-
-                try {
-                    List<List<?>> results = cache.query(
-                        new SqlFieldsQuery("select _key, _val from Long order by _val desc,
_key limit ?").setArgs(cnt))
-                        .getAll();
-
-                    for (List<?> res : results)
-                        System.out.println(res.get(0) + "=" + res.get(1));
-
-                    System.out.println("----------------");
-                }
-                catch (Exception e) {
-                    e.printStackTrace();
-                }
-            }
-        };
-
-        timer.schedule(task, 3000, 3000);
-
-        return task;
-    }
-
-    /**
-     * Increments value for key.
-     */
-    private static class IncrementingUpdater implements StreamReceiver<Integer, Long>
{
-        /** Process entries to increase value by entry key. */
-        private static final EntryProcessor<Integer, Long, ?> INC = new EntryProcessor<Integer,
Long, Object>() {
-            @Override public Object process(MutableEntry<Integer, Long> e, Object...
args) {
-                Long val = e.getValue();
-
-                e.setValue(val == null ? 1L : val + 1);
-
-                return null;
-            }
-        };
-
-        /** {@inheritDoc} */
-        @Override public void receive(IgniteCache<Integer, Long> cache, Collection<Map.Entry<Integer,
Long>> entries) {
-            for (Map.Entry<Integer, Long> entry : entries)
-                cache.invoke(entry.getKey(), INC);
-        }
-    }
-}


Mime
View raw message