RmdUtils (venice API)

java.lang.Object

com.linkedin.venice.schema.rmd.RmdUtils

public class RmdUtils extends Object

Ths class is responsible for deserializing RMDs and extract some information from it. It borrows some methods from RmdSerDe.

Constructor Summary

Constructors

Constructor

Description

RmdUtils()
Method Summary

Modifier and Type

Method

Description

static List<Long>

extractTimestampFromRmd(org.apache.avro.generic.GenericRecord replicationMetadataRecord)

static long

getLastUpdateTimestamp(Object object)

static RmdTimestampType

getRmdTimestampType(Object tsObject)

Returns the type of union record given tsObject is.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- RmdUtils
  
  public RmdUtils()
Method Details
- getRmdTimestampType
  
  public static RmdTimestampType getRmdTimestampType(Object tsObject)
  
  Returns the type of union record given tsObject is. Right now it will be either root level long or generic record of per field timestamp.
  
  Parameters:
  
  tsObject -
- extractTimestampFromRmd
  
  public static List<Long> extractTimestampFromRmd(org.apache.avro.generic.GenericRecord replicationMetadataRecord)
- getLastUpdateTimestamp
  
  public static long getLastUpdateTimestamp(Object object)