Following code creates the data streamer instance
dataStreamer =
IgniteContextWrapper.getInstance().getEngine().dataStreamer("eventCache-" +
System.getProperty(RUN_ID) +"-"+ tenantId);
and for writing the data to cache,
dataStreamer.addData(key, value);
Nothing fancy, very simple code.
Instead of streamer, If I used cache.put, everything works fine but its dead
slow
--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/
