com.netflix.genie.core.services.impl

Class CacheGenieFileTransferService

java.lang.Object

com.netflix.genie.core.services.impl.GenieFileTransferService

com.netflix.genie.core.services.impl.CacheGenieFileTransferService

public class CacheGenieFileTransferService
extends GenieFileTransferService

Caches the downloaded file from the remote location. Created by amajumdar on 7/22/16.

Constructor Summary

Constructors

Constructor and Description
CacheGenieFileTransferService(FileTransferFactory fileTransferFactory, java.lang.String baseCacheLocation, LocalFileTransferImpl localFileTransfer, com.netflix.spectator.api.Registry registry) Constructor.

Method Summary

Modifier and Type	Method and Description
protected java.nio.file.Path	createDirectories(java.lang.String path)
protected void	deleteFile(java.io.File file)
void	getFile(java.lang.String srcRemotePath, java.lang.String dstLocalPath) Get the file needed by Genie for job execution.
protected java.io.File	loadFile(java.lang.String path) Loads the file given the path and stores it under the cache location with file name as UUID string created using the path.

Methods inherited from class com.netflix.genie.core.services.impl.GenieFileTransferService

getFileTransfer, putFile

Methods inherited from class java.lang.Object

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

Constructor Detail

CacheGenieFileTransferService

public CacheGenieFileTransferService(@NotNull
                                     FileTransferFactory fileTransferFactory,
                                     @NotNull
                                     java.lang.String baseCacheLocation,
                                     @NotNull
                                     LocalFileTransferImpl localFileTransfer,
                                     @NotNull
                                     com.netflix.spectator.api.Registry registry)
                              throws GenieException

Constructor.

Parameters:

fileTransferFactory - file transfer implementation factory

baseCacheLocation - file cache location

localFileTransfer - Local file transfer service

registry - spectator registry

Throws:

GenieException - If there is any problem

Method Detail

getFile

public void getFile(@NotBlank(message="Source file path cannot be empty.")
                    java.lang.String srcRemotePath,
                    @NotBlank(message="Destination local path cannot be empty")
                    java.lang.String dstLocalPath)
             throws GenieException

Get the file needed by Genie for job execution.

Overrides:

getFile in class GenieFileTransferService

Parameters:

srcRemotePath - Path of the file in the remote location to be fetched

dstLocalPath - Local path where the file needs to be placed

Throws:

GenieException - If there is any problem

deleteFile

protected void deleteFile(java.io.File file)
                   throws java.io.IOException

Throws:

java.io.IOException

createDirectories

protected java.nio.file.Path createDirectories(java.lang.String path)
                                        throws GenieException

Throws:

GenieException

loadFile

protected java.io.File loadFile(java.lang.String path)
                         throws GenieException

Loads the file given the path and stores it under the cache location with file name as UUID string created using the path.

Parameters:

path - Path of the file to be loaded

Returns:

loaded file

Throws:

GenieException - Exception if the file does not load