io.druid.storage.s3

Class S3DataSegmentArchiver

java.lang.Object

io.druid.storage.s3.S3DataSegmentMover

io.druid.storage.s3.S3DataSegmentArchiver

All Implemented Interfaces:

DataSegmentArchiver, DataSegmentMover

public class S3DataSegmentArchiver
extends S3DataSegmentMover
implements DataSegmentArchiver

Constructor Summary

Constructors

Constructor and Description
S3DataSegmentArchiver(com.fasterxml.jackson.databind.ObjectMapper mapper, org.jets3t.service.impl.rest.httpclient.RestS3Service s3Client, S3DataSegmentArchiverConfig archiveConfig, S3DataSegmentPusherConfig restoreConfig)

Method Summary

Modifier and Type	Method and Description
DataSegment	archive(DataSegment segment) Perform an archive task on the segment and return the resulting segment or null if there was no action needed.
DataSegment	restore(DataSegment segment) Perform the restore from an archived segment and return the resulting segment or null if there was no action

Methods inherited from class io.druid.storage.s3.S3DataSegmentMover

move

Methods inherited from class java.lang.Object

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

Constructor Detail

S3DataSegmentArchiver

@Inject
public S3DataSegmentArchiver(com.fasterxml.jackson.databind.ObjectMapper mapper,
                                     org.jets3t.service.impl.rest.httpclient.RestS3Service s3Client,
                                     S3DataSegmentArchiverConfig archiveConfig,
                                     S3DataSegmentPusherConfig restoreConfig)

Method Detail

archive

public DataSegment archive(DataSegment segment)
                    throws SegmentLoadingException

Description copied from interface: DataSegmentArchiver

Perform an archive task on the segment and return the resulting segment or null if there was no action needed.

Specified by:

archive in interface DataSegmentArchiver

Parameters:

segment - The source segment

Returns:

The segment after archiving or `null` if there was no archiving performed.

Throws:

SegmentLoadingException - on error

restore

public DataSegment restore(DataSegment segment)
                    throws SegmentLoadingException

Description copied from interface: DataSegmentArchiver

Perform the restore from an archived segment and return the resulting segment or null if there was no action

Specified by:

restore in interface DataSegmentArchiver

Parameters:

segment - The source (archived) segment

Returns:

The segment after it has been unarchived

Throws:

SegmentLoadingException - on error