You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@bahir.apache.org by es...@apache.org on 2022/07/17 12:29:30 UTC
[bahir-flink] 09/16: fix: reformat code style
This is an automated email from the ASF dual-hosted git repository.
eskabetxe pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/bahir-flink.git
commit 959df22dd8780238183da1d15bc0ab31ec1add34
Author: min <40...@users.noreply.github.com>
AuthorDate: Thu May 19 19:39:21 2022 +0800
fix: reformat code style
---
.../flink/connectors/kudu/connector/convertor/RowResultConvertor.java | 2 +-
.../connectors/kudu/connector/convertor/RowResultRowConvertor.java | 2 +-
.../org/apache/flink/connectors/kudu/format/KuduRowInputFormat.java | 2 +-
.../kudu/table/dynamic/KuduDynamicTableSourceSinkFactory.java | 2 +-
.../kudu/table/function/lookup/AbstractKuduLookupFunction.java | 2 +-
.../flink/connectors/kudu/table/function/lookup/KuduLookupOptions.java | 2 +-
.../kudu/table/function/lookup/KuduRowDataLookupFunction.java | 2 +-
.../flink/connectors/kudu/writer/RowDataUpsertOperationMapperTest.java | 2 +-
8 files changed, 8 insertions(+), 8 deletions(-)
diff --git a/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/convertor/RowResultConvertor.java b/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/convertor/RowResultConvertor.java
index ee71b3c..2cbb97e 100644
--- a/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/convertor/RowResultConvertor.java
+++ b/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/convertor/RowResultConvertor.java
@@ -36,4 +36,4 @@ public interface RowResultConvertor<T> extends Serializable {
* @return {@link T}
*/
T convertor(RowResult row);
-}
\ No newline at end of file
+}
diff --git a/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/convertor/RowResultRowConvertor.java b/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/convertor/RowResultRowConvertor.java
index be9b448..b6f4eee 100644
--- a/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/convertor/RowResultRowConvertor.java
+++ b/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/convertor/RowResultRowConvertor.java
@@ -41,4 +41,4 @@ public class RowResultRowConvertor implements RowResultConvertor<Row> {
});
return values;
}
-}
\ No newline at end of file
+}
diff --git a/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/format/KuduRowInputFormat.java b/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/format/KuduRowInputFormat.java
index f7e5bf9..935de8f 100644
--- a/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/format/KuduRowInputFormat.java
+++ b/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/format/KuduRowInputFormat.java
@@ -52,4 +52,4 @@ public class KuduRowInputFormat extends AbstractKuduInputFormat<Row> {
public TypeInformation<Row> getProducedType() {
return TypeInformation.of(Row.class);
}
-}
\ No newline at end of file
+}
diff --git a/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicTableSourceSinkFactory.java b/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicTableSourceSinkFactory.java
index 973a81e..3a24372 100644
--- a/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicTableSourceSinkFactory.java
+++ b/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicTableSourceSinkFactory.java
@@ -240,4 +240,4 @@ public class KuduDynamicTableSourceSinkFactory implements DynamicTableSourceFact
//lookup
KUDU_LOOKUP_CACHE_MAX_ROWS, KUDU_LOOKUP_CACHE_TTL, KUDU_LOOKUP_MAX_RETRIES);
}
-}
\ No newline at end of file
+}
diff --git a/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/function/lookup/AbstractKuduLookupFunction.java b/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/function/lookup/AbstractKuduLookupFunction.java
index 5cb83d0..ccb9687 100644
--- a/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/function/lookup/AbstractKuduLookupFunction.java
+++ b/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/function/lookup/AbstractKuduLookupFunction.java
@@ -204,4 +204,4 @@ public abstract class AbstractKuduLookupFunction<IN> extends TableFunction<IN> {
}
}
}
-}
\ No newline at end of file
+}
diff --git a/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/function/lookup/KuduLookupOptions.java b/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/function/lookup/KuduLookupOptions.java
index 5ff3734..9a2f23f 100644
--- a/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/function/lookup/KuduLookupOptions.java
+++ b/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/function/lookup/KuduLookupOptions.java
@@ -78,4 +78,4 @@ public class KuduLookupOptions {
return new KuduLookupOptions(cacheMaxSize, cacheExpireMs, maxRetryTimes);
}
}
-}
\ No newline at end of file
+}
diff --git a/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/function/lookup/KuduRowDataLookupFunction.java b/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/function/lookup/KuduRowDataLookupFunction.java
index 0f400aa..a1bf7d7 100644
--- a/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/function/lookup/KuduRowDataLookupFunction.java
+++ b/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/function/lookup/KuduRowDataLookupFunction.java
@@ -79,4 +79,4 @@ public class KuduRowDataLookupFunction extends AbstractKuduLookupFunction<RowDat
return new KuduRowDataLookupFunction(keyNames, tableInfo, kuduReaderConfig, projectedFields, kuduLookupOptions);
}
}
-}
\ No newline at end of file
+}
diff --git a/flink-connector-kudu/src/test/java/org/apache/flink/connectors/kudu/writer/RowDataUpsertOperationMapperTest.java b/flink-connector-kudu/src/test/java/org/apache/flink/connectors/kudu/writer/RowDataUpsertOperationMapperTest.java
index dec125d..3cda636 100644
--- a/flink-connector-kudu/src/test/java/org/apache/flink/connectors/kudu/writer/RowDataUpsertOperationMapperTest.java
+++ b/flink-connector-kudu/src/test/java/org/apache/flink/connectors/kudu/writer/RowDataUpsertOperationMapperTest.java
@@ -54,4 +54,4 @@ public class RowDataUpsertOperationMapperTest extends AbstractOperationTest {
assertEquals(1, operations.size());
verify(mockTable).newUpsert();
}
-}
\ No newline at end of file
+}