Uses of Interface
org.thales.punch.libraries.storm.bolt.file.buffer.IArchiveBuffer

Packages that use IArchiveBuffer

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

Uses of IArchiveBuffer in org.thales.punch.libraries.storm.bolt.file

Method parameters in org.thales.punch.libraries.storm.bolt.file with type arguments of type IArchiveBuffer

Modifier and Type	Method and Description
BatchArchiver	BatchArchiver.prepare(Supplier<IArchiveBuffer> archiveBufferSupplier, org.thales.punch.libraries.metrics.api.IMetricContext metricContext) Prepare this instance.

Uses of IArchiveBuffer in org.thales.punch.libraries.storm.bolt.file.buffer

Classes in org.thales.punch.libraries.storm.bolt.file.buffer that implement IArchiveBuffer

Modifier and Type	Class and Description
class	AbstractArchiveBuffer
class	AvroParquetArchiveBuffer The AvroParquetArchiveBuffer writes its content into S3 cluster or Filesystem.
class	CephGzipArchiveBuffer The CephGzipArchiveBuffer writes its content into a Ceph cluster.
class	GzipArchiveBuffer The Gzip archiver creates a RAM byte array with gzip compressed batch content before writing to file (no streaming).
class	PlainArchiveBuffer The plain archiver simply creates a RAM byte array with the batch content.
class	S3ArchiveBuffer The plain archiver simply creates a RAM byte array with the batch content.
class	StreamingGzipArchiveBuffer A streaming gzip output file archiver.

Methods in org.thales.punch.libraries.storm.bolt.file.buffer that return IArchiveBuffer

Modifier and Type	Method and Description
IArchiveBuffer	StreamingGzipArchiveBuffer.prepare(org.thales.punch.libraries.objectstorage.indexing.BatchMetadata metaData)
IArchiveBuffer	IArchiveBuffer.prepare(org.thales.punch.libraries.objectstorage.indexing.BatchMetadata metadata) Before using the archive buffer call this.
IArchiveBuffer	AvroParquetArchiveBuffer.prepare(org.thales.punch.libraries.objectstorage.indexing.BatchMetadata metaData)
IArchiveBuffer	AbstractArchiveBuffer.prepare(org.thales.punch.libraries.objectstorage.indexing.BatchMetadata metaData)