public Entry<Integer, String> extract(TupleBus msg) -> public Entry<Integer,
String> extract(SinkRecord msg)
in your extractor.
-- Roman
On Tuesday, May 30, 2017 10:21 PM, ignitedFox <[email protected]>
wrote:
Hi Humphrey,
So I need to create another class Bus? and define all getters and setters
there right? and instead of , i need to use ? is that the change I need to
make?
--
View this message in context:
http://apache-ignite-users.70518.x6.nabble.com/How-to-solve-SinkRecord-cannot-be-cast-exception-tp13221p13231.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.
