Re: Missing records Ignite cache size grows

[diopek]

Yes, we checked uniqueness of key several times. Below is representative
snippet of our code, how we generate cache key inside inputIterator method.

@Override
protected Iterator<Tuple2&lt;Long,ArrayList&lt;MyDTO>>>
*inputIterator*(Object... args) throws CacheLoaderException {
        Iterator<Tuple2&lt;Long,ArrayList&lt;MyDTO>>> iterator = null;
        ResultSetExtractor<ArrayList&lt;Tuple2&lt;Long,ArrayList&lt;MyDTO>>>>
extOrRepMapResultSetExtractor = new
ResultSetExtractor<ArrayList&lt;Tuple2&lt;Long,ArrayList&lt;MyDTO>>>>() {
                @Override
                public ArrayList<Tuple2&lt;Long,ArrayList&lt;MyDTO>>>
extractData(ResultSet rs)
                                throws SQLException, DataAccessException {
                        ArrayList<Tuple2&lt;Long,ArrayList&lt;MyDTO>>> 
extOrRepList = new
ArrayList<Tuple2&lt;Long,ArrayList&lt;MyDTO>>>(startSize);
                        *final AtomicLong entryCnt = new AtomicLong(0);*
                        while (rs.next()) {     
                                extOrRepList.add(new Tuple2<Long,
ArrayList&lt;MyDTO>>(*entryCnt.incrementAndGet()*,prevDTOList));
                        }
                        return extOrRepList;
                }
        };

        jdbcTemplate.setFetchSize(SQL_FETCH_SIZE);      
        ArrayList<Tuple2&lt;Long,ArrayList&lt;MyDTO>>> extOrRepList = null;
        extOrRepList = jdbcTemplate.query(sql, extOrRepMapResultSetExtractor);  

        if (extOrRepList != null) {
                iterator = extOrRepList.iterator();
        }
        return iterator;
        
}



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/Missing-records-Ignite-cache-size-grows-tp10809p10890.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.