Package org.apache.ignite.cdc
Class CdcConfiguration
- java.lang.Object
- 
- org.apache.ignite.cdc.CdcConfiguration
 
- 
 public class CdcConfiguration extends Object This class definesCdcMainruntime configuration. Configuration is passed toCdcMainconstructor.
- 
- 
Constructor SummaryConstructors Constructor Description CdcConfiguration()
 - 
Method SummaryAll Methods Instance Methods Concrete Methods Modifier and Type Method Description longgetCheckFrequency()CdcConsumergetConsumer()longgetLockTimeout()MetricExporterSpi[]getMetricExporterSpi()Gets fully configured metric SPI implementations.booleanisKeepBinary()voidsetCheckFrequency(long checkFreq)voidsetConsumer(CdcConsumer consumer)voidsetKeepBinary(boolean keepBinary)voidsetLockTimeout(long lockTimeout)voidsetMetricExporterSpi(MetricExporterSpi... metricExporterSpi)Sets fully configured instances ofMetricExporterSpi.
 
- 
- 
- 
Method Detail- 
getConsumerpublic CdcConsumer getConsumer() - Returns:
- CDC consumer.
 
 - 
setConsumerpublic void setConsumer(CdcConsumer consumer) - Parameters:
- consumer- CDC consumer.
 
 - 
setMetricExporterSpipublic void setMetricExporterSpi(MetricExporterSpi... metricExporterSpi) Sets fully configured instances ofMetricExporterSpi.JmxMetricExporterSpiis used by default.- Parameters:
- metricExporterSpi- Fully configured instances of- MetricExporterSpi.
- See Also:
- getMetricExporterSpi(),- JmxMetricExporterSpi
 
 - 
getMetricExporterSpipublic MetricExporterSpi[] getMetricExporterSpi() Gets fully configured metric SPI implementations.JmxMetricExporterSpiis used by default.- Returns:
- Metric exporter SPI implementations.
- See Also:
- JmxMetricExporterSpi
 
 - 
isKeepBinarypublic boolean isKeepBinary() - Returns:
- keep binary value.
 
 - 
setKeepBinarypublic void setKeepBinary(boolean keepBinary) - Parameters:
- keepBinary- keep binary value.
 
 - 
getLockTimeoutpublic long getLockTimeout() - Returns:
- Amount of time to wait for lock acquisition.
 
 - 
setLockTimeoutpublic void setLockTimeout(long lockTimeout) - Parameters:
- lockTimeout- Amount of time to wait for lock acquisition.
 
 - 
getCheckFrequencypublic long getCheckFrequency() - Returns:
- Amount of time application sleeps between subsequent checks when no new files available.
 
 - 
setCheckFrequencypublic void setCheckFrequency(long checkFreq) - Parameters:
- checkFreq- Amount of time application sleeps between subsequent checks when no new files available.
 
 
- 
 
-