demo

recommend-model-produce/src/main/java/com/tzld/piaoquan/recommend/model/produce/i2i/I2IMilvusDataImport.java

@@ -4,12 +4,9 @@ import com.alibaba.fastjson.JSONObject;
 import io.milvus.client.*;
 import io.milvus.grpc.MutationResult;
 import io.milvus.param.*;
-import io.milvus.param.dml.InsertParam;
 import io.milvus.param.dml.UpsertParam;
 
 import com.tzld.piaoquan.recommend.model.produce.service.CMDService;
-import com.tzld.piaoquan.recommend.model.produce.service.HDFSService;
-import com.tzld.piaoquan.recommend.model.produce.service.OSSService;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang.math.NumberUtils;
 import org.apache.commons.lang3.StringUtils;
@@ -18,15 +15,10 @@ import org.apache.spark.api.java.JavaSparkContext;
 import org.apache.spark.sql.SparkSession;
 
 import java.io.IOException;
-import java.net.InetAddress;
-import java.net.InetSocketAddress;
-import java.net.Socket;
-import java.net.UnknownHostException;
 import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
-import java.util.concurrent.TimeUnit;
 
 /**
  * @author dyp