(flink-connector-kudu) 35/44: [BAHIR-308] Remove scala prefix where we can

[martijnvisser]

This is an automated email from the ASF dual-hosted git repository.

martijnvisser pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-kudu.git

commit 78c76c544ab426461e9e4156ebb9ddf561b7b97c
Author: Joao Boto <b...@boto.pro>
AuthorDate: Thu Mar 23 13:30:24 2023 +0100

    [BAHIR-308] Remove scala prefix where we can
---
 flink-connector-kudu/pom.xml                               | 14 +++++++++++---
 .../kudu/table/dynamic/KuduDynamicTableSource.java         |  3 +--
 2 files changed, 12 insertions(+), 5 deletions(-)

diff --git a/flink-connector-kudu/pom.xml b/flink-connector-kudu/pom.xml
index 134d6f7..8dc4f88 100644
--- a/flink-connector-kudu/pom.xml
+++ b/flink-connector-kudu/pom.xml
@@ -20,12 +20,12 @@
 
   <parent>
     <groupId>org.apache.bahir</groupId>
-    <artifactId>bahir-flink-parent_2.12</artifactId>
+    <artifactId>bahir-flink-parent</artifactId>
     <version>1.2-SNAPSHOT</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 
-  <artifactId>flink-connector-kudu_2.12</artifactId>
+  <artifactId>flink-connector-kudu</artifactId>
   <packaging>jar</packaging>
 
   <name>flink-connector-kudu</name>
@@ -84,13 +84,21 @@
       <groupId>org.apache.flink</groupId>
       <artifactId>flink-streaming-java</artifactId>
     </dependency>
+    <dependency>
+      <groupId>org.apache.flink</groupId>
+      <artifactId>flink-table-api-java-bridge</artifactId>
+    </dependency>
     <dependency>
       <groupId>org.apache.flink</groupId>
       <artifactId>flink-table-common</artifactId>
     </dependency>
     <dependency>
       <groupId>org.apache.flink</groupId>
-      <artifactId>flink-table-planner_${scala.binary.version}</artifactId>
+      <artifactId>flink-table-planner-loader</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>org.apache.flink</groupId>
+      <artifactId>flink-table-runtime</artifactId>
     </dependency>
     <dependency>
       <groupId>org.apache.kudu</groupId>
diff --git 
a/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicTableSource.java
 
b/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicTableSource.java
index cde6a13..da6bebb 100644
--- 
a/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicTableSource.java
+++ 
b/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicTableSource.java
@@ -43,7 +43,6 @@ import org.slf4j.LoggerFactory;
 
 import java.util.*;
 
-import static 
org.apache.flink.calcite.shaded.com.google.common.base.Preconditions.checkArgument;
 import static 
org.apache.flink.table.utils.TableSchemaUtils.containsPhysicalColumnsOnly;
 
 /**
@@ -143,7 +142,7 @@ public class KuduDynamicTableSource implements 
ScanTableSource, SupportsProjecti
     }
 
     private TableSchema projectSchema(TableSchema tableSchema, int[][] 
projectedFields) {
-        checkArgument(
+        Preconditions.checkArgument(
                 containsPhysicalColumnsOnly(tableSchema),
                 "Projection is only supported for physical columns.");
         TableSchema.Builder builder = TableSchema.builder();