这是一个Java的流式计算框架