Hi,
Please share a full code of your EntryProcessor. Which logger do you use
here?
Thanks,
Evgenii
2018-01-20 21:00 GMT+03:00 Pim D <pim.dorrest...@ns.nl>:
> Hi,
>
> I have created a datastreamer that will stream data from a database to my
> cache.
> This works very nice, untill...
> ... I include a StreamTransformer in the data streamer.
> When the transformer is set, nothing gets stored in the cache?!?
>
> In a simple example my transformer extends the StreamTransformer and
> implements process:
> @Override
> public Object process(MutableEntry<String, Integer> entry, Object...
> arg) throws EntryProcessorException {
> if (log.isDebugEnabled())
> log.debug("Laad " + entry.getKey() + " in de cache");
> if (arg.length==1 && arg[0] instanceof HighScore) {
> // Transformeer stream argument naar het cache object en zet
> deze
> entry.setValue((Integer) arg[0]);
> }
> return arg[0];
> }
>
> Eventually I would really like to transform the object read from the
> database to a new object which corresponds with my cache value object
> (basic
> ETL).
> But for now I first need to get the Streamer to work properly.
> Any clues why this is not working?
>
>
>
> --
> Sent from: http://apache-ignite-users.70518.x6.nabble.com/
>
