public class S3ArchiveBuffer extends GzipArchiveBuffer
This can only be used for testing or if you have at hand a filesystem based compression support.
createRoot, outputStream
destinations, filename, maxWrites, minWrites, pool
Constructor and Description |
---|
S3ArchiveBuffer(int minWrites,
int maxWrites,
List<org.thales.punch.libraries.objectstorage.tuples.ArchiveDevice> destinations,
org.thales.punch.libraries.record.client.encoder.api.IRecordEncoder<Map<String,Object>> encoder,
org.thales.punch.libraries.record.client.encoder.api.IRecordEncoder.RecordFormat format) |
Modifier and Type | Method and Description |
---|---|
protected void |
writeToDestination(org.thales.punch.libraries.objectstorage.tuples.ArchiveDevice destination,
byte[] bb)
Write byte array to provided destination.
|
getByteArray, putBytes
close, getDigest, getSize, getUncompressedSize, put
exit, getBatchOutputPath, handleDeviceFailure, prepare
public S3ArchiveBuffer(int minWrites, int maxWrites, List<org.thales.punch.libraries.objectstorage.tuples.ArchiveDevice> destinations, org.thales.punch.libraries.record.client.encoder.api.IRecordEncoder<Map<String,Object>> encoder, org.thales.punch.libraries.record.client.encoder.api.IRecordEncoder.RecordFormat format)
protected void writeToDestination(org.thales.punch.libraries.objectstorage.tuples.ArchiveDevice destination, byte[] bb) throws IOException
PlainArchiveBuffer
writeToDestination
in class PlainArchiveBuffer
destination
- targetbb
- content to writeIOException
- Unable to writeCopyright © 2023. All rights reserved.