[
https://issues.apache.org/jira/browse/IGNITE-5037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16224051#comment-16224051
]
Dmitriy Pavlov edited comment on IGNITE-5037 at 10/29/17 3:49 PM:
------------------------------------------------------------------
I agree here, there is some lack in the methods availabe. MapReduce job can be
performed only outside of the binding to partitions, but it would be convenient
to perform MR-job on the data in the cache (the group of caches).
We have method
{code}
public <R1, R2, T> R2 apply(IgniteClosure<T, R1> job, Collection<? extends T>
args,
IgniteReducer<R1, R2> rdc) throws IgniteException;
{code}
but there is no method taking IgniteReducer and the same time having affinity
collocation
was (Author: dpavlov):
I agree here, there is some lack in the methods availabe. MapReduce job can be
performed only outside of the binding to partitions, but it would be convenient
to perform on the data exactly the cache (the group of caches).
We have method
{code}
public <R1, R2, T> R2 apply(IgniteClosure<T, R1> job, Collection<? extends T>
args,
IgniteReducer<R1, R2> rdc) throws IgniteException;
{code}
but there is no method taking IgniteReducer and the same time having affinity
collocation
> Fix broken @AffinityKeyMapped annotation for compute jobs.
> ----------------------------------------------------------
>
> Key: IGNITE-5037
> URL: https://issues.apache.org/jira/browse/IGNITE-5037
> Project: Ignite
> Issue Type: Improvement
> Affects Versions: 1.7
> Reporter: Alexei Scherbakov
> Assignee: Maksim Kozlov
> Labels: newbie
>
> See related discussion on dev list entitled Proper collocation of
> computations and data
> (http://apache-ignite-developers.2346864.n4.nabble.com/Proper-collocation-of-computations-and-data-td16945.html).
> We must repair data affinity routing for compute jobs. It should work same as
> for affinityCall/Run with partition.
> Currently, ComputeTask map method returns Map<? extends ComputeJob,
> ClusterNode>,
> but we have to provide some API allows to map ComputeJobs to partitions or
> keys.
> This can be done using AffinityKeyMapped annotation or any other way.
> Since that's a publiŃ API any fixes should be discussed on dev list prior to
> implementation.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
