ignite-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Denis Mekhanikov (JIRA)" <j...@apache.org>
Subject [jira] [Assigned] (IGNITE-7355) peerClassLoading doesn't work with DataStreamer Transformer
Date Tue, 09 Jan 2018 16:21:00 GMT

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

Mime
View raw message