com.gpudb.filesystem.upload

Class FileUploader

java.lang.Object

com.gpudb.filesystem.common.FileOperation

com.gpudb.filesystem.upload.FileUploader

public class FileUploader
extends FileOperation

This is an internal class and not meant to be used by the end users of the filesystem API. The consequences of using this class directly in client code is not guaranteed and maybe undesirable. This class handles uploading of either single part file or multiple part uploads. This class extends the class FileOperation and provides additional functionalities of creating instances of UploadIoJob, starting them and waiting for them to terminate. The main exposed method to call is upload() which calls two private methods named uploadFullFiles() and uploadMultiPartFiles() respectively. The method uploadFullFiles() does the upload by calling the Jave endpoint to upload all files in one go. The method uploadMultiPartFiles() does the uploads by creating background threads since each file could take a long time to upload. The multiple parts of a single file are uploaded sequentially in a single thread and multiple files are uploaded in different threads.

Field Summary

Fields inherited from class com.gpudb.filesystem.common.FileOperation

db, dirName, fileHandlerOptions, fileNames, fullFileBatchManager, fullFileList, fullRemoteFileNames, KIFS_PATH_SEPARATOR, multiPartList, multiPartRemoteFileNames, namesOfFilesUploaded, opMode, recursive

Constructor Summary

Constructors

Constructor and Description
FileUploader(GPUdb db, List<String> fileNames, String remoteDirName, UploadOptions options, FileUploadListener callback, GPUdbFileHandler.Options fileHandlerOptions) Constructor -

Method Summary

Modifier and Type	Method and Description
String	getEncoding()
int	getRankForLocalDist()
UploadOptions	getUploadOptions()
void	setEncoding(String encoding)
void	setRankForLocalDist(int rankForLocalDist)
void	setUploadOptions(UploadOptions uploadOptions)
void	upload() This is the main upload method which is to be called by the users of this class.

Methods inherited from class com.gpudb.filesystem.common.FileOperation

decideMultiPart, getFileInfoFromServer, getFileInfoFromServer, getKifsPathSeparator, getNamesOfFilesUploaded, localDirExists, localFileExists, parseFileNames, sortFilesIntoFullAndMultipartLists, traverseLocalDirectories

Methods inherited from class java.lang.Object

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

Constructor Detail

FileUploader

public FileUploader(GPUdb db,
                    List<String> fileNames,
                    String remoteDirName,
                    UploadOptions options,
                    FileUploadListener callback,
                    GPUdbFileHandler.Options fileHandlerOptions)
             throws GPUdbException

Constructor -

Parameters:

db - - The GPUdb instance

fileNames - - List - Names of the files to be uploaded

remoteDirName - - String - Name of remote directory under KIFS

options - - The UploadOptions object which is used to configure the upload operation.

Throws:

GPUdbException

Method Detail

upload

public void upload()
            throws GPUdbException

This is the main upload method which is to be called by the users of this class. Internally depending whether there are files to be uploaded one shot or in parts it will call the methods uploadFullFiles() and uploadMultiPartFiles()

Throws:

GPUdbException

getUploadOptions

public UploadOptions getUploadOptions()

setUploadOptions

public void setUploadOptions(UploadOptions uploadOptions)

getRankForLocalDist

public int getRankForLocalDist()

setRankForLocalDist

public void setRankForLocalDist(int rankForLocalDist)

getEncoding

public String getEncoding()

setEncoding

public void setEncoding(String encoding)