You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gobblin.apache.org by su...@apache.org on 2020/03/31 20:08:44 UTC
[incubator-gobblin] branch master updated:
[GOBBLIN-1100][GOBBLIN-1104] Change access modifier for
generateTagsForPartitions to accomodate with []
This is an automated email from the ASF dual-hosted git repository.
suvasude pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-gobblin.git
The following commit(s) were added to refs/heads/master by this push:
new 112e455 [GOBBLIN-1100][GOBBLIN-1104] Change access modifier for generateTagsForPartitions to accomodate with []
112e455 is described below
commit 112e455dc6a4fd171a6bc3d4c2f7ee720eae2f3e
Author: Lei Sun <le...@linkedin.com>
AuthorDate: Tue Mar 31 13:08:34 2020 -0700
[GOBBLIN-1100][GOBBLIN-1104] Change access modifier for generateTagsForPartitions to accomodate with []
Closes #2944 from autumnust/accessLevel
---
.../source/extractor/extract/kafka/KafkaExtractorStatsTracker.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaExtractorStatsTracker.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaExtractorStatsTracker.java
index 2913b54..103bfe0 100644
--- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaExtractorStatsTracker.java
+++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaExtractorStatsTracker.java
@@ -409,8 +409,7 @@ public class KafkaExtractorStatsTracker {
/**
* A helper function to merge tags for KafkaPartition. Separate into a package-private method for ease of testing.
*/
- @VisibleForTesting
- Map<KafkaPartition, Map<String, String>> generateTagsForPartitions(MultiLongWatermark lowWatermark, MultiLongWatermark highWatermark,
+ public Map<KafkaPartition, Map<String, String>> generateTagsForPartitions(MultiLongWatermark lowWatermark, MultiLongWatermark highWatermark,
MultiLongWatermark nextWatermark, Map<KafkaPartition, Map<String, String>> additionalTags) {
Map<KafkaPartition, Map<String, String>> tagsForPartitionsMap = Maps.newHashMap();
for (int i = 0; i < this.partitions.size(); i++) {