Package com.linkedin.venice.serialization.avro

Class ChunkedValueManifestSerializer

java.lang.Object

com.linkedin.venice.serialization.avro.InternalAvroSpecificSerializer<ChunkedValueManifest>

com.linkedin.venice.serialization.avro.ChunkedValueManifestSerializer

All Implemented Interfaces:

VeniceKafkaSerializer<ChunkedValueManifest>, Closeable, AutoCloseable, org.apache.kafka.common.serialization.Deserializer<ChunkedValueManifest>, org.apache.kafka.common.serialization.Serializer<ChunkedValueManifest>

public class ChunkedValueManifestSerializer
extends InternalAvroSpecificSerializer<ChunkedValueManifest>

Field Summary

Fields inherited from class com.linkedin.venice.serialization.avro.InternalAvroSpecificSerializer

MAX_ATTEMPTS_FOR_SCHEMA_READER, SENTINEL_PROTOCOL_VERSION_USED_FOR_UNDETECTABLE_COMPILED_SCHEMA, SENTINEL_PROTOCOL_VERSION_USED_FOR_UNVERSIONED_PROTOCOL, VENICE_SCHEMA_READER_CONFIG, WAIT_TIME_BETWEEN_SCHEMA_READER_ATTEMPTS_IN_MS

Constructor Summary

Constructors

Constructor	Description
ChunkedValueManifestSerializer(boolean withoutHeader)

Method Summary

Methods inherited from class com.linkedin.venice.serialization.avro.InternalAvroSpecificSerializer

close, configure, createBinaryDecoder, deserialize, deserialize, deserialize, deserialize, deserialize, getCompiledProtocol, knownProtocols, removeAllSchemas, serialize, serialize, setSchemaReader

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.kafka.common.serialization.Deserializer

deserialize

Methods inherited from interface org.apache.kafka.common.serialization.Serializer

serialize

Constructor Details

ChunkedValueManifestSerializer

public ChunkedValueManifestSerializer(boolean withoutHeader)

Parameters:

withoutHeader - true: this will encode only the raw data, with no header false: this will deserialize data assuming the presence of a 4 bytes header and serialize it with 4 bytes of padding