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 <[email protected]> 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 +}
