alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-8035 Move activity classes to distinct package

Browse Source
This commit is contained in:
Jiri Pechanec 2024-08-20 13:20:49 +02:00
parent 110d3f38c1
commit fca0fdb8c4
7 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
debezium-connector-sqlserver/src/main/java/io/debezium/connector/sqlserver/metrics/AbstractSqlServerPartitionMetrics.java
View File

@ -12,12 +12,12 @@
import io.debezium.connector.common.CdcSourceTaskContext; import io.debezium.connector.common.CdcSourceTaskContext;
import io.debezium.data.Envelope.Operation; import io.debezium.data.Envelope.Operation;
import io.debezium.metrics.Metrics; import io.debezium.metrics.Metrics;
import io.debezium.metrics.activity.ActivityMonitoringMeter;
import io.debezium.pipeline.ConnectorEvent; import io.debezium.pipeline.ConnectorEvent;
import io.debezium.pipeline.meters.CommonEventMeter; import io.debezium.pipeline.meters.CommonEventMeter;
import io.debezium.pipeline.source.spi.EventMetadataProvider; import io.debezium.pipeline.source.spi.EventMetadataProvider;
import io.debezium.pipeline.spi.OffsetContext; import io.debezium.pipeline.spi.OffsetContext;
import io.debezium.spi.schema.DataCollectionId; import io.debezium.spi.schema.DataCollectionId;
import io.debezium.transforms.ActivityMonitoringMeter;
/** /**
* Base implementation of partition-scoped multi-partition SQL Server connector metrics. * Base implementation of partition-scoped multi-partition SQL Server connector metrics.

2
debezium-connector-sqlserver/src/main/java/io/debezium/connector/sqlserver/metrics/SqlServerPartitionMetricsMXBean.java
View File

@ -5,9 +5,9 @@
*/ */
package io.debezium.connector.sqlserver.metrics; package io.debezium.connector.sqlserver.metrics;
import io.debezium.metrics.activity.ActivityMonitoringMXBean;
import io.debezium.pipeline.metrics.traits.CommonEventMetricsMXBean; import io.debezium.pipeline.metrics.traits.CommonEventMetricsMXBean;
import io.debezium.pipeline.metrics.traits.SchemaMetricsMXBean; import io.debezium.pipeline.metrics.traits.SchemaMetricsMXBean;
import io.debezium.transforms.ActivityMonitoringMXBean;
/** /**
* Metrics scoped to a source partition that are common for both snapshot and streaming change event sources * Metrics scoped to a source partition that are common for both snapshot and streaming change event sources

2
debezium-core/src/main/java/io/debezium/transforms/ActivityMonitoringMXBean.java → debezium-core/src/main/java/io/debezium/metrics/activity/ActivityMonitoringMXBean.java
View File

@ -3,7 +3,7 @@
* *
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
*/ */
package io.debezium.transforms; package io.debezium.metrics.activity;
import java.util.Map; import java.util.Map;

2
debezium-core/src/main/java/io/debezium/transforms/ActivityMonitoringMeter.java → debezium-core/src/main/java/io/debezium/metrics/activity/ActivityMonitoringMeter.java
View File

@ -3,7 +3,7 @@
* *
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
*/ */
package io.debezium.transforms; package io.debezium.metrics.activity;
import java.util.Map; import java.util.Map;
import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentHashMap;

2
debezium-core/src/main/java/io/debezium/pipeline/metrics/DefaultStreamingChangeEventSourceMetrics.java
View File

@ -13,6 +13,7 @@
import io.debezium.connector.base.ChangeEventQueueMetrics; import io.debezium.connector.base.ChangeEventQueueMetrics;
import io.debezium.connector.common.CdcSourceTaskContext; import io.debezium.connector.common.CdcSourceTaskContext;
import io.debezium.data.Envelope.Operation; import io.debezium.data.Envelope.Operation;
import io.debezium.metrics.activity.ActivityMonitoringMeter;
import io.debezium.pipeline.ConnectorEvent; import io.debezium.pipeline.ConnectorEvent;
import io.debezium.pipeline.meters.ConnectionMeter; import io.debezium.pipeline.meters.ConnectionMeter;
import io.debezium.pipeline.meters.StreamingMeter; import io.debezium.pipeline.meters.StreamingMeter;
@ -20,7 +21,6 @@
import io.debezium.pipeline.spi.OffsetContext; import io.debezium.pipeline.spi.OffsetContext;
import io.debezium.pipeline.spi.Partition; import io.debezium.pipeline.spi.Partition;
import io.debezium.spi.schema.DataCollectionId; import io.debezium.spi.schema.DataCollectionId;
import io.debezium.transforms.ActivityMonitoringMeter;
/** /**
* The default implementation of metrics related to the streaming phase of a connector. * The default implementation of metrics related to the streaming phase of a connector.

2
debezium-core/src/main/java/io/debezium/pipeline/metrics/StreamingChangeEventSourceMetricsMXBean.java
View File

@ -5,9 +5,9 @@
*/ */
package io.debezium.pipeline.metrics; package io.debezium.pipeline.metrics;
import io.debezium.metrics.activity.ActivityMonitoringMXBean;
import io.debezium.pipeline.metrics.traits.ConnectionMetricsMXBean; import io.debezium.pipeline.metrics.traits.ConnectionMetricsMXBean;
import io.debezium.pipeline.metrics.traits.StreamingMetricsMXBean; import io.debezium.pipeline.metrics.traits.StreamingMetricsMXBean;
import io.debezium.transforms.ActivityMonitoringMXBean;
/** /**
* Metrics specific to streaming change event sources * Metrics specific to streaming change event sources

2
debezium-core/src/test/java/io/debezium/transforms/ActivityMonitoringMeterTest.java → debezium-core/src/test/java/io/debezium/metrics/activity/ActivityMonitoringMeterTest.java
View File

@ -3,7 +3,7 @@
* *
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
*/ */
package io.debezium.transforms; package io.debezium.metrics.activity;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;