Package com.linkedin.davinci.kafka.consumer

Class PartitionConsumptionState.TransientRecord

java.lang.Object

com.linkedin.davinci.kafka.consumer.PartitionConsumptionState.TransientRecord

Enclosing class:

PartitionConsumptionState

public static class PartitionConsumptionState.TransientRecord
extends Object

This immutable class holds a association between a key and value and the source offset of the consumed message. The value could be either as received in kafka ConsumerRecord or it could be a write computed value.

Constructor Summary

Constructors

Constructor	Description
TransientRecord(byte[] value, int valueOffset, int valueLen, int valueSchemaId, int kafkaClusterId, long kafkaConsumedOffset)

Method Summary

Modifier and Type	Method	Description
org.apache.avro.generic.GenericRecord	getReplicationMetadataRecord()
ChunkedValueManifest	getRmdManifest()
byte[]	getValue()
int	getValueLen()
ChunkedValueManifest	getValueManifest()
int	getValueOffset()
int	getValueSchemaId()
void	setReplicationMetadataRecord(org.apache.avro.generic.GenericRecord replicationMetadataRecord)
void	setRmdManifest(ChunkedValueManifest rmdManifest)
void	setValueManifest(ChunkedValueManifest valueManifest)

Methods inherited from class java.lang.Object

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

Constructor Details

TransientRecord

public TransientRecord(byte[] value,
 int valueOffset,
 int valueLen,
 int valueSchemaId,
 int kafkaClusterId,
 long kafkaConsumedOffset)

Method Details

getRmdManifest

public ChunkedValueManifest getRmdManifest()

setRmdManifest

public void setRmdManifest(ChunkedValueManifest rmdManifest)

getValueManifest

public ChunkedValueManifest getValueManifest()

setValueManifest

public void setValueManifest(ChunkedValueManifest valueManifest)

setReplicationMetadataRecord

public void setReplicationMetadataRecord(org.apache.avro.generic.GenericRecord replicationMetadataRecord)

getReplicationMetadataRecord

public org.apache.avro.generic.GenericRecord getReplicationMetadataRecord()

getValue

public byte[] getValue()

getValueOffset

public int getValueOffset()

getValueLen

public int getValueLen()

getValueSchemaId

public int getValueSchemaId()