format

apache · Dec 14, 2024 · b181a07 · b181a07
1 parent 4198e5b
commit b181a07
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 4 deletions.
diff --git a/xtable-api/src/main/java/org/apache/xtable/spi/sync/ConversionTarget.java b/xtable-api/src/main/java/org/apache/xtable/spi/sync/ConversionTarget.java
@@ -97,7 +97,7 @@ public interface ConversionTarget {
    *
    * @param sourceIdentifier the unique identifier of the source table commit
    * @return an {@link Optional} containing the target commit identifier if a corresponding commit
-   *    exists, or an empty {@link Optional} if no match is found
+   *     exists, or an empty {@link Optional} if no match is found
    */
   Optional<String> getTargetCommitIdentifier(String sourceIdentifier);
 }
diff --git a/xtable-core/src/test/java/org/apache/xtable/delta/TestDeltaSync.java b/xtable-core/src/test/java/org/apache/xtable/delta/TestDeltaSync.java
@@ -166,14 +166,16 @@ public void testCreateSnapshotControlFlow() throws Exception {
 
     TableFormatSync.getInstance()
         .syncSnapshot(Collections.singletonList(conversionTarget), snapshot1);
-    Optional<String> targetIdentifier1 = conversionTarget.getTargetCommitIdentifier(snapshot1.getSourceIdentifier());
+    Optional<String> targetIdentifier1 =
+        conversionTarget.getTargetCommitIdentifier(snapshot1.getSourceIdentifier());
     validateDeltaTable(basePath, new HashSet<>(Arrays.asList(dataFile1, dataFile2)), null);
     assertTrue(targetIdentifier1.isPresent());
     assertEquals("0", targetIdentifier1.get());
 
     TableFormatSync.getInstance()
         .syncSnapshot(Collections.singletonList(conversionTarget), snapshot2);
-    Optional<String> targetIdentifier2 = conversionTarget.getTargetCommitIdentifier(snapshot2.getSourceIdentifier());
+    Optional<String> targetIdentifier2 =
+        conversionTarget.getTargetCommitIdentifier(snapshot2.getSourceIdentifier());
     validateDeltaTable(basePath, new HashSet<>(Arrays.asList(dataFile2, dataFile3)), null);
     assertTrue(targetIdentifier2.isPresent());
     assertEquals("1", targetIdentifier2.get());

diff --git a/xtable-core/src/test/java/org/apache/xtable/hudi/ITHudiConversionSourceTarget.java b/xtable-core/src/test/java/org/apache/xtable/hudi/ITHudiConversionSourceTarget.java
@@ -392,7 +392,8 @@ CONTEXT, getHoodieWriteConfig(metaClient).getMetadataConfig(), tableBasePath, tr
     assertTrue(targetIdentifier5.isPresent());
 
     // Case that return empty target identifier
-    Optional<String> emptyTargetIdentifier = targetClient.getTargetCommitIdentifier("5", metaClient);
+    Optional<String> emptyTargetIdentifier =
+        targetClient.getTargetCommitIdentifier("5", metaClient);
     assertFalse(emptyTargetIdentifier.isPresent());
 
     // the first commit to the timeline should be archived