Technoboy- commented on a change in pull request #11564:
URL: https://github.com/apache/pulsar/pull/11564#discussion_r693290971
##
File path:
pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactorMXBeanImpl.java
##
@@ -0,0 +1,93 @@
+/**
+ * Licensed to the Apache S
Technoboy- commented on a change in pull request #11564:
URL: https://github.com/apache/pulsar/pull/11564#discussion_r693290940
##
File path:
pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/policies/data/CompactionStats.java
##
@@ -0,0 +1,37 @@
+/**
+ * Licensed
Technoboy- commented on a change in pull request #11564:
URL: https://github.com/apache/pulsar/pull/11564#discussion_r691985618
##
File path:
pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactorMXBeanImpl.java
##
@@ -0,0 +1,124 @@
+/**
+ * Licensed to the Apache
Technoboy- commented on a change in pull request #11564:
URL: https://github.com/apache/pulsar/pull/11564#discussion_r691963717
##
File path:
pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/policies/data/CompactStats.java
##
@@ -0,0 +1,37 @@
+/**
+ * Licensed to
Technoboy- commented on a change in pull request #11564:
URL: https://github.com/apache/pulsar/pull/11564#discussion_r689972100
##
File path:
pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactorMXBeanImpl.java
##
@@ -0,0 +1,125 @@
+/**
+ * Licensed to the Apache
Technoboy- commented on a change in pull request #11564:
URL: https://github.com/apache/pulsar/pull/11564#discussion_r689972100
##
File path:
pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactorMXBeanImpl.java
##
@@ -0,0 +1,125 @@
+/**
+ * Licensed to the Apache
Technoboy- commented on a change in pull request #11564:
URL: https://github.com/apache/pulsar/pull/11564#discussion_r689967367
##
File path:
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
##
@@ -1903,9 +1905,28 @@ public TopicStat
Technoboy- commented on a change in pull request #11564:
URL: https://github.com/apache/pulsar/pull/11564#discussion_r689967293
##
File path:
pulsar-broker/src/main/java/org/apache/pulsar/compaction/TwoPhaseCompactor.java
##
@@ -145,14 +149,17 @@ private void phaseOneLoop(RawR
Technoboy- commented on a change in pull request #11564:
URL: https://github.com/apache/pulsar/pull/11564#discussion_r689964478
##
File path:
pulsar-broker/src/main/java/org/apache/pulsar/compaction/TwoPhaseCompactor.java
##
@@ -145,14 +149,17 @@ private void phaseOneLoop(RawR
Technoboy- commented on a change in pull request #11564:
URL: https://github.com/apache/pulsar/pull/11564#discussion_r689963705
##
File path:
pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactorMXBeanImpl.java
##
@@ -0,0 +1,125 @@
+/**
+ * Licensed to the Apache
Technoboy- commented on a change in pull request #11564:
URL: https://github.com/apache/pulsar/pull/11564#discussion_r689111684
##
File path:
pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactorMXBeanImpl.java
##
@@ -0,0 +1,71 @@
+/**
+ * Licensed to the Apache S
Technoboy- commented on a change in pull request #11564:
URL: https://github.com/apache/pulsar/pull/11564#discussion_r689111490
##
File path:
pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactorMXBeanImpl.java
##
@@ -0,0 +1,71 @@
+/**
+ * Licensed to the Apache S
Technoboy- commented on a change in pull request #11564:
URL: https://github.com/apache/pulsar/pull/11564#discussion_r689102490
##
File path:
pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactorMXBean.java
##
@@ -0,0 +1,51 @@
+/**
+ * Licensed to the Apache Softw
Technoboy- commented on a change in pull request #11564:
URL: https://github.com/apache/pulsar/pull/11564#discussion_r688603056
##
File path:
pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactorMXBeanImpl.java
##
@@ -0,0 +1,60 @@
+/**
+ * Licensed to the Apache S
Technoboy- commented on a change in pull request #11564:
URL: https://github.com/apache/pulsar/pull/11564#discussion_r687285107
##
File path:
pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java
##
@@ -1327,7 +1327,11 @@ public Compactor newCompactor() throw
Technoboy- commented on a change in pull request #11564:
URL: https://github.com/apache/pulsar/pull/11564#discussion_r686503868
##
File path:
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
##
@@ -1809,9 +1811,25 @@ public TopicStat
Technoboy- commented on a change in pull request #11564:
URL: https://github.com/apache/pulsar/pull/11564#discussion_r686423836
##
File path:
pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/policies/data/CompactStats.java
##
@@ -0,0 +1,34 @@
+/**
+ * Licensed to
Technoboy- commented on a change in pull request #11564:
URL: https://github.com/apache/pulsar/pull/11564#discussion_r686422506
##
File path:
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
##
@@ -1809,9 +1811,25 @@ public TopicStat
18 matches
Mail list logo