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 java.lang.Object
implements JobArchiver

Implementation of JobArchiveService for S3 destinations.

Since:

4.0.0

Constructor Summary

Constructors

Constructor	Description
S3JobArchiverImpl(S3ClientFactory s3ClientFactory)	Constructor.

Method Summary

Modifier and Type	Method	Description
boolean	archiveDirectory(@NotNull java.nio.file.Path directory, java.util.List<java.io.File> filesList, @NotNull java.net.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 Detail

S3JobArchiverImpl

public S3JobArchiverImpl(S3ClientFactory s3ClientFactory)

Constructor.

Parameters:

s3ClientFactory - The factory to use to get S3 client instances for a given S3 bucket.

Method Detail

archiveDirectory

public boolean archiveDirectory(@NotNull
                                @NotNull java.nio.file.Path directory,
                                java.util.List<java.io.File> filesList,
                                @NotNull
                                @NotNull java.net.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