[
https://issues.apache.org/jira/browse/IGNITE-7355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Denis Mekhanikov reassigned IGNITE-7355:
----------------------------------------
Assignee: Denis Mekhanikov
> peerClassLoading 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
> Assignee: Denis Mekhanikov
>
> 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)
