public interface SampleStore extends CruiseControlConfigurable, AutoCloseable
Modifier and Type | Interface and Description |
---|---|
static class |
SampleStore.SampleLoader
A class that will be constructed by Kafka Cruise Control and used by sample store during sample loading time.
|
Modifier and Type | Method and Description |
---|---|
void |
close()
Close the sample store.
|
void |
evictSamplesBefore(long timestamp)
This method is called when a workload snapshot window is evicted.
|
void |
loadSamples(SampleStore.SampleLoader sampleLoader)
Load the samples from the sample store.
|
double |
sampleLoadingProgress()
Get the sample loading progress.
|
void |
storeSamples(MetricSampler.Samples samples)
Store all the samples to the sample store.
|
configure
void storeSamples(MetricSampler.Samples samples)
samples
- the samples to store.void loadSamples(SampleStore.SampleLoader sampleLoader)
sampleLoader
- the sample loader that takes in samples.double sampleLoadingProgress()
void evictSamplesBefore(long timestamp)
timestamp
- the timestamp of the snapshot window that has just been evicted.void close()
close
in interface AutoCloseable