scala中实现这样的事情，一个arraybuffer接收一行数据。1.这个buffer的长度达到定长如300，提交一次，清零继续。2.一定时间，如1分钟后，长度不到300，也提交一次，清零继续。如果1分钟内到了300，就提交，并重新计时。试了几种办法都不行，请高手指教，谢谢