And how about DELETE? On Fri, 15 Mar 2019 at 16:58, aealexsandrov <[email protected]> wrote:
> Hi, > > You can use the Kafka streamer for these purposes: > > https://apacheignite-mix.readme.io/docs/kafka-streamer > > Also, take a look at this thread. It contains examples of how to work with > JSON files: > > > http://apache-ignite-users.70518.x6.nabble.com/Kindly-tell-me-where-to-find-these-jar-files-td12649.html > > According to UPSERT specific. You should set the allowoverride flag to the > IgniteStreamer used by KafkaStreamer (otherwise it will be INSERT > specific). > You can do it using the next methods: > > > https://ignite.apache.org/releases/latest/javadoc/org/apache/ignite/stream/StreamAdapter.html#getStreamer-- > > https://ignite.apache.org/releases/latest/javadoc/org/apache/ignite/stream/StreamAdapter.html#setStreamer-org.apache.ignite.IgniteDataStreamer- > > BR, > Andrei > > > > -- > Sent from: http://apache-ignite-users.70518.x6.nabble.com/ >
