code format fixed

akvelon · Mar 22, 2021 · 906e6e7 · 906e6e7
1 parent 6ac4193
commit 906e6e7
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 4 deletions.
diff --git a/...in/java/org/apache/beam/examples/complete/datatokenization/transforms/DataProtectors.java b/...in/java/org/apache/beam/examples/complete/datatokenization/transforms/DataProtectors.java
@@ -110,7 +110,8 @@ public PCollectionTuple expand(PCollection<KV<Integer, Row>> inputRows) {
       Duration maxBuffering = Duration.millis(MAX_BUFFERING);
       PCollectionTuple pCollectionTuple =
           inputRows
-              .apply("GroupRowsIntoBatches",
+              .apply(
+                  "GroupRowsIntoBatches",
                   GroupIntoBatches.<Integer, Row>ofSize(batchSize())
                       .withMaxBufferingDuration(maxBuffering))
               .apply(

diff --git a/...ain/java/org/apache/beam/examples/complete/datatokenization/transforms/JsonToBeamRow.java b/...ain/java/org/apache/beam/examples/complete/datatokenization/transforms/JsonToBeamRow.java
@@ -30,9 +30,7 @@
 import org.apache.beam.sdk.values.Row;
 import org.apache.beam.vendor.guava.v26_0_jre.com.google.common.base.Strings;
 
-/**
- * The {@link JsonToBeamRow} converts jsons string to beam rows.
- */
+/** The {@link JsonToBeamRow} converts jsons string to beam rows. */
 public class JsonToBeamRow extends PTransform<PCollection<String>, PCollection<Row>> {
 
   private final String failedToParseDeadLetterPath;