This commit is contained in:
parent
9aec98cea0
commit
60e2713d56
|
@ -9,9 +9,9 @@ import org.apache.hadoop.conf.Configuration;
|
||||||
import org.apache.hadoop.fs.*;
|
import org.apache.hadoop.fs.*;
|
||||||
|
|
||||||
import eu.dnetlib.dhp.application.ArgumentApplicationParser;
|
import eu.dnetlib.dhp.application.ArgumentApplicationParser;
|
||||||
import eu.dnetlib.dhp.common.api.MissingConceptDoiException;
|
|
||||||
import eu.dnetlib.dhp.common.api.ZenodoAPIClient;
|
|
||||||
import eu.dnetlib.dhp.oa.graph.dump.exceptions.NoAvailableEntityTypeException;
|
import eu.dnetlib.dhp.oa.graph.dump.exceptions.NoAvailableEntityTypeException;
|
||||||
|
import eu.dnetlib.dhp.oa.zenodoapi.MissingConceptDoiException;
|
||||||
|
import eu.dnetlib.dhp.oa.zenodoapi.ZenodoAPIClient;
|
||||||
|
|
||||||
public class SendToZenodoHDFS implements Serializable {
|
public class SendToZenodoHDFS implements Serializable {
|
||||||
|
|
||||||
|
@ -81,10 +81,8 @@ public class SendToZenodoHDFS implements Serializable {
|
||||||
String pString = p.toString();
|
String pString = p.toString();
|
||||||
if (!pString.endsWith("_SUCCESS")) {
|
if (!pString.endsWith("_SUCCESS")) {
|
||||||
String name = pString.substring(pString.lastIndexOf("/") + 1);
|
String name = pString.substring(pString.lastIndexOf("/") + 1);
|
||||||
|
FSDataInputStream inputStream = fileSystem.open(p);
|
||||||
try (FSDataInputStream inputStream = fileSystem.open(p)) {
|
zenodoApiClient.uploadIS3(inputStream, name, fileSystem.getFileStatus(p).getLen());
|
||||||
zenodoApiClient.uploadIS(inputStream, name);
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@ -92,9 +90,9 @@ public class SendToZenodoHDFS implements Serializable {
|
||||||
zenodoApiClient.sendMretadata(metadata);
|
zenodoApiClient.sendMretadata(metadata);
|
||||||
}
|
}
|
||||||
|
|
||||||
if (Boolean.TRUE.equals(publish)) {
|
// if (Boolean.TRUE.equals(publish)) {
|
||||||
zenodoApiClient.publish();
|
// zenodoApiClient.publish();
|
||||||
}
|
// }
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue