public void testAddDataFromMap() throws Exception {
  try {
    binaries=false;
    startGrids(2);
    awaitPartitionMapExchange();
    Ignite g0=grid(0);
    IgniteDataStreamer<Integer,String> dataLdr=g0.dataStreamer(null);
    Map<Integer,String> map=U.newHashMap(KEYS_COUNT);
    for (int i=0; i < KEYS_COUNT; i++)     map.put(i,String.valueOf(i));
    dataLdr.addData(map);
    dataLdr.close();
    checkDistribution(grid(0));
    checkDistribution(grid(1));
    Random rnd=new Random();
    IgniteCache<Integer,String> c0=g0.cache(null);
    for (int i=0; i < 100; i++) {
      Integer k=rnd.nextInt(KEYS_COUNT);
      String v=c0.get(k);
      assertEquals(k.toString(),v);
    }
  }
  finally {
    G.stopAll(true);
  }
}

public void testAddDataFromMap ( ) throws Exception { try { binaries = false ; startGrids ( 2 ) ; awaitPartitionMapExchange ( ) ; Ignite g0 = grid ( 0 ) ; IgniteDataStreamer < Integer , String > dataLdr = g0 . dataStreamer ( null ) ; Map < Integer , String > map = U . newHashMap ( KEYS_COUNT ) ; for ( int i = 0 ; i < KEYS_COUNT ; i ++ ) map . put ( i , String . valueOf ( i ) ) ; dataLdr . addData ( map ) ; dataLdr . close ( ) ; checkDistribution ( grid ( 0 ) ) ; checkDistribution ( grid ( 1 ) ) ; Random rnd = new Random ( ) ; IgniteCache < Integer , String > c0 = g0 . cache ( null ) ; for ( int i = 0 ; i < 100 ; i ++ ) { Integer k = rnd . nextInt ( KEYS_COUNT ) ; String v = c0 . get ( k ) ; assertEquals ( k . toString ( ) , v ) ; } } finally { G . stopAll ( true ) ; } }
data streamer should correctly load entries from hashmap in case of grids with more than one node and with gridoptimizedmarshaller that requires serializable .
