com.netflix.genie.core.services.impl

Class LocalFileTransferImpl

java.lang.Object

com.netflix.genie.core.services.impl.LocalFileTransferImpl

All Implemented Interfaces:

FileTransfer

public class LocalFileTransferImpl
extends java.lang.Object
implements FileTransfer

An implementation of the FileTransferService interface in which the remote locations are on local filesystem.

Since:

3.0.0

Constructor Summary

Constructors

Constructor and Description
LocalFileTransferImpl()

Method Summary

Modifier and Type	Method and Description
void	getFile(java.lang.String srcRemotePath, java.lang.String dstLocalPath) Gets a file from any remote location to Genie's local working directory.
long	getLastModifiedTime(java.lang.String path) Returns the last modified time of the file with the given path.
boolean	isValid(java.lang.String fileName) This method validates whether it can handle operations for a particular file based on the prefix of the file like s3://, hdfs:// etc.
void	putFile(java.lang.String srcLocalPath, java.lang.String dstRemotePath) Puts a file from Genie's local working directory to a remote location.

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalFileTransferImpl

public LocalFileTransferImpl()

Method Detail

isValid

public boolean isValid(@NotBlank(message="Filename cannot be blank")
                       java.lang.String fileName)
                throws GenieException

This method validates whether it can handle operations for a particular file based on the prefix of the file like s3://, hdfs:// etc.

Specified by:

isValid in interface FileTransfer

Parameters:

fileName - file name to validate

Returns:

whether the implementation can handle file based on prefix

Throws:

GenieException - if there are errors

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

Gets a file from any remote location to Genie's local working directory.

Specified by:

getFile in interface FileTransfer

Parameters:

srcRemotePath - Source path of the files to copy

dstLocalPath - Destination path of the files to copy to

Throws:

GenieException - exception in case of an error

putFile

public void putFile(@NotBlank(message="Source local path cannot be empty.")
                    java.lang.String srcLocalPath,
                    @NotBlank(message="Destination remote path cannot be empty")
                    java.lang.String dstRemotePath)
             throws GenieException

Puts a file from Genie's local working directory to a remote location.

Specified by:

putFile in interface FileTransfer

Parameters:

srcLocalPath - Source path of the files to copy

dstRemotePath - Destination path of the files to copy to

Throws:

GenieException - exception in case of an error

getLastModifiedTime

public long getLastModifiedTime(java.lang.String path)
                         throws GenieException

Returns the last modified time of the file with the given path.

Specified by:

getLastModifiedTime in interface FileTransfer

Parameters:

path - location of the file

Returns:

time in milliseconds

Throws:

GenieException - exception in case of IO error