Support elastic Version type (#34)

getindata · Apr 23, 2024 · 04cfe37 · 04cfe37
1 parent 94b450f
commit 04cfe37
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/src/main/java/com/getindata/flink/connector/jdbc/catalog/ElasticTypeMapper.java b/src/main/java/com/getindata/flink/connector/jdbc/catalog/ElasticTypeMapper.java
@@ -42,6 +42,7 @@ public class ElasticTypeMapper implements JdbcDialectTypeMapper {
     private static final String ELASTIC_SCALED_FLOAT = "SCALED_FLOAT";
     private static final String ELASTIC_SHORT = "SHORT";
     private static final String ELASTIC_GEO_POINT = "GEO_POINT";
+    private static final String ELASTIC_VERSION = "VERSION";
 
     @Override
     public DataType mapping(ObjectPath tablePath, ResultSetMetaData metadata, int colIndex) throws SQLException {
@@ -53,6 +54,7 @@ public DataType mapping(ObjectPath tablePath, ResultSetMetaData metadata, int co
             case ELASTIC_KEYWORD:
             case ELASTIC_IP:
             case ELASTIC_GEO_POINT:
+            case ELASTIC_VERSION:
                 return DataTypes.STRING();
             case ELASTIC_BOOLEAN:
                 return DataTypes.BOOLEAN();

diff --git a/src/test/java/com/getindata/flink/connector/jdbc/catalog/ElasticJdbcCatalogFactoryTest.java b/src/test/java/com/getindata/flink/connector/jdbc/catalog/ElasticJdbcCatalogFactoryTest.java
@@ -5,7 +5,7 @@
 import org.apache.flink.table.catalog.exceptions.DatabaseNotExistException;
 import org.apache.flink.table.factories.CatalogFactory.Context;
 import org.apache.flink.table.factories.FactoryUtil;
-import org.junit.Test;
+import org.junit.jupiter.api.Test;
 
 import java.util.List;
 import java.util.Map;