From fe8d5b647200971b918109f47c00953c42e74868 Mon Sep 17 00:00:00 2001 From: Anqi Date: Tue, 14 Dec 2021 10:32:09 +0800 Subject: [PATCH] update PropertyType class (#40) --- .../connector/nebula/catalog/NebulaCatalog.java | 2 +- .../nebula/connection/NebulaMetaConnectionProvider.java | 2 +- .../org.apache.flink/connector/nebula/utils/NebulaUtils.java | 2 +- .../connector/nebula/sink/NebulaEdgeBatchExecutorTest.java | 2 +- .../nebula/sink/NebulaOutputFormatConverterTest.java | 4 +--- .../nebula/sink/NebulaRowEdgeOutputFormatConverterTest.java | 2 +- .../nebula/sink/NebulaRowVertexOutputFormatConverterTest.java | 2 +- .../connector/nebula/sink/NebulaVertexBatchExecutorTest.java | 2 +- .../apache/flink/connector/nebula/utils/NebulaUtilsTest.java | 2 +- 9 files changed, 9 insertions(+), 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 index ede5d27..3cfd15f 100644 --- 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,6 +14,7 @@ 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; @@ -21,7 +22,6 @@ 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/connector/src/main/java/org.apache.flink/connector/nebula/connection/NebulaMetaConnectionProvider.java b/connector/src/main/java/org.apache.flink/connector/nebula/connection/NebulaMetaConnectionProvider.java index 09e3c38..47d694f 100644 --- a/connector/src/main/java/org.apache.flink/connector/nebula/connection/NebulaMetaConnectionProvider.java +++ b/connector/src/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 index 346c96d..902afd2 100644 --- 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/connector/src/test/java/org/apache/flink/connector/nebula/sink/NebulaEdgeBatchExecutorTest.java b/connector/src/test/java/org/apache/flink/connector/nebula/sink/NebulaEdgeBatchExecutorTest.java index 6683c0e..9782ec9 100644 --- a/connector/src/test/java/org/apache/flink/connector/nebula/sink/NebulaEdgeBatchExecutorTest.java +++ b/connector/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/connector/src/test/java/org/apache/flink/connector/nebula/sink/NebulaOutputFormatConverterTest.java b/connector/src/test/java/org/apache/flink/connector/nebula/sink/NebulaOutputFormatConverterTest.java index c8f72bd..7bff693 100644 --- a/connector/src/test/java/org/apache/flink/connector/nebula/sink/NebulaOutputFormatConverterTest.java +++ b/connector/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/connector/src/test/java/org/apache/flink/connector/nebula/sink/NebulaRowEdgeOutputFormatConverterTest.java b/connector/src/test/java/org/apache/flink/connector/nebula/sink/NebulaRowEdgeOutputFormatConverterTest.java index c8a6a10..b840911 100644 --- a/connector/src/test/java/org/apache/flink/connector/nebula/sink/NebulaRowEdgeOutputFormatConverterTest.java +++ b/connector/src/test/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/connector/src/test/java/org/apache/flink/connector/nebula/sink/NebulaRowVertexOutputFormatConverterTest.java b/connector/src/test/java/org/apache/flink/connector/nebula/sink/NebulaRowVertexOutputFormatConverterTest.java index 0839bac..da356e5 100644 --- a/connector/src/test/java/org/apache/flink/connector/nebula/sink/NebulaRowVertexOutputFormatConverterTest.java +++ b/connector/src/test/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/connector/src/test/java/org/apache/flink/connector/nebula/sink/NebulaVertexBatchExecutorTest.java b/connector/src/test/java/org/apache/flink/connector/nebula/sink/NebulaVertexBatchExecutorTest.java index 9d26e7f..6583f8d 100644 --- a/connector/src/test/java/org/apache/flink/connector/nebula/sink/NebulaVertexBatchExecutorTest.java +++ b/connector/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 index 3b00547..ba22c87 100644 --- 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 {