Hazelcast Jet TestSources Sınıfı

Giriş
Şu satırı dahil ederiz 

import com.hazelcast.jet.pipeline.test.TestSources;

Açıklaması şöyle

Data generators for quick start and testing

items metodu

Belirtilen listeyi döner

Örnek

Şöyle yaparız

Pipeline pipeline = Pipeline.create();

BatchSource<String> leftSource = TestSources.items("the", "quick", "brown", "fox");
BatchSource<String> rightSource = TestSources.items("jumps", "over", "the", "lazy", "dog");

BatchStage<String> left = pipeline.readFrom(leftSource);
BatchStage<String> right = pipeline.readFrom(rightSource);

left.merge(right)
    .writeTo(Sinks.logger());

Örnek

Şöyle yaparız

List<String> source = new ArrayList<>();
...
Pipeline pipeline = Pipeline.create();
pipeline.readFrom(TestSources.items(source))
  ...

itemStream metodu - itemsPerSecond

Saniyede belirtilen sayı kadar nesne döner.

Örnek

Şöyle yaparız

public static void main(String[] args) {
  Pipeline pipeline = Pipeline.create();
  pipeline.readFrom(TestSources.itemStream(10))
    .withoutTimestamps()
    .filter(event -> event.sequence() % 2 == 0)
    .setName("filter out odd numbers")
    .writeTo(Sinks.logger());

  HazelcastInstance hz = Hazelcast.bootstrappedInstance();
  hz.getJet().newJob(pipeline);
}

itemStream metodu - itemsPerSecond + GeneratorFunction

Örnek

Şöyle yaparız. Aslında bu kötü bir örnek. Burada saniyede 10 tane Person nesnesi yaratılıyor ama hepsi aynı sabit String ile ilklendiriliyor

String item = ...; 
Pipeline pipeline = Pipeline.create();
pipeline.readFrom(TestSources.itemStream(10, (t, u) -> item))
  .withoutTimestamps()
  .rebalance()
  .map(t -> new Person(t))
  .rebalance()
  ...