Membuat kueri database relasional melalui Google DataFlow Transformer

Ya itu mungkin. Anda bisa membuat objek Connection Anda sementara sehingga tidak serial dan membuatnya sekali per bundel melalui startBundle metode. Setelah semua elemen dalam bundel diproses, koneksi dapat ditutup melalui finishBundle metode.

class MyDoFn extends DoFn<X, Y> {
  private transient Connection jdbc;

  @Setup
  public void setup(Context c) {
    jdbc = // Create connection
  }

  @ProcessElement
  public void processElement(ProcessContext c) {
    // query database
  }

  @Teardown
  public void tearDown(Context c) {
    // close connection
  }
}