This is an automated email from the ASF dual-hosted git repository.
timoninmaxim pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git
from e70b66c5deb IGNITE-21029 Updated log4j2 dependency to 2.22.0 version
(#11080)
add d053cb88048 IGNITE-17700 Introduce CdcManager (#11044)
No new revisions were added by this update.
Summary of changes:
.../ignite/internal/cdc/CdcConsumerState.java | 39 ++
.../org/apache/ignite/internal/cdc/CdcMain.java | 240 +++++++++---
.../org/apache/ignite/internal/cdc/CdcManager.java | 123 ++++++
.../org/apache/ignite/internal/cdc/CdcMode.java} | 19 +-
.../internal/cdc/CdcUtilityActiveCdcManager.java | 73 ++++
.../{CdcDataRecord.java => CdcManagerRecord.java} | 30 +-
...dcDataRecord.java => CdcManagerStopRecord.java} | 21 +-
.../internal/pagemem/wal/record/WALRecord.java | 8 +-
.../processors/cache/GridCacheProcessor.java | 27 ++
.../processors/cache/GridCacheSharedContext.java | 37 +-
.../IgniteCacheDatabaseSharedManager.java | 4 +
.../persistence/wal/FileWriteAheadLogManager.java | 6 +-
.../wal/filehandle/FileWriteHandleImpl.java | 42 ++-
.../wal/serializer/RecordDataV1Serializer.java | 34 ++
.../ignite/cdc/CdcIgniteNodeActiveModeTest.java | 394 +++++++++++++++++++
.../java/org/apache/ignite/cdc/CdcManagerTest.java | 415 +++++++++++++++++++++
.../java/org/apache/ignite/cdc/WalForCdcTest.java | 4 +
.../testframework/wal/record/RecordUtils.java | 18 +
.../ignite/testsuites/IgnitePdsTestSuite2.java | 4 +
19 files changed, 1425 insertions(+), 113 deletions(-)
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/cdc/CdcManager.java
copy
modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/agg/AggregateType.java
=> core/src/main/java/org/apache/ignite/internal/cdc/CdcMode.java} (75%)
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/cdc/CdcUtilityActiveCdcManager.java
copy
modules/core/src/main/java/org/apache/ignite/internal/pagemem/wal/record/{CdcDataRecord.java
=> CdcManagerRecord.java} (53%)
copy
modules/core/src/main/java/org/apache/ignite/internal/pagemem/wal/record/{CdcDataRecord.java
=> CdcManagerStopRecord.java} (66%)
create mode 100644
modules/core/src/test/java/org/apache/ignite/cdc/CdcIgniteNodeActiveModeTest.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/cdc/CdcManagerTest.java
