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


Example:
{code:java}
 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> {

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

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



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Mime
View raw message