Uses of Class
org.thales.punch.libraries.storm.bolt.file.BatchArchiver

Packages that use BatchArchiver

Package	Description
org.thales.punch.libraries.storm.bolt	Punchplatform bolts package.
org.thales.punch.libraries.storm.bolt.file

Uses of BatchArchiver in org.thales.punch.libraries.storm.bolt

Methods in org.thales.punch.libraries.storm.bolt that return BatchArchiver

Modifier and Type	Method and Description
protected BatchArchiver	AbstractFileOutput.createArchiver(org.thales.punch.libraries.objectstorage.indexing.BatchMetadata metadata) Create correct BatchArchiver from metadata

Methods in org.thales.punch.libraries.storm.bolt with parameters of type BatchArchiver

Modifier and Type	Method and Description
protected void	AbstractFileOutput.flush(BatchArchiver batch) Flush this batch, i.e.

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

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

Modifier and Type	Method and Description
BatchArchiver	BatchArchiver.prepare(Supplier<IArchiveBuffer> archiveBufferSupplier, org.thales.punch.libraries.metrics.api.IMetricContext metricContext) Prepare this instance.
BatchArchiver	BatchArchiver.setAnchoredTuple(org.apache.storm.tuple.Tuple tuple) In the exactly once mode, the first tuple of each batch is kept unacknowledged until the batch is flushed.
BatchArchiver	BatchArchiver.setBloomParameters(int expectedInsertions, double fpp) Use this to make your BatchArchiver instance compute bloom filters.