Package com.linkedin.venice.spark.input.pubsub.raw

Class VeniceRawPubsubStats

java.lang.Object

com.linkedin.venice.spark.input.pubsub.raw.VeniceRawPubsubStats

public class VeniceRawPubsubStats
extends Object

Encapsulates statistics for the Venice Raw Pubsub Input Partition Reader. Tracks metrics about record processing during partition reading.

Constructor Summary

Constructors

Constructor	Description
VeniceRawPubsubStats()	Creates a new stats object with zero-initialized metrics.
VeniceRawPubsubStats(long recordsServed, long recordsSkipped, long recordsDeliveredByGet)	Creates a new stats object with the given metrics.

Method Summary

Modifier and Type	Method	Description
long	getRecordsDeliveredByGet()
long	getRecordsServed()
long	getRecordsSkipped()
void	incrementRecordsDeliveredByGet()	Increments the count of records delivered by get() by 1.
void	incrementRecordsServed()	Increments the count of records served by 1.
void	incrementRecordsSkipped()	Increments the count of records skipped by 1.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

VeniceRawPubsubStats

public VeniceRawPubsubStats()

Creates a new stats object with zero-initialized metrics.

VeniceRawPubsubStats

public VeniceRawPubsubStats(long recordsServed,
 long recordsSkipped,
 long recordsDeliveredByGet)

Creates a new stats object with the given metrics.

Parameters:

recordsServed - The number of records successfully served

recordsSkipped - The number of records skipped (e.g., control messages)

recordsDeliveredByGet - The number of times the get() method was called

Method Details

getRecordsServed

public long getRecordsServed()

Returns:

The number of records successfully served

getRecordsSkipped

public long getRecordsSkipped()

Returns:

The number of records skipped (e.g., control messages)

getRecordsDeliveredByGet

public long getRecordsDeliveredByGet()

Returns:

The number of times the get() method was called

incrementRecordsServed

public void incrementRecordsServed()

Increments the count of records served by 1.

incrementRecordsSkipped

public void incrementRecordsSkipped()

Increments the count of records skipped by 1.

incrementRecordsDeliveredByGet

public void incrementRecordsDeliveredByGet()

Increments the count of records delivered by get() by 1.

toString

public String toString()

Overrides:

toString in class Object