Package com.linkedin.davinci.client
Class DaVinciRecordTransformerRecordMetadata
java.lang.Object
com.linkedin.davinci.client.DaVinciRecordTransformerRecordMetadata
Per record metadata wrapper for 
DaVinciRecordTransformer.- 
Field SummaryFields
- 
Constructor SummaryConstructorsConstructorDescriptionDaVinciRecordTransformerRecordMetadata(int writerSchemaId, long timestamp, PubSubPosition pubSubPosition, int payloadSize, ByteBuffer replicationMetadataPayload) DaVinciRecordTransformerRecordMetadata(long timestamp, PubSubPosition pubSubPosition, int payloadSize, ByteBuffer replicationMetadataPayload) 
- 
Method SummaryModifier and TypeMethodDescriptionintlongint
- 
Field Details- 
SENTINEL_WRITER_SCHEMA_IDpublic static final int SENTINEL_WRITER_SCHEMA_ID- See Also:
 
 
- 
- 
Constructor Details- 
DaVinciRecordTransformerRecordMetadatapublic DaVinciRecordTransformerRecordMetadata(long timestamp, PubSubPosition pubSubPosition, int payloadSize, ByteBuffer replicationMetadataPayload) 
- 
DaVinciRecordTransformerRecordMetadatapublic DaVinciRecordTransformerRecordMetadata(int writerSchemaId, long timestamp, PubSubPosition pubSubPosition, int payloadSize, ByteBuffer replicationMetadataPayload) 
 
- 
- 
Method Details- 
getWriterSchemaIdpublic int getWriterSchemaId()- Returns:
- the schema ID that the record was written with if it's a PUT.
 If the record came from disk, or it's a DELETE, it will be SENTINEL_WRITER_SCHEMA_ID.
 
- 
getTimestamppublic long getTimestamp()- Returns:
- timestamp that the record was added to the version topic If the record came from disk, it will be 0.
 
- 
getPubSubPosition- Returns:
- the position of the record in the topic. If the record came from disk, it will be the earliest position in the topic partition.
 
- 
getPayloadSizepublic int getPayloadSize()- Returns:
- the size in bytes of the key + value
 
- 
getReplicationMetadataPayload- Returns:
- the serialized replication metadata payload if it's a PUT. If the record came from disk or it's a DELETE, it will be null.
 
 
-