public class App { private static final String CONTAINER_NAME = "arctestAPI"; private static final String OBJECT_NAME = "arc"; static byte[][] etagMap = null; public static void main( String[] args ) throws IOException { Iterable modules = ImmutableSet. builder() //.add(new SLF4JLoggingModule()) //.add(new Module1()) // .add(new SwiftContextModuleFinal()) .build(); Properties overrides = new Properties(); BlobStoreContext context = ContextBuilder.newBuilder("openstack-swift") .endpoint("http://x.xx.xx.xx:5000/v2.0") .credentials("xxx:xxx", "xxx") .modules(modules) .overrides(overrides) .buildView(BlobStoreContext.class); BlobStore blobStore = context.getBlobStore(); PayloadSlicer slicer = new BasePayloadSlicer(); int partId = 0; Payload payload = blob.getPayload(); List ongoingOperations = Lists.newArrayList(); MultipartUpload uploadId = blobStore.initiateMultipartUpload(CONTAINER_NAME, blob.getMetadata(), putopt); //for (int partNumber = 0; partNumber < parts; partNumber++) { for (Payload part : slicer.slice(payload, 33554432)) { MultipartPart future = blobStore.uploadMultipartPart(uploadId, partId +1,part); System.out.println("Part-" + partId + " "+ future.partETag()); ongoingOperations.add(future); partId++; } String etag = blobStore.completeMultipartUpload(uploadId,ongoingOperations ); System.out.println("Complete" + etag); System.out.println("PUTBLOB"); } }