ignite-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Sergi Vladykin <sergi.vlady...@gmail.com>
Subject Re: Cache performance for LOCAL mode + setIndexedTypes
Date Mon, 11 Jul 2016 21:15:21 GMT
I guess updating indexes is not free.

Sergi

On Mon, Jul 11, 2016 at 11:48 PM, AndreyVel <andrey4vel@gmail.com> wrote:

> Hello, I have created simple test for testing performance put operations
> on single computer,
> can anybody explain why performance for LOCAL mode different for Indexed
> and non Indexed mode?
>
>
>      Cache performance put(Integer, String)/sec: one client and 2
>      remote servers.
>
> CacheMode       TRANSACTIONAL   TRANSACTIONAL
> setIndexedTypes(Integer, String)        ATOMIC  ATOMIC
> setIndexedTypes(Integer, String)
> LOCAL   45154   107306  340627  581250
> REPLICATED      3270    2865    7272    5694
> PARTITIONED     6773    5403    8558    6714
>
>
> VM options -Xms1g -Xmx1g
> Topology snapshot [ver=5, servers=2, clients=1, CPUs=8, heap=3.0GB]
>
>
> public class CachePerformance {
>
>     private static int CACHE_SIZE =100 * 1000;
>     private static StringCACHE_NAME ="cachePerf";
>
>     public static void main(String[] args) {
>         try {
>             Ignition.setClientMode(true);
>             IgniteConfiguration igniteCfg =new IgniteConfiguration();
>             igniteCfg.setPeerClassLoadingEnabled(true);
>
>             Ignite ignite = Ignition.start(igniteCfg);
>             CachePerformance.execute(ignite);
>         }catch (Throwable ex) {
>             ex.printStackTrace();
>         }
>     }
>
> public static void execute(Ignite ignite)throws Exception {
>
>     Random rand =new Random();
>
>     for (CacheMode cacheMode : CacheMode.values()) {
>
>         for (CacheAtomicityMode atomMode : CacheAtomicityMode.values()) {
>             for (int indexMode =0; indexMode <=1; indexMode++) {
>
>                 CacheConfiguration<Integer, String> cacheCfg =new
> CacheConfiguration<>(CACHE_NAME);
>                 if (indexMode ==1)
>                     cacheCfg.setIndexedTypes(Integer.class, String.class);
>
>                 cacheCfg.setAtomicityMode(atomMode);
>                 cacheCfg.setCacheMode(cacheMode);
>
>                 ignite.destroyCache(CACHE_NAME);
>                 IgniteCache<Integer, String> cache =
> ignite.getOrCreateCache(cacheCfg);
>                 String cacheDesc ="cacheMode=" + cacheMode +", atomMode="
> + atomMode +", indexMode=" + indexMode;
>
>                 long time = System.nanoTime();
>                 for (int ind =0; ind <CACHE_SIZE; ind++) {
>                         Integer key = rand.nextInt();
>                         cache.put(key,"=" + ind);
>                 }
>
>                 long deltaMs = (System.nanoTime() - time) /1000000;
>                 long perfSec = (deltaMs ==0) ?0 :1000 *CACHE_SIZE /
> deltaMs;
>                 System.out.println(cacheDesc +", Perf/Sec = " + perfSec);
>             }
>         }
>     }
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message