Hazelcast Jet DeleteProcessorSupplier Sınıfı

Giriş
Şu satırı dahil ederiz 

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

Kalıtım şöyle

ProcessorSupplier

  AbstractJdbcSqlConnectorProcessorSupplier

    DeleteProcessorSupplier

get metodu

Kodu şöyle. Belirtilen sayıda WriteJdbcP processor yaratır

@Nonnull
@Override
public Collection<? extends Processor> get(int localParallelism) {
  List<Processor> processors = new ArrayList<>(localParallelism);
  for (int i = 0; i < count; i++) {
    Processor processor = new WriteJdbcP<>(
      query,
      dataSource,
      (PreparedStatement ps, JetSqlRow row) -> {
        for (int j = 0; j < row.getFieldCount(); j++) {
          ps.setObject(j + 1, row.get(j));
        }
      },
      false,
      batchLimit
    );
    processors.add(processor);
  }
  return processors;
}