Class ChunkedValueManifestSerializer
- java.lang.Object
-
- com.linkedin.venice.serialization.avro.InternalAvroSpecificSerializer<ChunkedValueManifest>
-
- com.linkedin.venice.serialization.avro.ChunkedValueManifestSerializer
-
- All Implemented Interfaces:
VeniceKafkaSerializer<ChunkedValueManifest>
,java.io.Closeable
,java.lang.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
-
-
-
-
Constructor Detail
-
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
-
-