Hazelcast Jet SourceBuilder Arayüzü

Giriş
Şu satırı dahil ederiz 

importcom.hazelcast.jet.pipeline.SourceBuilder;

Eğer elle bir BatchSource yaratmak istersek kullanıırız. Çoğunlukla bir veri yapısı doldurulup

- Sources.files()

- Sources.list()

- Sources.map()

gibi metodlar kullanılıyor

batch metodu

İmzası şöyle. BatchSource nesnesi döner. 

public static <C> SourceBuilder<C>.Batch<Void> batch(
  String name,
  FunctionEx<? super Processor.Context, ? extends C> createFn
)

Örnek

Şöyle yaparız. Burada source olarak sonsuz bir stream kullanıyoruz. Stream'in durmasını sağlayan şey fillBuffer() metodu

SourceBuilder
  .batch("java-8-stream", new Java8StreamSource<>(() -> Stream.iterate(1, i -> i + 1)))
  .fillBufferFn(new Java8StreamFiller<>())
  .build();

Örnek

Şöyle yaparız

BatchSource<String> mySource() {
  return SourceBuilder.batch("72743077", jobContext -> new MyBatchSource()
    .fillBufferFn(...)
    .build();
}