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

Class CephGzipArchiveBuffer

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

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

All Implemented Interfaces:

IArchiveBuffer

public class CephGzipArchiveBuffer
extends GzipArchiveBuffer

The CephGzipArchiveBuffer writes its content into a Ceph cluster.

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
CephGzipArchiveBuffer(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)

Method Summary

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.

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

getByteArray, putBytes

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

close, getDigest, getSize, getUncompressedSize, put

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

CephGzipArchiveBuffer

public CephGzipArchiveBuffer(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)

Method Detail

writeToDestination

protected void writeToDestination(org.thales.punch.libraries.objectstorage.tuples.ArchiveDevice destination,
                                  byte[] bb)
                           throws IOException

Description copied from class: PlainArchiveBuffer

Write byte array to provided destination.

Overrides:

writeToDestination in class PlainArchiveBuffer

Parameters:

destination - target

bb - content to write

Throws:

IOException - Unable to write