implements serializable

client/src/main/generated/com/vesoft/nebula/graph/GraphService.java

@@ -6,6 +6,7 @@
  */
 package com.vesoft.nebula.graph;
 
+import java.io.Serializable;
 import java.util.List;
 import java.util.ArrayList;
 import java.util.Map;
@@ -65,7 +66,7 @@ public interface AsyncIface {
 
   }
 
-  public static class Client extends EventHandlerBase implements Iface, TClientIf {
+  public static class Client extends EventHandlerBase implements Iface, TClientIf, Serializable {
     public Client(TProtocol prot)
     {
       this(prot, prot);

client/src/main/java/com/vesoft/nebula/client/meta/AbstractMetaClient.java

@@ -11,11 +11,12 @@
 import com.google.common.net.InetAddresses;
 import com.google.common.net.InternetDomainName;
 import com.vesoft.nebula.client.graph.data.HostAddress;
+import java.io.Serializable;
 import java.net.InetAddress;
 import java.net.UnknownHostException;
 import java.util.List;
 
-public class AbstractMetaClient {
+public class AbstractMetaClient implements Serializable {
     protected final List<HostAddress> addresses;
     protected final int connectionRetry;
     protected final int executionRetry;

client/src/main/java/com/vesoft/nebula/client/meta/MetaClient.java

@@ -48,6 +48,7 @@
 import com.vesoft.nebula.meta.VerifyClientVersionResp;
 import com.vesoft.nebula.util.SslUtil;
 import java.io.IOException;
+import java.io.Serializable;
 import java.net.UnknownHostException;
 import java.util.Arrays;
 import java.util.HashSet;

client/src/main/java/com/vesoft/nebula/client/meta/MetaManager.java

@@ -16,6 +16,7 @@
 import com.vesoft.nebula.meta.IdName;
 import com.vesoft.nebula.meta.SpaceItem;
 import com.vesoft.nebula.meta.TagItem;
+import java.io.Serializable;
 import java.net.UnknownHostException;
 import java.util.ArrayList;
 import java.util.HashMap;
@@ -30,7 +31,7 @@
 /**
  * MetaManager is a manager for meta info, such as spaces,tags and edges.
  */
-public class MetaManager implements MetaCache {
+public class MetaManager implements MetaCache, Serializable {
     private class SpaceInfo {
         private SpaceItem spaceItem = null;
         private Map<String, TagItem> tagItems = new HashMap<>();

client/src/main/java/com/vesoft/nebula/client/storage/StorageClient.java

@@ -18,6 +18,7 @@
 import com.vesoft.nebula.storage.ScanEdgeRequest;
 import com.vesoft.nebula.storage.ScanVertexRequest;
 import com.vesoft.nebula.storage.VertexProp;
+import java.io.Serializable;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.HashSet;
@@ -26,7 +27,7 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-public class StorageClient {
+public class StorageClient implements Serializable {
     private static final Logger LOGGER = LoggerFactory.getLogger(StorageClient.class);
 
     private final GraphStorageConnection connection;

client/src/main/java/com/vesoft/nebula/client/storage/StorageConnPoolFactory.java

@@ -6,6 +6,7 @@
 package com.vesoft.nebula.client.storage;
 
 import com.vesoft.nebula.client.graph.data.HostAddress;
+import java.io.Serializable;
 import org.apache.commons.pool2.KeyedPooledObjectFactory;
 import org.apache.commons.pool2.PooledObject;
 import org.apache.commons.pool2.impl.DefaultPooledObject;
@@ -14,7 +15,7 @@
 
 @SuppressWarnings("checkstyle:Indentation")
 public class StorageConnPoolFactory
-        implements KeyedPooledObjectFactory<HostAddress, GraphStorageConnection> {
+        implements KeyedPooledObjectFactory<HostAddress, GraphStorageConnection>, Serializable {
     private static final Logger LOGGER = LoggerFactory.getLogger(StorageConnPoolFactory.class);
 
     private final StoragePoolConfig config;

client/src/main/java/com/vesoft/nebula/client/storage/data/BaseTableRow.java

@@ -11,10 +11,11 @@
 import com.vesoft.nebula.client.graph.data.GeographyWrapper;
 import com.vesoft.nebula.client.graph.data.TimeWrapper;
 import com.vesoft.nebula.client.graph.data.ValueWrapper;
+import java.io.Serializable;
 import java.io.UnsupportedEncodingException;
 import java.util.List;
 
-public class BaseTableRow {
+public class BaseTableRow implements Serializable {
     protected final List<ValueWrapper> values;
     protected String decodeType = "utf-8";
 

client/src/main/java/com/vesoft/nebula/client/storage/data/EdgeRow.java

@@ -6,9 +6,10 @@
 package com.vesoft.nebula.client.storage.data;
 
 import com.vesoft.nebula.client.graph.data.ValueWrapper;
+import java.io.Serializable;
 import java.util.Map;
 
-public class EdgeRow {
+public class EdgeRow implements Serializable {
     private final ValueWrapper srcId;
     private final ValueWrapper dstId;
     private final long rank;

client/src/main/java/com/vesoft/nebula/client/storage/data/VertexRow.java

@@ -6,9 +6,10 @@
 package com.vesoft.nebula.client.storage.data;
 
 import com.vesoft.nebula.client.graph.data.ValueWrapper;
+import java.io.Serializable;
 import java.util.Map;
 
-public class VertexRow {
+public class VertexRow implements Serializable {
     private final ValueWrapper vid;
     private final Map<String, ValueWrapper> props;
 

client/src/main/java/com/vesoft/nebula/client/storage/scan/ScanResultIterator.java

@@ -13,6 +13,7 @@
 import com.vesoft.nebula.client.storage.StorageConnPool;
 import com.vesoft.nebula.storage.PartitionResult;
 import com.vesoft.nebula.storage.ScanResponse;
+import java.io.Serializable;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -22,7 +23,7 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-public class ScanResultIterator {
+public class ScanResultIterator implements Serializable {
     private static final Logger LOGGER = LoggerFactory.getLogger(ScanResultIterator.class);
 
     protected boolean hasNext = true;