Class ZlibPayloadCodec

java.lang.Object

io.temporal.payload.codec.ZlibPayloadCodec

All Implemented Interfaces:

PayloadCodec

public class ZlibPayloadCodec
extends Object
implements PayloadCodec

PayloadCodec that provides a basic compression using Zlib.

Please note that this is by no means the best solution for lots of small payloads which is typical for a lot of applications. You can use this implementation as an example and base for your own implementation using the compressor of your choice, for example Google Snappy

Constructor Summary

Constructors

Constructor	Description
ZlibPayloadCodec()
ZlibPayloadCodec(int level)

Method Summary

Modifier and Type	Method	Description
List<io.temporal.api.common.v1.Payload>	decode(List<io.temporal.api.common.v1.Payload> payloads)
List<io.temporal.api.common.v1.Payload>	encode(List<io.temporal.api.common.v1.Payload> payloads)

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.temporal.payload.codec.PayloadCodec

withContext

Constructor Details

ZlibPayloadCodec

public ZlibPayloadCodec()

ZlibPayloadCodec

public ZlibPayloadCodec(int level)

Parameters:

level - compression level

See Also:

• Deflater(int level)

Method Details

encode

@Nonnull
public List<io.temporal.api.common.v1.Payload> encode(@Nonnull
 List<io.temporal.api.common.v1.Payload> payloads)

Specified by:

encode in interface PayloadCodec

decode

@Nonnull
public List<io.temporal.api.common.v1.Payload> decode(@Nonnull
 List<io.temporal.api.common.v1.Payload> payloads)

Specified by:

decode in interface PayloadCodec