def setDefaultValuesInTracker()

in core/src/main/scala/org/apache/spark/eventhubs/PartitionsStatusTracker.scala [249:261]

• 13 lines of code
• 1 McCabe index (conditional complexity)

  def setDefaultValuesInTracker(numOfPartitions: Int,
                                pContext: PartitionContext,
                                maxBatchReceiveTime: Long,
                                throttlingSP: Option[ThrottlingStatusPlugin]) = {
    partitionContext = pContext
    partitionsCount = numOfPartitions
    acceptableBatchReceiveTimeInMs = maxBatchReceiveTime
    enoughUpdatesCount = (partitionsCount / 2) + 1
    throttlingStatusPlugin = throttlingSP
    defaultPartitionsPerformancePercentage = Some(
      (for (pid <- 0 until partitionsCount)
        yield (NameAndPartition(pContext.eventHubName, pid), 1.0))(breakOut))
  }