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 Summary
Constructors Constructor Description CdcConfiguration()
-
Method Summary
All 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
-
getConsumer
public CdcConsumer getConsumer()
- Returns:
- CDC consumer.
-
setConsumer
public void setConsumer(CdcConsumer consumer)
- Parameters:
consumer- CDC consumer.
-
setMetricExporterSpi
public void setMetricExporterSpi(MetricExporterSpi... metricExporterSpi)
Sets fully configured instances ofMetricExporterSpi.JmxMetricExporterSpiis used by default.- Parameters:
metricExporterSpi- Fully configured instances ofMetricExporterSpi.- See Also:
getMetricExporterSpi(),JmxMetricExporterSpi
-
getMetricExporterSpi
public MetricExporterSpi[] getMetricExporterSpi()
Gets fully configured metric SPI implementations.JmxMetricExporterSpiis used by default.- Returns:
- Metric exporter SPI implementations.
- See Also:
JmxMetricExporterSpi
-
isKeepBinary
public boolean isKeepBinary()
- Returns:
- keep binary value.
-
setKeepBinary
public void setKeepBinary(boolean keepBinary)
- Parameters:
keepBinary- keep binary value.
-
getLockTimeout
public long getLockTimeout()
- Returns:
- Amount of time to wait for lock acquisition.
-
setLockTimeout
public void setLockTimeout(long lockTimeout)
- Parameters:
lockTimeout- Amount of time to wait for lock acquisition.
-
getCheckFrequency
public long getCheckFrequency()
- Returns:
- Amount of time application sleeps between subsequent checks when no new files available.
-
setCheckFrequency
public void setCheckFrequency(long checkFreq)
- Parameters:
checkFreq- Amount of time application sleeps between subsequent checks when no new files available.
-
-