Package com.ljarocki.parallelzip.internal

Class ParallelZipWriter.Sink

java.lang.Object

com.ljarocki.parallelzip.internal.ParallelZipWriter.Sink

Enclosing class:

ParallelZipWriter

public static final class ParallelZipWriter.Sink
extends Object

A running compress-and-write pipeline. Entries are handed in via add(com.ljarocki.parallelzip.internal.ParallelZipWriter.Entry) (which blocks when the bounded in-flight window is full, providing backpressure), a worker pool compresses them, and a single writer thread streams them out in submission order. This lets a producer feed entries incrementally without materializing them all at once.

Constructor Summary

Constructors

Constructor	Description
Sink(Path out, boolean store, boolean skipAlreadyCompressed, int level, int threads, boolean forceZip64, long spillThreshold, Path spillDir)

Method Summary

Modifier and Type	Method	Description
void	add(ParallelZipWriter.Entry e)
ParallelZipWriter.Result	finish()

Methods inherited from class java.lang.Object

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

Constructor Details

Sink

public Sink(Path out,
 boolean store,
 boolean skipAlreadyCompressed,
 int level,
 int threads,
 boolean forceZip64,
 long spillThreshold,
 Path spillDir)

Method Details

add

public void add(ParallelZipWriter.Entry e)
         throws InterruptedException

Throws:

InterruptedException

finish

public ParallelZipWriter.Result finish()
                                throws IOException,
InterruptedException

Throws:

IOException

InterruptedException