ignite-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Evgenii Zhuravlev (JIRA)" <j...@apache.org>
Subject [jira] [Created] (IGNITE-7355) peerClassLoadin doesn't work with DataStreamer Transformer
Date Fri, 05 Jan 2018 17:12:03 GMT
Evgenii Zhuravlev created IGNITE-7355:

             Summary: peerClassLoadin doesn't work with DataStreamer Transformer
                 Key: IGNITE-7355
                 URL: https://issues.apache.org/jira/browse/IGNITE-7355
             Project: Ignite
          Issue Type: Bug
    Affects Versions: 2.3
            Reporter: Evgenii Zhuravlev

 try (IgniteDataStreamer<String, Object> streamer = ignite.dataStreamer(CacheName.CACHE))
            streamer.receiver(StreamTransformer.from(new MyCacheEntryProcessor()));
            streamer.addData("key", "value");

private static class MyCacheEntryProcessor implements CacheEntryProcessor<String, Object,
Object> {

        public Object process(MutableEntry<String, Object> mutableEntry, Object... objects)
throws EntryProcessorException {
            return null;

workaround: use streamer.deployClass(MyCacheEntryProcessor.class);

This message was sent by Atlassian JIRA

View raw message