Jonatan Klock

clock is not working

6

**The groupByInterval is not working with clock.** **Code** clock = clocks.uniform(sqlContext, frequency="1day", offset="0ns", begin_date_time="2016-01-01", end_date_time="2017-01-01") intervalized = flint_ShipMode.groupByInterval(clock) print(type(ShipMode)) ShipMode.printSchema() ShipMode.count() class 'pyspark.sql.dataframe.DataFrame'> root |-- uid: string (nullable = true)...