ML examples wrap logic in IgniteThread. Why?

[dmagda]

Yury, ML folks,

I've mentioned a strange thing. Looks like every example we have wraps up
its logic in the following block

IgniteThread igniteThread = new
IgniteThread(ignite.configuration().getIgniteInstanceName(),
    KMeansClusterizationExample.class.getSimpleName(), () -> {


//ML specific stuff (training, predicting, calculations, etc.)

});

igniteThread.start();
igniteThread.join();


Why do we do that?

Denis

[Yuriy Babak]

Denis,

Thanks for this notice, actually this is some kind of atavism. Run this
code inside IgniteThread was a requirement when we had a distributed
matrices. But now all our algorithms builds over distributed datasets and
we don't need it anymore.

I created JIRA ticket <https://issues.apache.org/jira/browse/IGNITE-9711>
for this.

Thanks,
Yuriy

чт, 27 сент. 2018 г. в 0:20, Denis Magda <[hidden email]>:

> Yury, ML folks,
>
> I've mentioned a strange thing. Looks like every example we have wraps up
> its logic in the following block
>
> IgniteThread igniteThread = new
> IgniteThread(ignite.configuration().getIgniteInstanceName(),
>     KMeansClusterizationExample.class.getSimpleName(), () -> {
>
>
> //ML specific stuff (training, predicting, calculations, etc.)
>
> });
>
> igniteThread.start();
> igniteThread.join();
>
>
> Why do we do that?
>
> Denis
>

[dmagda]

Thanks Yury, good to know about that!

--
Denis

On Wed, Sep 26, 2018 at 3:49 PM Юрий Бабак <[hidden email]> wrote:

> Denis,
>
> Thanks for this notice, actually this is some kind of atavism. Run this
> code inside IgniteThread was a requirement when we had a distributed
> matrices. But now all our algorithms builds over distributed datasets and
> we don't need it anymore.
>
> I created JIRA ticket <https://issues.apache.org/jira/browse/IGNITE-9711>
> for this.
>
> Thanks,
> Yuriy
>
> чт, 27 сент. 2018 г. в 0:20, Denis Magda <[hidden email]>:
>
> > Yury, ML folks,
> >
> > I've mentioned a strange thing. Looks like every example we have wraps up
> > its logic in the following block
> >
> > IgniteThread igniteThread = new
> > IgniteThread(ignite.configuration().getIgniteInstanceName(),
> >     KMeansClusterizationExample.class.getSimpleName(), () -> {
> >
> >
> > //ML specific stuff (training, predicting, calculations, etc.)
> >
> > });
> >
> > igniteThread.start();
> > igniteThread.join();
> >
> >
> > Why do we do that?
> >
> > Denis
> >
>