Hi Saurabh, DataStreamerImpl is an internal implementation class and it's not a good idea to extend it to provide your own implementation.
If you want to implement your own streamer to integrate with another product, refer to streamers implementation guideline [1]. Or you can use one of the implementations that are already provided in Ignite. [1] https://cwiki.apache.org/confluence/display/IGNITE/Streamers+Implementation+Guidelines -Val -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Issue-while-extending-out-of-the-box-classes-tp2733p2747.html Sent from the Apache Ignite Users mailing list archive at Nabble.com.
