ignite.compute(ignite..cluster().forLocal()).run() will run the ignite
runnble on local node.
final pseudo code -
ignite.compute().broadcast(new IgniteRunnable() {
@Override
public void run() {
Observable<Long> o = Observable.timer(((CommonUtils.getCurrentDayTime() +
24 * 60 * 60 * 1000) - System.currentTimeMillis()), 24 * 60 * 60 *
1000, TimeUnit.MILLISECONDS,
scheduler);
o.subscribe(item -> {
ignite.compute(ignite..cluster().forLocal()).run(new IgniteRunnableTask());
});
}
});
On 7 March 2017 at 10:23, Anil <[email protected]> wrote:
> Hi,
>
> Are there any settings to use ignite.compute().run() to run the task on
> local node ?
>
> i am try to schedule the task on each node using Rx Scheduler. so I am
> broadcasting a runnable which initiates the scheduler on each node.
>
> As I know, we cannot run a task on local node using
> ignite.compute().run(). this will run the task on one of the nodes. correct
> ?
>
> we can start the thread for runnable instance and this will run the task
> on local node. Bu this cannot inject ignite instance into runnable instance.
>
> Do you have any suggestions to achieve this ?
>
> Thanks
>
>
>
