Merge pull request #372 from rpmoore/put_bulk_force

Put bulk force
SpectraLogic · Oct 21, 2016 · 375c18d · 375c18d
2 parents ad8d335 + 9cdaff9
commit 375c18d
Show file tree

Hide file tree

Showing 4 changed files with 15 additions and 4 deletions.
diff --git a/README.md b/README.md
@@ -41,7 +41,7 @@ The SDK can also be included directly into a Maven or Gradle build. There is als
       <dependency>
         <groupId>com.spectralogic.ds3</groupId>
         <artifactId>ds3-sdk</artifactId>
-        <version>3.2.6</version>
+        <version>3.2.7</version>
         <!-- <classifier>all</classifier> -->
       </dependency>
     ...
@@ -64,8 +64,8 @@ repositories {
 
 dependencies {
     ...
-    compile 'com.spectralogic.ds3:ds3-sdk:3.2.6'
-    // compile 'com.spectralogic.ds3:ds3-sdk:3.2.6:all'
+    compile 'com.spectralogic.ds3:ds3-sdk:3.2.7'
+    // compile 'com.spectralogic.ds3:ds3-sdk:3.2.7:all'
     ...
 }
 

diff --git a/build.gradle b/build.gradle
@@ -15,7 +15,7 @@
 
 allprojects {
     group = 'com.spectralogic.ds3'
-    version = '3.2.6'
+    version = '3.2.7'
 }
 
 subprojects {

diff --git a/ds3-sdk/src/main/java/com/spectralogic/ds3client/helpers/Ds3ClientHelpersImpl.java b/ds3-sdk/src/main/java/com/spectralogic/ds3client/helpers/Ds3ClientHelpersImpl.java
@@ -111,6 +111,7 @@ private Ds3ClientHelpers.Job innerStartWriteJob(final String bucket,
         final PutBulkJobSpectraS3Request request = new PutBulkJobSpectraS3Request(bucket, Lists.newArrayList(objectsToWrite))
                 .withPriority(options.getPriority())
                 .withAggregating(options.isAggregating())
+                .withForce(options.isForce())
                 .withIgnoreNamingConflicts(options.doIgnoreNamingConflicts());
 
         if (options.getMaxUploadSize() > 0) {

diff --git a/ds3-sdk/src/main/java/com/spectralogic/ds3client/helpers/options/WriteJobOptions.java b/ds3-sdk/src/main/java/com/spectralogic/ds3client/helpers/options/WriteJobOptions.java
@@ -26,6 +26,7 @@ public class WriteJobOptions {
     private ChecksumType.Type checksumType;
     private boolean aggregating;
     private boolean ignoreNamingConflicts;
+    private boolean force;
 
     private WriteJobOptions() {
         this.priority = null;
@@ -34,6 +35,7 @@ private WriteJobOptions() {
         this.checksumType = ChecksumType.Type.NONE;
         this.aggregating = false;
         this.ignoreNamingConflicts = false;
+        this.force = false;
     }
 
     public static WriteJobOptions create() {
@@ -113,4 +115,12 @@ public WriteJobOptions withIgnoreNamingConflicts(final boolean ignore) {
         this.ignoreNamingConflicts = ignore;
         return this;
     }
+
+    public boolean isForce() {
+        return force;
+    }
+
+    public void setForce(final boolean force) {
+        this.force = force;
+    }
 }