File tree Expand file tree Collapse file tree
sdks/java/io/debezium/src/main/java/org/apache/beam/io/debezium Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -153,14 +153,11 @@ public PCollectionRowTuple expand(PCollectionRowTuple input) {
153153 } else {
154154 if (configuration .getMaxNumberOfRecords () != null ) {
155155 readTransform =
156- readTransform .withMaxNumberOfRecords (
157- configuration .getMaxNumberOfRecords ());
156+ readTransform .withMaxNumberOfRecords (configuration .getMaxNumberOfRecords ());
158157 }
159158
160159 if (configuration .getMaxTimeToRun () != null ) {
161- readTransform =
162- readTransform .withMaxTimeToRun (
163- configuration .getMaxTimeToRun ());
160+ readTransform = readTransform .withMaxTimeToRun (configuration .getMaxTimeToRun ());
164161 }
165162 }
166163
@@ -263,6 +260,10 @@ public static Builder builder() {
263260
264261 @ AutoValue .Builder
265262 public abstract static class Builder {
263+ public abstract Builder setMaxNumberOfRecords (@ Nullable Integer maxNumberOfRecords );
264+
265+ public abstract Builder setMaxTimeToRun (@ Nullable Long maxTimeToRun );
266+
266267 public abstract Builder setUsername (String username );
267268
268269 public abstract Builder setPassword (String password );
You can’t perform that action at this time.
0 commit comments