THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
CDCConsumer public API interface:
Code Block | ||||||
---|---|---|---|---|---|---|
| ||||||
/** Consumer of WAL records */ public interface CDCConsumer { /** * @return Consumer ID. */ String id(); /** * Initialize this consumer. * * @param configuration Ignite configuration. */ void start(IgniteConfiguration configuration, IgniteLogger log); /** * @param record WAL record. * @param <T> Record type. * @return {@code True} if state of the consumption should be saved. */ <T extends WALRecord> booolean onRecord(T record); /** * Stops this consumer. * This methods can be invoked only after {@link #start(IgniteConfiguration, IgniteLogger)}. */ void stop(); } |
...