Hazelcast Jet PipelineImpl Sınıfı

Giriş
Şu satırı dahil ederiz 

import com.hazelcast.jet.impl.pipeline.PipelineImpl;

Pipeline arayüzünden kalıtır. readFrom(), writeTo() gibi işlemler adjacencyMap içindedir. Bu map içindeki nesneler Serializable olmak zorunda

Kod şöyle

public class PipelineImpl implements Pipeline {

  private static final long serialVersionUID = 1L;

  private final Map<Transform, List<Transform>> adjacencyMap = new LinkedHashMap<>();
  private final Map<String, File> attachedFiles = new HashMap<>();
  private boolean preserveOrder;
  ...
}