Package com.linkedin.davinci.client

Class InternalDaVinciRecordTransformerConfig

java.lang.Object

com.linkedin.davinci.client.InternalDaVinciRecordTransformerConfig

public class InternalDaVinciRecordTransformerConfig
extends Object

Internal config used for InternalDaVinciRecordTransformer. This is what gets passed into the StoreIngestionTask.

Constructor Summary

Constructors

Constructor	Description
InternalDaVinciRecordTransformerConfig(DaVinciRecordTransformerConfig recordTransformerConfig, AggVersionedDaVinciRecordTransformerStats recordTransformerStats)

Method Summary

Modifier and Type	Method	Description
DaVinciRecordTransformerConfig	getRecordTransformerConfig()
AggVersionedDaVinciRecordTransformerStats	getRecordTransformerStats()
int	getStartConsumptionLatchCount()
void	setStartConsumptionLatchCount(int startConsumptionLatchCount)

Methods inherited from class java.lang.Object

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

Constructor Details

InternalDaVinciRecordTransformerConfig

public InternalDaVinciRecordTransformerConfig(DaVinciRecordTransformerConfig recordTransformerConfig,
 AggVersionedDaVinciRecordTransformerStats recordTransformerStats)

Method Details

getRecordTransformerConfig

public DaVinciRecordTransformerConfig getRecordTransformerConfig()

getRecordTransformerStats

public AggVersionedDaVinciRecordTransformerStats getRecordTransformerStats()

setStartConsumptionLatchCount

public void setStartConsumptionLatchCount(int startConsumptionLatchCount)

Parameters:

startConsumptionLatchCount - the count used for the latch to guarantee we finish scanning every RocksDB partition before starting remote consumption.

getStartConsumptionLatchCount

public int getStartConsumptionLatchCount()

Returns:

startConsumptionLatchCount