update PropertyType class (#40)

vesoft-inc · Dec 14, 2021 · fe8d5b6 · fe8d5b6
1 parent 3c4a5a8
commit fe8d5b6
Show file tree

Hide file tree

Showing 9 changed files with 9 additions and 11 deletions.
diff --git a/connector/src/main/java/org.apache.flink/connector/nebula/catalog/NebulaCatalog.java b/connector/src/main/java/org.apache.flink/connector/nebula/catalog/NebulaCatalog.java
@@ -14,14 +14,14 @@
 import static org.apache.flink.table.factories.FactoryUtil.CONNECTOR;
 
 import com.facebook.thrift.TException;
+import com.vesoft.nebula.PropertyType;
 import com.vesoft.nebula.client.graph.data.HostAddress;
 import com.vesoft.nebula.client.graph.exception.ClientServerIncompatibleException;
 import com.vesoft.nebula.client.meta.MetaClient;
 import com.vesoft.nebula.client.meta.exception.ExecuteFailedException;
 import com.vesoft.nebula.meta.ColumnDef;
 import com.vesoft.nebula.meta.EdgeItem;
 import com.vesoft.nebula.meta.IdName;
-import com.vesoft.nebula.meta.PropertyType;
 import com.vesoft.nebula.meta.Schema;
 import com.vesoft.nebula.meta.TagItem;
 import java.util.ArrayList;

diff --git a/.../main/java/org.apache.flink/connector/nebula/connection/NebulaMetaConnectionProvider.java b/.../main/java/org.apache.flink/connector/nebula/connection/NebulaMetaConnectionProvider.java
@@ -6,6 +6,7 @@
 package org.apache.flink.connector.nebula.connection;
 
 import com.facebook.thrift.TException;
+import com.vesoft.nebula.PropertyType;
 import com.vesoft.nebula.client.graph.data.CASignedSSLParam;
 import com.vesoft.nebula.client.graph.data.HostAddress;
 import com.vesoft.nebula.client.graph.data.SSLParam;
@@ -14,7 +15,6 @@
 import com.vesoft.nebula.client.meta.MetaClient;
 import com.vesoft.nebula.client.meta.exception.ExecuteFailedException;
 import com.vesoft.nebula.meta.ColumnDef;
-import com.vesoft.nebula.meta.PropertyType;
 import com.vesoft.nebula.meta.Schema;
 import com.vesoft.nebula.meta.SpaceItem;
 import java.io.Serializable;

diff --git a/connector/src/main/java/org.apache.flink/connector/nebula/utils/NebulaUtils.java b/connector/src/main/java/org.apache.flink/connector/nebula/utils/NebulaUtils.java
@@ -5,8 +5,8 @@
 
 package org.apache.flink.connector.nebula.utils;
 
+import com.vesoft.nebula.PropertyType;
 import com.vesoft.nebula.client.graph.data.HostAddress;
-import com.vesoft.nebula.meta.PropertyType;
 import java.util.ArrayList;
 import java.util.List;
 

diff --git a/...tor/src/test/java/org/apache/flink/connector/nebula/sink/NebulaEdgeBatchExecutorTest.java b/...tor/src/test/java/org/apache/flink/connector/nebula/sink/NebulaEdgeBatchExecutorTest.java
@@ -5,13 +5,13 @@
 
 package org.apache.flink.connector.nebula.sink;
 
+import com.vesoft.nebula.PropertyType;
 import com.vesoft.nebula.client.graph.NebulaPoolConfig;
 import com.vesoft.nebula.client.graph.data.HostAddress;
 import com.vesoft.nebula.client.graph.data.ResultSet;
 import com.vesoft.nebula.client.graph.exception.IOErrorException;
 import com.vesoft.nebula.client.graph.net.NebulaPool;
 import com.vesoft.nebula.client.graph.net.Session;
-import com.vesoft.nebula.meta.PropertyType;
 import java.util.Arrays;
 import java.util.HashMap;
 import java.util.Map;

diff --git a/...src/test/java/org/apache/flink/connector/nebula/sink/NebulaOutputFormatConverterTest.java b/...src/test/java/org/apache/flink/connector/nebula/sink/NebulaOutputFormatConverterTest.java
@@ -5,12 +5,10 @@
 
 package org.apache.flink.connector.nebula.sink;
 
-import com.vesoft.nebula.meta.PropertyType;
+import com.vesoft.nebula.PropertyType;
 import java.util.Arrays;
 import java.util.HashMap;
 import java.util.Map;
-import org.apache.flink.connector.nebula.sink.NebulaRowEdgeOutputFormatConverter;
-import org.apache.flink.connector.nebula.sink.NebulaRowVertexOutputFormatConverter;
 import org.apache.flink.connector.nebula.statement.EdgeExecutionOptions;
 import org.apache.flink.connector.nebula.statement.ExecutionOptions;
 import org.apache.flink.connector.nebula.statement.VertexExecutionOptions;

diff --git a/...t/java/org/apache/flink/connector/nebula/sink/NebulaRowEdgeOutputFormatConverterTest.java b/...t/java/org/apache/flink/connector/nebula/sink/NebulaRowEdgeOutputFormatConverterTest.java
@@ -1,6 +1,6 @@
 package org.apache.flink.connector.nebula.sink;
 
-import com.vesoft.nebula.meta.PropertyType;
+import com.vesoft.nebula.PropertyType;
 import java.util.Arrays;
 import java.util.HashMap;
 import java.util.Map;

diff --git a/...java/org/apache/flink/connector/nebula/sink/NebulaRowVertexOutputFormatConverterTest.java b/...java/org/apache/flink/connector/nebula/sink/NebulaRowVertexOutputFormatConverterTest.java
@@ -1,6 +1,6 @@
 package org.apache.flink.connector.nebula.sink;
 
-import com.vesoft.nebula.meta.PropertyType;
+import com.vesoft.nebula.PropertyType;
 import java.util.Arrays;
 import java.util.HashMap;
 import java.util.Map;

diff --git a/...r/src/test/java/org/apache/flink/connector/nebula/sink/NebulaVertexBatchExecutorTest.java b/...r/src/test/java/org/apache/flink/connector/nebula/sink/NebulaVertexBatchExecutorTest.java
@@ -5,13 +5,13 @@
 
 package org.apache.flink.connector.nebula.sink;
 
+import com.vesoft.nebula.PropertyType;
 import com.vesoft.nebula.client.graph.NebulaPoolConfig;
 import com.vesoft.nebula.client.graph.data.HostAddress;
 import com.vesoft.nebula.client.graph.data.ResultSet;
 import com.vesoft.nebula.client.graph.exception.IOErrorException;
 import com.vesoft.nebula.client.graph.net.NebulaPool;
 import com.vesoft.nebula.client.graph.net.Session;
-import com.vesoft.nebula.meta.PropertyType;
 import java.util.Arrays;
 import java.util.HashMap;
 import java.util.Map;

diff --git a/connector/src/test/java/org/apache/flink/connector/nebula/utils/NebulaUtilsTest.java b/connector/src/test/java/org/apache/flink/connector/nebula/utils/NebulaUtilsTest.java
@@ -1,6 +1,6 @@
 package org.apache.flink.connector.nebula.utils;
 
-import com.vesoft.nebula.meta.PropertyType;
+import com.vesoft.nebula.PropertyType;
 import junit.framework.TestCase;
 
 public class NebulaUtilsTest extends TestCase {