Class ZstdOutputStream

java.lang.Object

java.io.OutputStream

java.io.FilterOutputStream

com.github.luben.zstd.ZstdOutputStream

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable

public class ZstdOutputStream
extends FilterOutputStream

OutputStream filter that compresses the data using Zstd compression

Field Summary

Fields inherited from class FilterOutputStream

out

Constructor Summary

Constructors

Constructor	Description
ZstdOutputStream(@NotNull OutputStream outStream)	create a new compressing OutputStream
ZstdOutputStream(@NotNull OutputStream outStream, int level)	create a new compressing OutputStream
ZstdOutputStream(@NotNull OutputStream outStream, int level, boolean closeFrameOnFlush)	Deprecated. Use ZstdOutputStream() or ZstdOutputStream(level) and set the other params with the setters
ZstdOutputStream(@NotNull OutputStream outStream, int level, boolean closeFrameOnFlush, boolean useChecksums)	Deprecated. Use ZstdOutputStream() or ZstdOutputStream(level) and set the other params with the setters
ZstdOutputStream(@NotNull OutputStream outStream, @NotNull BufferPool bufferPool)	create a new compressing OutputStream
ZstdOutputStream(@NotNull OutputStream outStream, @NotNull BufferPool bufferPool, int level)	create a new compressing OutputStream

Method Summary

Modifier and Type	Method	Description
void	close()
protected void	finalize()
void	flush()	Flushes the output
static long	recommendedCOutSize()
@NotNull ZstdOutputStream	setChainLog(int chainLog)	Advanced Compression Option: Set the maximum number of bits for the secondary search structure.
@NotNull ZstdOutputStream	setChecksum(boolean useChecksums)	Enable checksums for the compressed stream.
@NotNull ZstdOutputStream	setCloseFrameOnFlush(boolean closeOnFlush)	Enable closing the frame on flush.
@NotNull ZstdOutputStream	setDict(byte @NotNull [] dict)
@NotNull ZstdOutputStream	setDict(@NotNull ZstdDictCompress dict)
void	setFinalize(boolean finalize)	Deprecated. If you don't rely on finalizers, use `ZstdOutputStreamNoFinalizer` instead.
@NotNull ZstdOutputStream	setHashLog(int hashLog)	Advanced Compression Option: Set the maximum number of bits for a hash table.
@NotNull ZstdOutputStream	setJobSize(int jobSize)	Advanced Compression Option: Set the size of each compression job.
@NotNull ZstdOutputStream	setLevel(int level)	Set the compression level.
@NotNull ZstdOutputStream	setLong(int windowLog)	Set the Long Distance Matching.
@NotNull ZstdOutputStream	setMinMatch(int minMatch)	Advanced Compression Option: Set the minimum match length.
@NotNull ZstdOutputStream	setOverlapLog(int overlapLog)	Advanced Compression Option: Set the amount of data reloaded from the previous job.
@NotNull ZstdOutputStream	setSearchLog(int searchLog)	Advanced Compression Option: Set the maximum number of searches in a hash chain or a binary tree using logarithmic scale.
@NotNull ZstdOutputStream	setStrategy(int strategy)	Advanced Compression Option: Set the strategy used by a match finder.
@NotNull ZstdOutputStream	setTargetLength(int targetLength)	Advanced Compression Option: Set the target match length.
@NotNull ZstdOutputStream	setWindowLog(int windowLog)	Advanced Compression Option: Set the maximum number of bits for a match distance.
@NotNull ZstdOutputStream	setWorkers(int n)	Enable use of worker threads for parallel compression.
void	write(byte @NotNull [] src, int offset, int len)
void	write(int i)

Methods inherited from class FilterOutputStream

write

Methods inherited from class OutputStream

nullOutputStream

Methods inherited from class Object

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

Constructor Details

ZstdOutputStream

@Deprecated
public ZstdOutputStream(@NotNull
 @NotNull OutputStream outStream,
 int level,
 boolean closeFrameOnFlush,
 boolean useChecksums)
                 throws IOException

Deprecated.

Use ZstdOutputStream() or ZstdOutputStream(level) and set the other params with the setters

Throws:

IOException

ZstdOutputStream

@Deprecated
public ZstdOutputStream(@NotNull
 @NotNull OutputStream outStream,
 int level,
 boolean closeFrameOnFlush)
                 throws IOException

Deprecated.

Use ZstdOutputStream() or ZstdOutputStream(level) and set the other params with the setters

Throws:

IOException

ZstdOutputStream

public ZstdOutputStream(@NotNull
 @NotNull OutputStream outStream,
 int level)
                 throws IOException

create a new compressing OutputStream

Parameters:

outStream - the stream to wrap

level - the compression level

Throws:

IOException

ZstdOutputStream

public ZstdOutputStream(@NotNull
 @NotNull OutputStream outStream)
                 throws IOException

create a new compressing OutputStream

Parameters:

outStream - the stream to wrap

Throws:

IOException

ZstdOutputStream

public ZstdOutputStream(@NotNull
 @NotNull OutputStream outStream,
 @NotNull
 @NotNull BufferPool bufferPool,
 int level)
                 throws IOException

create a new compressing OutputStream

Parameters:

outStream - the stream to wrap

bufferPool - the pool to fetch and return buffers

Throws:

IOException

ZstdOutputStream

public ZstdOutputStream(@NotNull
 @NotNull OutputStream outStream,
 @NotNull
 @NotNull BufferPool bufferPool)
                 throws IOException

