Hi,

You must use IgniteDataStreamer#addData(key, value) to stream data into
Ignite.

What you did when you attached a receiver would make the data streamer
execute the receiver on the nodes in co-located mode (that is the receiver
logic will be called on the node where the receiver's input data is
located). But to have the receiver logic called you must stream the data
using addData.

Reply via email to