edu.iu.dsc.tws.rsched.uploaders.s3

Class S3Uploader

java.lang.Object

java.lang.Thread

edu.iu.dsc.tws.rsched.uploaders.s3.S3Uploader

All Implemented Interfaces:

IUploader, java.lang.AutoCloseable, java.lang.Runnable

public class S3Uploader
extends java.lang.Thread
implements IUploader

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
S3Uploader()

Method Summary

Modifier and Type	Method and Description
void	close() This is to for disposing or cleaning up any internal state accumulated by the uploader
boolean	complete() if uploader is threaded, this method will wait for the threaded uploading to finish
void	initialize(Config cnfg, java.lang.String jbID) Initialize the uploader with the incoming context.
void	run()
boolean	undo() Undo uploading.
java.net.URI	uploadPackage(java.lang.String sourceLocation) UploadPackage will upload the job package to the given location.

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

S3Uploader

public S3Uploader()

Method Detail

initialize

public void initialize(Config cnfg,
                       java.lang.String jbID)

Description copied from interface: IUploader

Initialize the uploader with the incoming context.

Specified by:

initialize in interface IUploader

run

public void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

uploadPackage

public java.net.URI uploadPackage(java.lang.String sourceLocation)
                           throws UploaderException

Description copied from interface: IUploader

UploadPackage will upload the job package to the given location.

Specified by:

uploadPackage in interface IUploader

Parameters:

sourceLocation - the source location with all the files

Returns:

destination URI of where the job package has been uploaded if successful, or null if failed.

Throws:

UploaderException

complete

public boolean complete()

Description copied from interface: IUploader

if uploader is threaded, this method will wait for the threaded uploading to finish

Specified by:

complete in interface IUploader

Returns:

undo

public boolean undo()

Description copied from interface: IUploader

Undo uploading. Remove uploaded files.

Specified by:

undo in interface IUploader

close

public void close()

Description copied from interface: IUploader

This is to for disposing or cleaning up any internal state accumulated by the uploader

Specified by:

close in interface IUploader

Specified by:

close in interface java.lang.AutoCloseable