Hazelcast Jet SelectProcessorSupplier Sınıfı - ReadJdbcP Processor Yaratır

Giriş

Şu satırı dahil ederiz

import com.hazelcast.jet.sql.impl.connector.jdbc.SelectProcessorSupplier;

constructor

Kod şöyle. Processor'a verilecek SQL cümlesi ve parametreler belirtilir.

public SelectProcessorSupplier(String dataConnectionName,
                               String query,
                               int[] parameterPositions) {
  ...
}

get metodu

Kod şöyle. count parametresi dikkate alınmaz ve tek bir ReadJdbcP yaratılır

@Override
public Collection<? extends Processor> get(int count) {
  Processor processor = new ReadJdbcP<>(
    ...
  );
  return singleton(processor);
}