Package com.linkedin.davinci.kafka.consumer

Class TopicPartitionIngestionInfo

java.lang.Object

com.linkedin.davinci.kafka.consumer.TopicPartitionIngestionInfo

public class TopicPartitionIngestionInfo
extends java.lang.Object

Constructor Summary

Constructors

Constructor	Description
TopicPartitionIngestionInfo(long latestOffset, long offsetLag, double msgRate, double byteRate, int consumerIdx, long elapsedTimeSinceLastPollInMs)

Method Summary

Modifier and Type	Method	Description
boolean	equals(java.lang.Object o)
double	getByteRate()
int	getConsumerIdx()
long	getElapsedTimeSinceLastPollInMs()
long	getLatestOffset()
double	getMsgRate()
long	getOffsetLag()
int	hashCode()
void	setByteRate(double byteRate)
void	setConsumerIdx(int consumerIdx)
void	setElapsedTimeSinceLastPollInMs(long elapsedTimeSinceLastPollInMs)
void	setMsgRate(double msgRate)
void	setOffsetLag(long offsetLag)

Methods inherited from class java.lang.Object

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

Constructor Detail

TopicPartitionIngestionInfo

public TopicPartitionIngestionInfo(long latestOffset,
                                   long offsetLag,
                                   double msgRate,
                                   double byteRate,
                                   int consumerIdx,
                                   long elapsedTimeSinceLastPollInMs)

Method Detail

getLatestOffset

public long getLatestOffset()

getOffsetLag

public long getOffsetLag()

setOffsetLag

public void setOffsetLag(long offsetLag)

getMsgRate

public double getMsgRate()

setMsgRate

public void setMsgRate(double msgRate)

getByteRate

public double getByteRate()

setByteRate

public void setByteRate(double byteRate)

getConsumerIdx

public int getConsumerIdx()

setConsumerIdx

public void setConsumerIdx(int consumerIdx)

getElapsedTimeSinceLastPollInMs

public long getElapsedTimeSinceLastPollInMs()

setElapsedTimeSinceLastPollInMs

public void setElapsedTimeSinceLastPollInMs(long elapsedTimeSinceLastPollInMs)

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object