org.thales.punch.libraries.storm.bolt.file.buffer

Class GzipArchiveBuffer

java.lang.Object

org.thales.punch.libraries.storm.bolt.file.buffer.AbstractArchiveBuffer

org.thales.punch.libraries.storm.bolt.file.buffer.PlainArchiveBuffer

org.thales.punch.libraries.storm.bolt.file.buffer.GzipArchiveBuffer

All Implemented Interfaces:

IArchiveBuffer

Direct Known Subclasses:

CephGzipArchiveBuffer, S3ArchiveBuffer

public class GzipArchiveBuffer
extends PlainArchiveBuffer

The Gzip archiver creates a RAM byte array with gzip compressed batch content before writing to file (no streaming). Works the same way as PlainArchiveBuffer but with gzip compression.

Author:

dimi

Field Summary

Fields inherited from class org.thales.punch.libraries.storm.bolt.file.buffer.PlainArchiveBuffer

createRoot, outputStream

Fields inherited from class org.thales.punch.libraries.storm.bolt.file.buffer.AbstractArchiveBuffer

destinations, filename, maxWrites, minWrites, pool

Constructor Summary

Constructors

Constructor and Description
GzipArchiveBuffer(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, boolean createRoot) Ctor

Method Summary

Modifier and Type	Method and Description
protected byte[]	getByteArray() Get final byte array
protected void	putBytes(byte[] bytes) Write bytes to correct buffer

Methods inherited from class org.thales.punch.libraries.storm.bolt.file.buffer.PlainArchiveBuffer

close, getDigest, getSize, getUncompressedSize, put, writeToDestination

Methods inherited from class org.thales.punch.libraries.storm.bolt.file.buffer.AbstractArchiveBuffer

exit, getBatchOutputPath, handleDeviceFailure, prepare

Methods inherited from class java.lang.Object

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

Constructor Detail

GzipArchiveBuffer

public GzipArchiveBuffer(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,
                         boolean createRoot)

Ctor

Parameters:

createRoot - true to create the root directory

Method Detail

putBytes

protected void putBytes(byte[] bytes)
                 throws IOException

Description copied from class: PlainArchiveBuffer

Write bytes to correct buffer

Overrides:

putBytes in class PlainArchiveBuffer

Parameters:

bytes - content to write

Throws:

IOException - Unable to write

getByteArray

protected byte[] getByteArray()

Description copied from class: PlainArchiveBuffer

Get final byte array

Overrides:

getByteArray in class PlainArchiveBuffer

Returns:

output stream content