Кластерные операции¶

Система предоставляет возможность выполнения кластерных операций, основанную на технологии HazelcastJet.

Зависимости¶

В версии системы 2.7 и старше используется версия hazelcast 5.1.2

implementation "com.hazelcast:hazelcast:5.1.2"

Как использовать¶

org.unidata.mdm.core.service.RunService - адаптер com.hazelcast.jet.JetService

Вариант использования RunService

JobConfig jc = new com.hazelcast.jet.config.JobConfig();
jc.setArgument("param_name", "param_value");

String runId = IdUtils.v1String();

Pipeline pipeline = com.hazelcast.jet.pipeline.Pipeline.create();

pipeline
    .readFrom(...)
    .mapUsingService(...)
    .writeTo(...)

RunContext ctx = RunContext.builder()
        .pipeline(pipeline)
        .runConfig(jc)
        .runName("run_name:" + runId)
        .build();

runService.run(ctx);