为什么 DoFnTester 不再支持 finishBundle() 中的输出?
Why doesn't DoFnTester support outputs in finishBundle() any more?
我们有一些函数可以批量处理捆绑包中的元素。他们需要在 finishBundle() 方法中输出最后一批。
类似于 的回答中描述的内容。
在基于 Beam 0.4.0 的最新 Dataflow 2.0.0-beta1 版本中,如果被测函数调用上下文中的输出方法,DoFnTester 会从其 finishBundle() 方法中抛出 UnsupportedOperationException。
这种行为改变有什么原因吗?运行时是否不再支持 DoFn.finishBundle() 的输出?
这是 DoFnTester 中的回归。我已经针对 Beam here
提交了一个错误
我们有一些函数可以批量处理捆绑包中的元素。他们需要在 finishBundle() 方法中输出最后一批。
类似于
在基于 Beam 0.4.0 的最新 Dataflow 2.0.0-beta1 版本中,如果被测函数调用上下文中的输出方法,DoFnTester 会从其 finishBundle() 方法中抛出 UnsupportedOperationException。
这种行为改变有什么原因吗?运行时是否不再支持 DoFn.finishBundle() 的输出?
这是 DoFnTester 中的回归。我已经针对 Beam here
提交了一个错误