Re: Ignite 2.0 tasks/roadmap

[Andrey Velichko]

15.07.2016 0:31, Dmitriy Setrakyan пишет:

On Fri, Jul 15, 2016 at 12:26 AM, AndreyVel  wrote:


Good feature may be Aggregated cache - analog materialized view in DBMS
Aggregated cache is great for performance (KPI, analytecal reports).


Do you mean a copy of the aggregated data in another cache? What happens
when the data in the original caches is updated?




Yes, aggregated data can be store in another cache,
embedded aggregating cache can be updated sync/async. Aggregating from 
the box has better performance then creating custom event listeners.


If cache entry updated/deleted aggregate listener can get 2 values old 
and new.

Re: Cache performance for LOCAL mode + setIndexedTypes

[Andrey Velichko]

Agree, indexes consume CPU, but as shown in the table,
performance for index and  CacheMode=LOCAL more then 2x.

CacheMode.CacheMode + TRANSACTIONAL = 45 K op./sec
CacheMode.CacheMode + TRANSACTIONAL + setIndexedTypes = 107 K op./sec

CacheMode.CacheMode + ATOMIC= 340 K op./sec
CacheMode.CacheMode + ATOMIC+ setIndexedTypes = 581 K op./sec


12.07.2016 0:15, Sergi Vladykin пишет:

I guess updating indexes is not free.

Sergi

On Mon, Jul 11, 2016 at 11:48 PM, AndreyVel  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  3270286572725694
PARTITIONED 6773540385586714


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 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 cache =
ignite.getOrCreateCache(cacheCfg);
 String cacheDesc ="cacheMode=" + cacheMode +", atomMode="
+ atomMode +", indexMode=" + indexMode;

 long time = System.nanoTime();
 for (int ind =0; ind 

ContinuousQuery onUpdate

[Andrey Velichko]

Hello, I need help about issue 
https://issues.apache.org/jira/browse/IGNITE-2079


If there are Exceptions inside notifyCallback0, client lose 
eventonUpdatefor ContinuousQuery.setLocalListener

see line 674 of CacheContinuousQueryHandler.notifyCallback0

It is common situation when listener handler fails and event lost for 
listener.

What the best way delivery Exception for listener?
Maybe it is unbelievable situation whencache.put passed and listener 
handler fails?

[jira] [Created] (IGNITE-3373) Distributed IgniteSet shows size() == 0 for any new node

[Andrey Velichko (JIRA)]

Andrey Velichko created IGNITE-3373:
---

 Summary: Distributed IgniteSet shows size() == 0 for any new node
 Key: IGNITE-3373
 URL: https://issues.apache.org/jira/browse/IGNITE-3373
 Project: Ignite
  Issue Type: Bug
Reporter: Andrey Velichko


For distributed IgniteSet new node shows incorrdet set size
igniteSet.size() == 0 shows 0, 

CollectionConfiguration collectionConfiguration = new 
CollectionConfiguration();
collectionConfiguration.setCollocated(true); 

IgniteSet numbers = ignite.set("numbers", null);
if (numbers == null) {
System.out.println("[local] creating collection [numbers]");
numbers = ignite.set("numbers", collectionConfiguration);
}

boolean cont = numbers.contains(42L);   // true - OK
int num = numbers.size();   // 0 Error ???
System.out.println("size=" + num + ", contains=" + cont);

numbers.forEach(val -> {
System.out.println(val); // Iterator is not iterate :(
});

numbers.add(42L);
Thread.sleep(1000 * 6000);



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

New contributor: Andrey Velichko

[Andrey Velichko]

Hi Ignite Community!

My name is Andrey. I want to contribute to Apache Ignite and am starting
with the following issue:IGNITE-2852 
. Any suggestions are 
welcome.

Thanks!