ignite-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vkulichenko <valentin.kuliche...@gmail.com>
Subject Re: Update value in stream transformer
Date Tue, 10 Jan 2017 19:41:06 GMT
I see what you're saying now. Streamed value is passed to your implementation
as an argument, so you can do smth like this:

stmr.receiver(new StreamTransformer<Integer, Long>() {
    @Override public Object process(MutableEntry<Integer, Long> e, Object...
args) {
        Object streamed = args[0];

        // Entry processor logic here.


View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Update-value-in-stream-transformer-tp9974p10001.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

View raw message