fix checkstyle

vernedeng · Dec 19, 2024 · 9670a30 · 9670a30
1 parent e78f0af
commit 9670a30
Show file tree

Hide file tree

Showing 4 changed files with 15 additions and 10 deletions.
diff --git a/...transform-sdk/src/main/java/org/apache/inlong/sdk/transform/decode/RowDataSourceData.java b/...transform-sdk/src/main/java/org/apache/inlong/sdk/transform/decode/RowDataSourceData.java
@@ -14,17 +14,19 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
- 
+
 package org.apache.inlong.sdk.transform.decode;
 
+import org.apache.inlong.sort.formats.base.RowDataToFieldConverters;
+
 import lombok.extern.slf4j.Slf4j;
 import org.apache.flink.table.data.RowData;
-import org.apache.inlong.sort.formats.base.RowDataToFieldConverters;
 
 import java.util.Map;
 
 @Slf4j
 public class RowDataSourceData implements SourceData {
+
     private final RowData rowData;
     private final Map<String, Integer> fieldPositionMap;
     private final RowDataToFieldConverters.RowFieldConverter[] converters;

diff --git a/...nsform-sdk/src/main/java/org/apache/inlong/sdk/transform/decode/RowDataSourceDecoder.java b/...nsform-sdk/src/main/java/org/apache/inlong/sdk/transform/decode/RowDataSourceDecoder.java
@@ -17,13 +17,14 @@
 
 package org.apache.inlong.sdk.transform.decode;
 
-import org.apache.flink.table.data.RowData;
 import org.apache.inlong.sdk.transform.pojo.FieldInfo;
 import org.apache.inlong.sdk.transform.pojo.RowDataSourceInfo;
 import org.apache.inlong.sdk.transform.process.Context;
 import org.apache.inlong.sort.formats.base.RowDataToFieldConverters;
 import org.apache.inlong.sort.formats.base.TableFormatForRowDataUtils;
 
+import org.apache.flink.table.data.RowData;
+
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -47,7 +48,7 @@ public RowDataSourceDecoder(RowDataSourceInfo sourceInfo) {
 
     private Map<String, Integer> parseFieldPositionMap(List<FieldInfo> fields) {
         Map<String, Integer> map = new HashMap<>();
-        for (int i =0; i < fields.size(); i++) {
+        for (int i = 0; i < fields.size(); i++) {
             map.put(fields.get(i).getName(), i);
         }
         return map;

diff --git a/...ransform-sdk/src/main/java/org/apache/inlong/sdk/transform/encode/RowDataSinkEncoder.java b/...ransform-sdk/src/main/java/org/apache/inlong/sdk/transform/encode/RowDataSinkEncoder.java
@@ -17,14 +17,15 @@
 
 package org.apache.inlong.sdk.transform.encode;
 
-import org.apache.flink.table.data.GenericRowData;
-import org.apache.flink.table.data.RowData;
 import org.apache.inlong.sdk.transform.pojo.FieldInfo;
 import org.apache.inlong.sdk.transform.pojo.RowDataSinkInfo;
 import org.apache.inlong.sdk.transform.process.Context;
 import org.apache.inlong.sort.formats.base.FieldToRowDataConverters;
 import org.apache.inlong.sort.formats.base.TableFormatUtils;
 
+import org.apache.flink.table.data.GenericRowData;
+import org.apache.flink.table.data.RowData;
+
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -47,7 +48,7 @@ public RowDataSinkEncoder(RowDataSinkInfo sinkInfo) {
 
     private Map<String, Integer> parseFieldPositionMap(List<FieldInfo> fields) {
         Map<String, Integer> map = new HashMap<>();
-        for (int i =0; i < fields.size(); i++) {
+        for (int i = 0; i < fields.size(); i++) {
             map.put(fields.get(i).getName(), i);
         }
         return map;

diff --git a/.../java/org/apache/inlong/sdk/transform/process/processor/TestRowData2RowDataProcessor.java b/.../java/org/apache/inlong/sdk/transform/process/processor/TestRowData2RowDataProcessor.java
@@ -17,16 +17,17 @@
 
 package org.apache.inlong.sdk.transform.process.processor;
 
-import org.apache.flink.table.data.GenericRowData;
-import org.apache.flink.table.data.RowData;
-import org.apache.flink.table.data.StringData;
 import org.apache.inlong.sdk.transform.decode.SourceDecoderFactory;
 import org.apache.inlong.sdk.transform.encode.SinkEncoderFactory;
 import org.apache.inlong.sdk.transform.pojo.FieldInfo;
 import org.apache.inlong.sdk.transform.pojo.RowDataSinkInfo;
 import org.apache.inlong.sdk.transform.pojo.RowDataSourceInfo;
 import org.apache.inlong.sdk.transform.pojo.TransformConfig;
 import org.apache.inlong.sdk.transform.process.TransformProcessor;
+
+import org.apache.flink.table.data.GenericRowData;
+import org.apache.flink.table.data.RowData;
+import org.apache.flink.table.data.StringData;
 import org.junit.Assert;
 import org.junit.Test;