Fråga efter en relationsdatabas genom Google DataFlow Transformer

Ja det är möjligt. Du kan göra ditt Connection-objekt transient så att det inte serialiseras och skapa det en gång per paket genom startBundle metod. När alla element i paketet har bearbetats kan anslutningen stängas genom finishBundle metod.

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
  }
}