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/
