You need to create your own class you want to store in Ignite, if you want to query the objects later using annotation look at [1]. Mine was just an example to show, and not to use.
As input you getting SinkRecord, which you need to convert to Entry<Integer, YourClass> where Integer would be the BUS_ID and YourClass would be the object you want to store using indexes [1]. https://apacheignite.readme.io/docs/indexes#annotation-based-configuration -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/How-to-solve-SinkRecord-cannot-be-cast-exception-tp13221p13232.html Sent from the Apache Ignite Users mailing list archive at Nabble.com.
