Skip to content

Commit

Permalink
Fix the scalastyle issue
Browse files Browse the repository at this point in the history
  • Loading branch information
Reza Safi committed Aug 24, 2018
1 parent f37b7e8 commit 2b0b1ce
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,7 @@ private class DefaultPerPartitionConfig(conf: SparkConf)
extends PerPartitionConfig {
val maxRate = conf.getLong("spark.streaming.kafka.maxRatePerPartition", 0)
val minRate = conf.getLong("spark.streaming.kafka.minRatePerPartition", 1)

def maxRatePerPartition(topicPartition: TopicPartition): Long = maxRate
def minRatePerPartition(topicPartition: TopicPartition): Long = minRate
}

0 comments on commit 2b0b1ce

Please sign in to comment.