htran1 commented on a change in pull request #2804: GOBBLIN-955: Expose a method to get average record size in KafkaExtra… URL: https://github.com/apache/incubator-gobblin/pull/2804#discussion_r344804554
########## File path: gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaExtractorStatsTracker.java ########## @@ -43,6 +44,9 @@ public static final String TOPIC = "topic"; public static final String PARTITION = "partition"; + //Small values of exponential decay factor implies that recent values are weighted less heavily. + private static final Double EXPONENTIAL_DECAY_FACTOR = 0.125; Review comment: These are not used. ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
