dssm train

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

@@ -57,7 +57,7 @@ public class I2IDSSMPredict {
 //            String gzPath = "/root/recommend-model/model.tar.gz";
 //            ossService.download(bucketName, gzPath, objectName);
             String modelDir = "/root/recommend-model";
-            hdfsService.copyFromLocalFile(gzPath2, "/dyp/dssm");
+            hdfsService.copyToLocalFile("/dyp/dssm/model.tar.gz", gzPath2);
             CompressUtil.decompressGzFile(gzPath2, modelDir);
 
             String modelFile = modelDir + "/dssm.pdmodel";

recommend-model-produce/src/main/java/com/tzld/piaoquan/recommend/model/produce/service/HDFSService.java

@@ -46,4 +46,10 @@ public class HDFSService implements Serializable {
         return false;
     }
 
+    public boolean copyToLocalFile(String hdfs, String local) throws IOException {
+        Path localP = new Path(local);
+        Path hdfsP = new Path(hdfs);
+        fSystem.copyToLocalFile(hdfs, local);
+        return false;
+    }
 }