Package com.netflix.genie.common.internal.services.impl

Class S3JobArchiverImpl

java.lang.Object

com.netflix.genie.common.internal.services.impl.S3JobArchiverImpl

All Implemented Interfaces:

JobArchiver

public class S3JobArchiverImpl
extends Object
implements JobArchiver

Implementation of JobArchiver for S3 destinations.

Constructor Summary

Constructors

Constructor	Description
S3JobArchiverImpl(S3TransferManagerFactory transferManagerFactory)	Constructor.

Method Summary

Modifier and Type	Method	Description
boolean	archiveDirectory(@NotNull Path directory, List<File> filesList, @NotNull URI target)	Attempt to archive a directory located at directory to the target.

Methods inherited from class java.lang.Object

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

Constructor Details

S3JobArchiverImpl

public S3JobArchiverImpl(S3TransferManagerFactory transferManagerFactory)

Constructor.

Parameters:

transferManagerFactory - The factory to use to get S3 transfer manager instances for a given S3 bucket.

Method Details

archiveDirectory

public boolean archiveDirectory(@NotNull
 @NotNull Path directory,
 List<File> filesList,
 @NotNull
 @NotNull URI target)
                         throws JobArchiveException

Attempt to archive a directory located at directory to the target. All existing data "under" target should be assumed to be overwritten/replaced.

Specified by:

archiveDirectory in interface JobArchiver

Parameters:

directory - The directory to archive

filesList - The list of files to archive

target - The root of a writable location to archive to.

Returns:

false if this implementation doesn't support archiving to target. true if does support archiving to target and the archival was successful

Throws:

JobArchiveException - If an exception happened during archival