RmdPushUtils (venice API)

java.lang.Object

com.linkedin.venice.spark.utils.RmdPushUtils

public final class RmdPushUtils extends Object

Utility class for handling replication metadata (RMD) related operations in Venice push jobs.

Constructor Summary

Constructors

Constructor

Description

RmdPushUtils()
Method Summary

Modifier and Type

Method

Description

static boolean

containsLogicalTimestamp(PushJobSetting pushJobSetting)

static RecordDeserializer<Long>

getDeserializerForLogicalTimestamp()

static org.apache.avro.Schema

getInputRmdSchema(PushJobSetting pushJobSetting)

static RecordSerializer<Long>

getSerializerForLogicalTimestamp()

static boolean

rmdFieldPresent(PushJobSetting pushJobSetting)

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

Constructor Details
- RmdPushUtils
  
  public RmdPushUtils()
Method Details
- getDeserializerForLogicalTimestamp
  
  public static RecordDeserializer<Long> getDeserializerForLogicalTimestamp()
- getSerializerForLogicalTimestamp
  
  public static RecordSerializer<Long> getSerializerForLogicalTimestamp()
- getInputRmdSchema
  
  public static org.apache.avro.Schema getInputRmdSchema(PushJobSetting pushJobSetting)
- containsLogicalTimestamp
  
  public static boolean containsLogicalTimestamp(PushJobSetting pushJobSetting)
- rmdFieldPresent
  
  public static boolean rmdFieldPresent(PushJobSetting pushJobSetting)