create a new compressing OutputStream

Parameters:

outStream - the stream to wrap

bufferPool - the pool to fetch and return buffers

Throws:

IOException

Method Details

setFinalize

@Deprecated
public void setFinalize(boolean finalize)

Deprecated.

If you don't rely on finalizers, use `ZstdOutputStreamNoFinalizer` instead.

Enable or disable class finalizers If finalizers are disabled the responsibility fir calling the `close` method is on the consumer.

Parameters:

finalize - default `true` - finalizers are enabled

finalize

protected void finalize()
                 throws Throwable

Overrides:

finalize in class Object

Throws:

Throwable

recommendedCOutSize

public static long recommendedCOutSize()

setChecksum

@NotNull
public @NotNull ZstdOutputStream setChecksum(boolean useChecksums)
                                      throws IOException

Enable checksums for the compressed stream. Default: false

Throws:

IOException

setLevel

@NotNull
public @NotNull ZstdOutputStream setLevel(int level)
                                   throws IOException

Set the compression level. Default: Zstd.defaultCompressionLevel()

Throws:

IOException

setLong

@NotNull
public @NotNull ZstdOutputStream setLong(int windowLog)
                                  throws IOException

Set the Long Distance Matching. Values for windowLog outside the range 10-27 will disable and reset LDM

Throws:

IOException

setWorkers

@NotNull
public @NotNull ZstdOutputStream setWorkers(int n)
                                     throws IOException

Enable use of worker threads for parallel compression. Default: no worker threads.

Throws:

IOException

setOverlapLog

@NotNull
public @NotNull ZstdOutputStream setOverlapLog(int overlapLog)
                                        throws IOException

Advanced Compression Option: Set the amount of data reloaded from the previous job. See https://facebook.github.io/zstd/zstd_manual.html#Chapter5 for more information.

Throws:

IOException

setJobSize

@NotNull
public @NotNull ZstdOutputStream setJobSize(int jobSize)
                                     throws IOException

Advanced Compression Option: Set the size of each compression job. Only applies when multi threaded compression is enabled. See https://facebook.github.io/zstd/zstd_manual.html#Chapter5 for more information.

Throws:

IOException

setTargetLength

@NotNull
public @NotNull ZstdOutputStream setTargetLength(int targetLength)
                                          throws IOException

Advanced Compression Option: Set the target match length. See https://facebook.github.io/zstd/zstd_manual.html#Chapter5 for more information.

Throws:

IOException

setMinMatch

@NotNull
public @NotNull ZstdOutputStream setMinMatch(int minMatch)
                                      throws IOException

Advanced Compression Option: Set the minimum match length. See https://facebook.github.io/zstd/zstd_manual.html#Chapter5 for more information.

Throws:

IOException

setSearchLog

@NotNull
public @NotNull ZstdOutputStream setSearchLog(int searchLog)
                                       throws IOException

Advanced Compression Option: Set the maximum number of searches in a hash chain or a binary tree using logarithmic scale. See https://facebook.github.io/zstd/zstd_manual.html#Chapter5 for more information.

Throws:

IOException

setChainLog

@NotNull
public @NotNull ZstdOutputStream setChainLog(int chainLog)
                                      throws IOException

Advanced Compression Option: Set the maximum number of bits for the secondary search structure. See https://facebook.github.io/zstd/zstd_manual.html#Chapter5 for more information.

Throws:

IOException

setHashLog

@NotNull
public @NotNull ZstdOutputStream setHashLog(int hashLog)
                                     throws IOException

Advanced Compression Option: Set the maximum number of bits for a hash table. See https://facebook.github.io/zstd/zstd_manual.html#Chapter5 for more information.

Throws:

IOException

setWindowLog

@NotNull
public @NotNull ZstdOutputStream setWindowLog(int windowLog)
                                       throws IOException

Advanced Compression Option: Set the maximum number of bits for a match distance. See https://facebook.github.io/zstd/zstd_manual.html#Chapter5 for more information.

Throws:

IOException

setStrategy

@NotNull
public @NotNull ZstdOutputStream setStrategy(int strategy)
                                      throws IOException

Advanced Compression Option: Set the strategy used by a match finder. See https://facebook.github.io/zstd/zstd_manual.html#Chapter5 for more information.

Throws:

IOException

setCloseFrameOnFlush

@NotNull
public @NotNull ZstdOutputStream setCloseFrameOnFlush(boolean closeOnFlush)

Enable closing the frame on flush. This will guarantee that it can be ready fully if the process crashes before closing the stream. On the downside it will negatively affect the compression ratio. Default: false.

setDict

@NotNull
public @NotNull ZstdOutputStream setDict(byte @NotNull [] dict)
                                  throws IOException

Throws:

IOException

setDict

@NotNull
public @NotNull ZstdOutputStream setDict(@NotNull
 @NotNull ZstdDictCompress dict)
                                  throws IOException

Throws:

IOException

write

public void write(byte @NotNull [] src,
 int offset,
 int len)
           throws IOException

Overrides:

write in class FilterOutputStream

Throws:

IOException

write

public void write(int i)
           throws IOException

Overrides:

write in class FilterOutputStream

Throws:

IOException

flush

public void flush()
           throws IOException

Flushes the output

Specified by:

flush in interface Flushable

Overrides:

flush in class FilterOutputStream

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class FilterOutputStream

Throws:

IOException