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, java.lang.String consumerIdStr, long elapsedTimeSinceLastPollInMs, java.lang.String versionTopicName)

Method Summary

Modifier and Type	Method	Description
boolean	equals(java.lang.Object o)
double	getByteRate()
java.lang.String	getConsumerIdStr()
long	getElapsedTimeSinceLastPollInMs()
long	getLatestOffset()
double	getMsgRate()
long	getOffsetLag()
java.lang.String	getVersionTopicName()
int	hashCode()
void	setByteRate(double byteRate)
void	setConsumerIdStr(java.lang.String consumerIdStr)
void	setElapsedTimeSinceLastPollInMs(long elapsedTimeSinceLastPollInMs)
void	setMsgRate(double msgRate)
void	setOffsetLag(long offsetLag)
void	setVersionTopicName(java.lang.String versionTopicName)

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,
                                   java.lang.String consumerIdStr,
                                   long elapsedTimeSinceLastPollInMs,
                                   java.lang.String versionTopicName)

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)

getConsumerIdStr

public java.lang.String getConsumerIdStr()

setConsumerIdStr

public void setConsumerIdStr(java.lang.String consumerIdStr)

getElapsedTimeSinceLastPollInMs

public long getElapsedTimeSinceLastPollInMs()

setElapsedTimeSinceLastPollInMs

public void setElapsedTimeSinceLastPollInMs(long elapsedTimeSinceLastPollInMs)

getVersionTopicName

public java.lang.String getVersionTopicName()

setVersionTopicName

public void setVersionTopicName(java.lang.String versionTopicName)

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