Package com.linkedin.davinci.kafka.consumer

Class TopicPartitionIngestionInfo

java.lang.Object

com.linkedin.davinci.kafka.consumer.TopicPartitionIngestionInfo

public class TopicPartitionIngestionInfo
extends Object

Constructor Summary

Constructors

Constructor	Description
TopicPartitionIngestionInfo(long latestOffset, long offsetLag, double msgRate, double byteRate, String consumerIdStr, long elapsedTimeSinceLastConsumerPollInMs, long elapsedTimeSinceLastRecordForPartitionInMs, String versionTopicName)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
double	getByteRate()
String	getConsumerIdStr()
long	getElapsedTimeSinceLastConsumerPollInMs()
long	getElapsedTimeSinceLastRecordForPartitionInMs()
long	getLatestOffset()
double	getMsgRate()
long	getOffsetLag()
String	getVersionTopicName()
int	hashCode()
void	setByteRate(double byteRate)
void	setConsumerIdStr(String consumerIdStr)
void	setElapsedTimeSinceLastConsumerPollInMs(long elapsedTimeSinceLastConsumerPollInMs)
void	setElapsedTimeSinceLastRecordForPartitionInMs(long elapsedTimeSinceLastRecordForPartitionInMs)
void	setMsgRate(double msgRate)
void	setOffsetLag(long offsetLag)
void	setVersionTopicName(String versionTopicName)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

TopicPartitionIngestionInfo

public TopicPartitionIngestionInfo(long latestOffset,
 long offsetLag,
 double msgRate,
 double byteRate,
 String consumerIdStr,
 long elapsedTimeSinceLastConsumerPollInMs,
 long elapsedTimeSinceLastRecordForPartitionInMs,
 String versionTopicName)

Method Details

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 String getConsumerIdStr()

setConsumerIdStr

public void setConsumerIdStr(String consumerIdStr)

getElapsedTimeSinceLastConsumerPollInMs

public long getElapsedTimeSinceLastConsumerPollInMs()

setElapsedTimeSinceLastConsumerPollInMs

public void setElapsedTimeSinceLastConsumerPollInMs(long elapsedTimeSinceLastConsumerPollInMs)

getElapsedTimeSinceLastRecordForPartitionInMs

public long getElapsedTimeSinceLastRecordForPartitionInMs()

setElapsedTimeSinceLastRecordForPartitionInMs

public void setElapsedTimeSinceLastRecordForPartitionInMs(long elapsedTimeSinceLastRecordForPartitionInMs)

getVersionTopicName

public String getVersionTopicName()

setVersionTopicName

public void setVersionTopicName(String versionTopicName)

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object