edu.iu.dsc.tws.rsched.uploaders.k8s

Class DirectUploader

java.lang.Object

java.lang.Thread

edu.iu.dsc.tws.rsched.uploaders.k8s.DirectUploader

All Implemented Interfaces:

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

public class DirectUploader
extends java.lang.Thread
implements IUploader, JobEndListener

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
DirectUploader()

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() DirectUploader should run until the job completes it should upload the job package in case of failures and job scaling up new workers
void	initialize(Config cnfg, java.lang.String jbID) Initialize the uploader with the incoming context.
void	jobEnded() job has ended stop the uploader clear temp job package directory
void	run() watch job pods until they become Running and start an uploader for each pod afterward
void	stopUploader()
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

DirectUploader

public DirectUploader()

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

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

run

public void run()

watch job pods until they become Running and start an uploader for each pod afterward

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

complete

public boolean complete()

DirectUploader should run until the job completes it should upload the job package in case of failures and job scaling up new workers

Specified by:

complete in interface IUploader

Returns:

stopUploader

public void stopUploader()

jobEnded

public void jobEnded()

job has ended stop the uploader clear temp job package directory

Specified by:

jobEnded in interface JobEndListener

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