org.apache.orc.impl

Class ZstdCodec

java.lang.Object

org.apache.orc.impl.ZstdCodec

All Implemented Interfaces:

org.apache.orc.CompressionCodec, org.apache.orc.impl.DirectDecompressionCodec

public class ZstdCodec
extends Object
implements org.apache.orc.CompressionCodec, org.apache.orc.impl.DirectDecompressionCodec

orc ZstdCodec.

NOTE: The file was copied and modified to support zstd-jni. This feature is only supported in ORC 2.0, but 2.0 only supports JDK17. We need to support JDK8.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.orc.CompressionCodec

org.apache.orc.CompressionCodec.Modifier

Constructor Summary

Constructors

Constructor and Description
ZstdCodec()
ZstdCodec(int level, int windowLog)

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	compress(ByteBuffer in, ByteBuffer out, ByteBuffer overflow, Options options) Compresses an input ByteBuffer into an output ByteBuffer using Zstandard compression.
void	decompress(ByteBuffer in, ByteBuffer out)
void	destroy()
void	directDecompress(ByteBuffer in, ByteBuffer out)
protected static byte[]	getBuffer(int size)
Options	getDefaultOptions()
CompressionKind	getKind()
org.apache.orc.impl.ZstdCodec.ZstdOptions	getZstdOptions()
boolean	isAvailable()
void	reset()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.orc.CompressionCodec

compress, modify

Constructor Detail

ZstdCodec

public ZstdCodec(int level,
                 int windowLog)

ZstdCodec

public ZstdCodec()

Method Detail

getZstdOptions

public org.apache.orc.impl.ZstdCodec.ZstdOptions getZstdOptions()

getBuffer

protected static byte[] getBuffer(int size)

getDefaultOptions

public Options getDefaultOptions()

compress

public boolean compress(ByteBuffer in,
                        ByteBuffer out,
                        ByteBuffer overflow,
                        Options options)
                 throws IOException

Compresses an input ByteBuffer into an output ByteBuffer using Zstandard compression. If the maximum bound of the number of output bytes exceeds the output ByteBuffer size, the remaining bytes are written to the overflow ByteBuffer.

Parameters:

in - the bytes to compress

out - the compressed bytes

overflow - put any additional bytes here

options - the options to control compression

Returns:

ZstdOptions

Throws:

IOException

decompress

public void decompress(ByteBuffer in,
                       ByteBuffer out)
                throws IOException

Specified by:

decompress in interface org.apache.orc.CompressionCodec

Throws:

IOException

isAvailable

public boolean isAvailable()

Specified by:

isAvailable in interface org.apache.orc.impl.DirectDecompressionCodec

directDecompress

public void directDecompress(ByteBuffer in,
                             ByteBuffer out)
                      throws IOException

Specified by:

directDecompress in interface org.apache.orc.impl.DirectDecompressionCodec

Throws:

IOException

reset

public void reset()

Specified by:

reset in interface org.apache.orc.CompressionCodec

destroy

public void destroy()

getKind

public CompressionKind getKind()

close

public void close()

Specified by:

close in interface org.apache.orc.CompressionCodec