From 642e8b1a66af995b8b29a78e01f577ed65647e7f Mon Sep 17 00:00:00 2001 From: "wenjie.wang01" Date: Mon, 12 Aug 2024 19:21:23 +0800 Subject: [PATCH] fix code style. --- .../connectors/seatunnel/hbase/config/HbaseParameters.java | 2 +- .../seatunnel/connectors/seatunnel/hbase/sink/HbaseSink.java | 2 +- .../connectors/seatunnel/hbase/sink/HbaseSinkFactory.java | 2 +- .../connectors/seatunnel/hbase/sink/HbaseSinkWriter.java | 2 +- .../java/org/apache/seatunnel/e2e/connector/hbase/HbaseIT.java | 2 +- 5 files changed, 5 insertions(+), 5 deletions(-) diff --git a/seatunnel-connectors-v2/connector-hbase/src/main/java/org/apache/seatunnel/connectors/seatunnel/hbase/config/HbaseParameters.java b/seatunnel-connectors-v2/connector-hbase/src/main/java/org/apache/seatunnel/connectors/seatunnel/hbase/config/HbaseParameters.java index ffed2dd7bfb..4d020700ad6 100644 --- a/seatunnel-connectors-v2/connector-hbase/src/main/java/org/apache/seatunnel/connectors/seatunnel/hbase/config/HbaseParameters.java +++ b/seatunnel-connectors-v2/connector-hbase/src/main/java/org/apache/seatunnel/connectors/seatunnel/hbase/config/HbaseParameters.java @@ -125,4 +125,4 @@ public static HbaseParameters buildWithSourceConfig(Config pluginConfig) { } return builder.build(); } -} \ No newline at end of file +} diff --git a/seatunnel-connectors-v2/connector-hbase/src/main/java/org/apache/seatunnel/connectors/seatunnel/hbase/sink/HbaseSink.java b/seatunnel-connectors-v2/connector-hbase/src/main/java/org/apache/seatunnel/connectors/seatunnel/hbase/sink/HbaseSink.java index bdc44424751..22c992f208f 100644 --- a/seatunnel-connectors-v2/connector-hbase/src/main/java/org/apache/seatunnel/connectors/seatunnel/hbase/sink/HbaseSink.java +++ b/seatunnel-connectors-v2/connector-hbase/src/main/java/org/apache/seatunnel/connectors/seatunnel/hbase/sink/HbaseSink.java @@ -67,4 +67,4 @@ public AbstractSinkWriter createWriter(SinkWriter.Context co return new HbaseSinkWriter( seaTunnelRowType, hbaseParameters, rowkeyColumnIndexes, versionColumnIndex); } -} \ No newline at end of file +} diff --git a/seatunnel-connectors-v2/connector-hbase/src/main/java/org/apache/seatunnel/connectors/seatunnel/hbase/sink/HbaseSinkFactory.java b/seatunnel-connectors-v2/connector-hbase/src/main/java/org/apache/seatunnel/connectors/seatunnel/hbase/sink/HbaseSinkFactory.java index 18f8c165543..af9564fbe8d 100644 --- a/seatunnel-connectors-v2/connector-hbase/src/main/java/org/apache/seatunnel/connectors/seatunnel/hbase/sink/HbaseSinkFactory.java +++ b/seatunnel-connectors-v2/connector-hbase/src/main/java/org/apache/seatunnel/connectors/seatunnel/hbase/sink/HbaseSinkFactory.java @@ -115,4 +115,4 @@ private String replaceCatalogTableInPath(String originTableName, CatalogTable ca } return tableName; } -} \ No newline at end of file +} diff --git a/seatunnel-connectors-v2/connector-hbase/src/main/java/org/apache/seatunnel/connectors/seatunnel/hbase/sink/HbaseSinkWriter.java b/seatunnel-connectors-v2/connector-hbase/src/main/java/org/apache/seatunnel/connectors/seatunnel/hbase/sink/HbaseSinkWriter.java index 638c3570ad7..982908bfcad 100644 --- a/seatunnel-connectors-v2/connector-hbase/src/main/java/org/apache/seatunnel/connectors/seatunnel/hbase/sink/HbaseSinkWriter.java +++ b/seatunnel-connectors-v2/connector-hbase/src/main/java/org/apache/seatunnel/connectors/seatunnel/hbase/sink/HbaseSinkWriter.java @@ -200,4 +200,4 @@ private byte[] convertColumnToBytes(SeaTunnelRow row, int index) { CommonErrorCodeDeprecated.UNSUPPORTED_DATA_TYPE, errorMsg); } } -} \ No newline at end of file +} diff --git a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-hbase-e2e/src/test/java/org/apache/seatunnel/e2e/connector/hbase/HbaseIT.java b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-hbase-e2e/src/test/java/org/apache/seatunnel/e2e/connector/hbase/HbaseIT.java index 0b31b4a0185..cb6849eb516 100644 --- a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-hbase-e2e/src/test/java/org/apache/seatunnel/e2e/connector/hbase/HbaseIT.java +++ b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-hbase-e2e/src/test/java/org/apache/seatunnel/e2e/connector/hbase/HbaseIT.java @@ -197,4 +197,4 @@ public ArrayList readData(TableName table) throws IOException { scanner.close(); return results; } -} \ No newline at end of file +}