Skip to content

Commit 3ecf4d0

Browse files
committed
fix fill/histogrammar method
1 parent c712d2d commit 3ecf4d0

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

sparksql/src/main/scala/org/dianahep/histogrammar/sparksql.scala

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -135,6 +135,8 @@ package sparksql.pyspark {
135135
class AggregatorConverter {
136136
type Agg = C forSome {type C <: Container[C] with Aggregation{type Datum >: Row}}
137137

138+
def histogrammar[CONTAINER <: Container[CONTAINER] with Aggregation{type Datum = Row}](df: DataFrame, container: CONTAINER) = df.histogrammar(container)(ClassTag(container.getClass))
139+
138140
def Average(quantity: Column) = org.dianahep.histogrammar.Average[Row](quantity)
139141

140142
def Bag(quantity: Column, range: String) = range match {

0 commit comments

Comments
 (0)