Hazelcast Jet CDC CdcSinks Sınıfı

Giriş

Şu satırı dahil ederiz 

import com.hazelcast.jet.cdc.CdcSinks;

CDC ile yakalanan değişiklikleri bir sink nesnesine yazar

map metodu

Örnek

Şöyle yaparız

StreamSource<ChangeRecord> theDataBase = ...;,
IMap<Long, String> myMap = ...;

var pipeline = Pipeline.create();
pipeline.readFrom(theDataBase)
  .withoutTimestamps()
  .writeTo(CdcSinks.map(myMap, 
    record -> Long.parseLong(record.key().toMap().get("id").toString()), 
    record -> record.value().toJson()));

record nesnesi com.hazelcast.jet.cdc.ChangeRecord tipinden. key() metodu ile 

com.hazelcast.jet.cdc.RecordPart nesnesi elde edilir. toMap() çağrısı ile JSON nesnesi map haline getirilir