def sampleProto[T <: AbstractMessage: ClassTag]()

in ratatool-sampling/src/main/scala/com/spotify/ratatool/samplers/package.scala [179:205]

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

  def sampleProto[T <: AbstractMessage: ClassTag](
    coll: SCollection[T],
    fraction: Double,
    fields: Seq[String] = Seq(),
    seed: Option[Int] = None,
    hashAlgorithm: HashAlgorithm = FarmHash,
    distribution: Option[SampleDistribution] = None,
    distributionFields: Seq[String] = Seq(),
    precision: Precision = Approximate,
    maxKeySize: Int = 1e6.toInt,
    byteEncoding: ByteEncoding = RawEncoding
  ): SCollection[T] = {
    BigSampler.sample(
      coll,
      fraction,
      fields,
      seed,
      hashAlgorithm,
      distribution,
      distributionFields,
      precision,
      BigSamplerProto.hashProtobufField,
      BigSamplerProto.buildKey(distributionFields),
      maxKeySize,
      byteEncoding
    )
  }