Google DataFlow Transformer के माध्यम से रिलेशनल डेटाबेस को क्वेरी करना

हाँ, ऐसा सम्भव है। आप अपने कनेक्शन ऑब्जेक्ट को क्षणिक बना सकते हैं ताकि इसे क्रमबद्ध न किया जाए और इसे प्रति बंडल एक बार startBundle के माध्यम से बनाया जाए तरीका। एक बार बंडल में सभी तत्व संसाधित हो जाने के बाद, कनेक्शन को finishBundle के माध्यम से बंद किया जा सकता है तरीका।

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