🎉Community Raffle - Win $25

An exclusive raffle opportunity for active members like you! Complete your profile, answer questions and get your first accepted badge to enter the raffle.
Join and Win

Parallel execution of subprocesses

User: "HeikoPaulheim"
New Altair Community Member
Updated by Jocelyn
Hi RapidMiners,

I have written an operator that executes a subprocess with different subsets of the data (like Bagging does, just a bit trickier, since the metadata also changes between the runs - but I eventually got it to work).

Now, my question is: can I execute multiple instances of the subprocess in parallel? If yes, how do I do that? The problem is that there seems to be only one instance of the nested process and its ports, so if I try something like that

innerExampleSource.deliver(DATA_FOR_THIS_RUN);
getSubprocess(0).execute();
PredictionModel model = (PredictionModel) innerModelSink.getData(PredictionModel.class);
in a multithreaded fashion, it breaks.

Any hints and/or templates?

Thank you,
Heiko

Find more posts tagged with

Sort by:
1 - 1 of 11
    User: "HeikoPaulheim"
    New Altair Community Member
    OP
    Hi RapidMiners,

    I found a way around by calling "cloneOperator". However, I am not exactly sure what is happening here (despite the documentation of said method saying "Use this method only if you sure what you are doing."  ;)), so I still appreciate your feedback.

    Cheers,
    Heiko