You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@ignite.apache.org by "Evgenii Zhuravlev (JIRA)" <ji...@apache.org> on 2018/01/05 17:12:03 UTC

[jira] [Updated] (IGNITE-7355) peerClassLoading doesn't work with DataStreamer Transformer

     [ https://issues.apache.org/jira/browse/IGNITE-7355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Evgenii Zhuravlev updated IGNITE-7355:
--------------------------------------
    Summary: peerClassLoading doesn't work with DataStreamer Transformer  (was: peerClassLoadin doesn't work with DataStreamer Transformer)

> 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
>
> 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)