rebase from dev

apache · Apr 9, 2024 · 979c175 · 979c175
1 parent 0d85176
commit 979c175
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 3 deletions.
diff --git a/...n/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/TextReadStrategy.java b/...n/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/TextReadStrategy.java
@@ -145,7 +145,9 @@ public SeaTunnelRowType getSeaTunnelRowTypeInfo(String path) {
                             + "SeaTunnel will not support column projection");
         }
         TextDeserializationSchema.Builder builder =
-                TextDeserializationSchema.builder().delimiter(TextFormatConstant.PLACEHOLDER).textLineSplitor(textLineSplitor);
+                TextDeserializationSchema.builder()
+                        .delimiter(TextFormatConstant.PLACEHOLDER)
+                        .textLineSplitor(textLineSplitor);
         if (isMergePartition) {
             deserializationSchema =
                     builder.seaTunnelRowType(this.seaTunnelRowTypeWithPartition).build();
@@ -180,7 +182,9 @@ public void setSeaTunnelRowTypeInfo(SeaTunnelRowType seaTunnelRowType) {
         }
         initFormatter();
         TextDeserializationSchema.Builder builder =
-                TextDeserializationSchema.builder().delimiter(fieldDelimiter).textLineSplitor(textLineSplitor);
+                TextDeserializationSchema.builder()
+                        .delimiter(fieldDelimiter)
+                        .textLineSplitor(textLineSplitor);
         if (isMergePartition) {
             deserializationSchema =
                     builder.seaTunnelRowType(userDefinedRowTypeWithPartition).build();

diff --git a/...format-text/src/main/java/org/apache/seatunnel/format/text/TextDeserializationSchema.java b/...format-text/src/main/java/org/apache/seatunnel/format/text/TextDeserializationSchema.java
@@ -137,7 +137,8 @@ public Builder textLineSplitor(TextLineSplitor splitor) {
         }
 
         public TextDeserializationSchema build() {
-            return new TextDeserializationSchema(seaTunnelRowType, separators, encoding, textLineSplitor);
+            return new TextDeserializationSchema(
+                    seaTunnelRowType, separators, encoding, textLineSplitor);
         }
     }