abdullah alamoudi has submitted this change and it was merged. Change subject: Enable Remove Quietly for Remove Directory Jobs ......................................................................
Enable Remove Quietly for Remove Directory Jobs Change-Id: I00a60bf4ac6d64295224c2cebc28fb22f92e77fd Reviewed-on: https://asterix-gerrit.ics.uci.edu/775 Tested-by: Jenkins <[email protected]> Reviewed-by: Murtadha Hubail <[email protected]> --- M hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/file/FileRemoveOperatorDescriptor.java 1 file changed, 12 insertions(+), 5 deletions(-) Approvals: Murtadha Hubail: Looks good to me, approved Jenkins: Verified diff --git a/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/file/FileRemoveOperatorDescriptor.java b/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/file/FileRemoveOperatorDescriptor.java index cf2008c..43b1b34 100644 --- a/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/file/FileRemoveOperatorDescriptor.java +++ b/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/file/FileRemoveOperatorDescriptor.java @@ -37,10 +37,13 @@ public class FileRemoveOperatorDescriptor extends AbstractSingleActivityOperatorDescriptor { private final IFileSplitProvider fileSplitProvider; + private final boolean quietly; - public FileRemoveOperatorDescriptor(IOperatorDescriptorRegistry spec, IFileSplitProvider fileSplitProvder) { + public FileRemoveOperatorDescriptor(IOperatorDescriptorRegistry spec, IFileSplitProvider fileSplitProvder, + boolean quietly) { super(spec, 0, 0); this.fileSplitProvider = fileSplitProvder; + this.quietly = quietly; } private static final long serialVersionUID = 1L; @@ -62,10 +65,14 @@ @Override public void initialize() throws HyracksDataException { File f = ioManager.getAbsoluteFileRef(deviceId, path).getFile(); - try { - FileUtils.deleteDirectory(f); - } catch (IOException e) { - throw new HyracksDataException(e); + if (quietly) { + FileUtils.deleteQuietly(f); + } else { + try { + FileUtils.deleteDirectory(f); + } catch (IOException e) { + throw new HyracksDataException(e); + } } } -- To view, visit https://asterix-gerrit.ics.uci.edu/775 To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings Gerrit-MessageType: merged Gerrit-Change-Id: I00a60bf4ac6d64295224c2cebc28fb22f92e77fd Gerrit-PatchSet: 4 Gerrit-Project: hyracks Gerrit-Branch: master Gerrit-Owner: abdullah alamoudi <[email protected]> Gerrit-Reviewer: Jenkins <[email protected]> Gerrit-Reviewer: Murtadha Hubail <[email protected]> Gerrit-Reviewer: abdullah alamoudi <[email protected]>
