spark structured streaming实现每30秒计算前30分钟的用户增长率

spark structured streaming实现每30秒计算前30分钟的用户增长率，spark structured stream是否可以实现？如何实现