Package ai.superstream.model

Class TopicConfiguration

java.lang.Object

ai.superstream.model.TopicConfiguration

public class TopicConfiguration
extends Object

Represents the configuration for a specific Kafka topic.

Constructor Summary

Constructors

Constructor	Description
TopicConfiguration()
TopicConfiguration(String topicName, int potentialReductionPercentage, long dailyWritesBytes, Map<String,Object> optimizedConfiguration)

Method Summary

Modifier and Type	Method	Description
long	calculateImpactScore()	Calculate the potential impact of optimization for this topic.
boolean	equals(Object o)
long	getDailyWritesBytes()
Map<String,Object>	getOptimizedConfiguration()
int	getPotentialReductionPercentage()
String	getTopicName()
int	hashCode()
void	setDailyWritesBytes(long dailyWritesBytes)
void	setOptimizedConfiguration(Map<String,Object> optimizedConfiguration)
void	setPotentialReductionPercentage(int potentialReductionPercentage)
void	setTopicName(String topicName)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

TopicConfiguration

public TopicConfiguration()

TopicConfiguration

public TopicConfiguration(String topicName,
 int potentialReductionPercentage,
 long dailyWritesBytes,
 Map<String,Object> optimizedConfiguration)

Method Details

getTopicName

public String getTopicName()

setTopicName

public void setTopicName(String topicName)

getPotentialReductionPercentage

public int getPotentialReductionPercentage()

setPotentialReductionPercentage

public void setPotentialReductionPercentage(int potentialReductionPercentage)

getDailyWritesBytes

public long getDailyWritesBytes()

setDailyWritesBytes

public void setDailyWritesBytes(long dailyWritesBytes)

getOptimizedConfiguration

public Map<String,Object> getOptimizedConfiguration()

setOptimizedConfiguration

public void setOptimizedConfiguration(Map<String,Object> optimizedConfiguration)

calculateImpactScore

public long calculateImpactScore()

Calculate the potential impact of optimization for this topic.

Returns:

The impact score, calculated as potentialReductionPercentage * dailyWritesBytes

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