1、你红色部分的loop为何是2，我是这么理解（猜测）的。loop了多少次其实就是调用了多少次Next，不管这个Next成功获取数据还是失败，因为这个loop累加发生在Next函数的defer里面。当第一次调用Next的时候返回一行记录，但是这个时候并没有结束，下次调用Next的时候底层返回报错没有数据，然后close掉所有算子。
2、StreamAgg没有父算子，它的调用者就是连接不停的获取数据即不停的调用StreamAgg的Next返回chunk数据。
1、你红色部分的loop为何是2，我是这么理解（猜测）的。loop了多少次其实就是调用了多少次Next，不管这个Next成功获取数据还是失败，因为这个loop累加发生在Next函数的defer里面。当第一次调用Next的时候返回一行记录，但是这个时候并没有结束，下次调用Next的时候底层返回报错没有数据，然后close掉所有算子。
2、StreamAgg没有父算子，它的调用者就是连接不停的获取数据即不停的调用StreamAgg的Next返回chunk数据。