def __init__()

in pydeequ/metrics.py [0:0]

• 10 lines of code
• 4 McCabe index (conditional complexity)

    def __init__(self, spark_session: SparkSession, kllResult):
        self._spark_session = spark_session
        self._kllResult = kllResult
        self._buckets = [
            BucketValue(self._kllResult.buckets().apply(b)) for b in range(self._kllResult.buckets().size())
        ]
        self._parameters = [
            float(self._kllResult.parameters().apply(p)) for p in range(self._kllResult.parameters().size())
        ]
        self._data = [list(d) for d in self._kllResult.data()]