spotlessApply

apache · Nov 1, 2024 · f960dba · f960dba
1 parent 8da4d34
commit f960dba
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/JdbcIO.java b/sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/JdbcIO.java
@@ -1380,6 +1380,12 @@ public ReadWithPartitions<T, PartitionColumnT> withFetchSize(int fetchSize) {
       return toBuilder().setFetchSize(fetchSize).build();
     }
 
+    /** Whether to disable auto commit on read. Defaults to true if not provided. */
+    public ReadWithPartitions<T, PartitionColumnT> withDisableAutoCommit(
+        boolean disableAutoCommit) {
+      return toBuilder().setDisableAutoCommit(disableAutoCommit).build();
+    }
+
     /** Data output type is {@link Row}, and schema is auto-inferred from the database. */
     public ReadWithPartitions<T, PartitionColumnT> withRowOutput() {
       return toBuilder().setUseBeamSchema(true).build();