public class JmxMetricsAnalyzer
extends java.lang.Object
Constructor and Description |
---|
JmxMetricsAnalyzer(java.util.Map<java.lang.Integer,java.lang.String> metricsFilenames,
org.apache.kafka.clients.admin.AdminClient adminClient,
java.lang.String topic,
int numPartitions,
boolean debug) |
Modifier and Type | Method and Description |
---|---|
boolean |
checkBytesFetchedFromLocalLog(int thresholdBytes)
Checks that the number of bytes fetched from a local log is within
the given threshold
|
java.util.Map<java.lang.Integer,java.lang.Long> |
checkTierSize()
Obtains a map of partition to tier size.
|
boolean |
checkZeroErrorPartitions()
Verifies the cluster state.
|
boolean |
tieringCompleted()
Determines whether tiering has completed by checking the following:
1.
|
boolean |
tieringStarted()
Checks whether tiering has started.
|
public JmxMetricsAnalyzer(java.util.Map<java.lang.Integer,java.lang.String> metricsFilenames, org.apache.kafka.clients.admin.AdminClient adminClient, java.lang.String topic, int numPartitions, boolean debug) throws java.io.IOException
java.io.IOException
public java.util.Map<java.lang.Integer,java.lang.Long> checkTierSize()
public boolean checkZeroErrorPartitions()
public boolean checkBytesFetchedFromLocalLog(int thresholdBytes)
public boolean tieringCompleted() throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
java.util.concurrent.ExecutionException
java.lang.InterruptedException
public boolean tieringStarted()