File tree 1 file changed +5
-6
lines changed
hub/src/main/scala/ai/chronon/hub/handlers 1 file changed +5
-6
lines changed Original file line number Diff line number Diff line change @@ -119,18 +119,17 @@ class TimeSeriesHandler(driftStore: DriftStore) {
119
119
// check if we have a numeric / categorical feature. If the percentile drift series has non-null doubles
120
120
// then we have a numeric feature at hand
121
121
val isNumeric =
122
- Option (tileDriftSeries.percentileDriftSeries).exists(series =>
123
- series.asScala.exists(_ != null ))
124
-
122
+ Option (tileDriftSeries.percentileDriftSeries).exists(series => series.asScala.exists(_ != null ))
123
+
125
124
val lhsList = if (metric == NullMetric ) {
126
125
Option (tileDriftSeries.nullRatioChangePercentSeries).map(_.asScala).getOrElse(Seq .empty)
127
126
} else {
128
- if (isNumeric)
127
+ if (isNumeric)
129
128
Option (tileDriftSeries.percentileDriftSeries).map(_.asScala).getOrElse(Seq .empty)
130
- else
129
+ else
131
130
Option (tileDriftSeries.histogramDriftSeries).map(_.asScala).getOrElse(Seq .empty)
132
131
}
133
-
132
+
134
133
val points = lhsList.zip(tileDriftSeries.timestamps.asScala).map {
135
134
case (v, ts) => TimeSeriesPoint (v, ts)
136
135
}
You can’t perform that action at this time.
0 commit comments