Package com.linkedin.davinci.compression

Class KeyUrnCompressor

java.lang.Object

com.linkedin.davinci.compression.KeyUrnCompressor

public class KeyUrnCompressor
extends Object

This class provides functionality to compress and decompress keys containing URNs using a URN dictionary. It supports both string type key schema (when the entire key is a URN) and record type key schema (when the key is a record containing one or more URN fields).

Constructor Summary

Constructors

Constructor	Description
KeyUrnCompressor(org.apache.avro.Schema keySchema, UrnDictV1 urnDict)
KeyUrnCompressor(org.apache.avro.Schema keySchema, List<String> urnFieldNames, UrnDictV1 urnDict)

Method Summary

Modifier and Type	Method	Description
byte[]	compressKey(byte[] key, boolean updateDictUponUnknownUrn)
byte[]	compressKey(Object keyObject, boolean updateDictUponUnknownUrn)
Object	decompressAndDecodeKey(byte[] compressedKey)
byte[]	decompressKey(byte[] compressedKey)
UrnDictV1	getUrnDict()
List<String>	getUrnFieldNames()
static void	validateKeySchemaBasedOnUrnFieldNames(org.apache.avro.Schema keySchema, List<String> urnFieldNames)

Methods inherited from class java.lang.Object

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

Constructor Details

KeyUrnCompressor

public KeyUrnCompressor(org.apache.avro.Schema keySchema,
 UrnDictV1 urnDict)

KeyUrnCompressor

public KeyUrnCompressor(org.apache.avro.Schema keySchema,
 List<String> urnFieldNames,
 UrnDictV1 urnDict)

Method Details

compressKey

public byte[] compressKey(byte[] key,
 boolean updateDictUponUnknownUrn)

compressKey

public byte[] compressKey(Object keyObject,
 boolean updateDictUponUnknownUrn)

decompressAndDecodeKey

public Object decompressAndDecodeKey(byte[] compressedKey)

decompressKey

public byte[] decompressKey(byte[] compressedKey)

validateKeySchemaBasedOnUrnFieldNames

public static void validateKeySchemaBasedOnUrnFieldNames(org.apache.avro.Schema keySchema,
 List<String> urnFieldNames)

getUrnDict

public UrnDictV1 getUrnDict()

getUrnFieldNames

public List<String> getUrnFieldNames()