Hazelcast Jet AggregateOperations Sınıfı

Giriş

Şu satırı dahil ederiz

import com.hazelcast.jet.aggregate.AggregateOperations;

Şeklen şöyle

counting metodu

Örnek

Şöyle yaparız

Pipeline p = Pipeline.create();
p.readFrom(sourceOfLines())
  .flatMap(line -> traverseArray(line.split("\\W+")))
  .filter(word -> !word.isEmpty())
  .groupingKey(wholeItem())
  .aggregate(counting())
  .writeTo(Sinks.map("counts"));

toList metodu

BatchStage<List<X>> şeklinde bir şey döner

Örnek

Şöyle yaparız

jdbcSource
  .aggregate(AggregateOperations.toList())
  .writeTo(Sinks.json("directory-where-a-single-file-will-be-created"))