Apply suggestions from code review

apache · Nov 30, 2022 · fa1bd88 · fa1bd88
1 parent 5a3ee7f
commit fa1bd88
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/GroupIntoBatches.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/GroupIntoBatches.java
@@ -117,7 +117,7 @@ public class GroupIntoBatches<K, InputT>
    */
   @AutoValue
   public abstract static class BatchingParams<InputT> implements Serializable {
-    public static <InputT> BatchingParams<InputT> createDefault() {
+    private static <InputT> BatchingParams<InputT> createDefault() {
       return new AutoValue_GroupIntoBatches_BatchingParams(
           Long.MAX_VALUE, Long.MAX_VALUE, null, Duration.ZERO);
     }

diff --git a/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/GroupIntoBatchesTest.java b/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/GroupIntoBatchesTest.java
@@ -183,8 +183,7 @@ public void testInGlobalWindowBatchSizeByteSizeFn() {
 
     // to ensure ordered processing
     TestStream.Builder<KV<String, String>> streamBuilder =
-        TestStream.create(KvCoder.of(StringUtf8Coder.of(), StringUtf8Coder.of()))
-            .advanceWatermarkTo(Instant.EPOCH);
+        TestStream.create(KvCoder.of(StringUtf8Coder.of(), StringUtf8Coder.of()));
 
     long offset = 0L;
     for (KV<String, String> kv : data) {