如何解决Apache Beam如何对文件使用TestStream
我有一个简单的管道,该管道仅将文件从源复制到目标。我正在尝试为设置的窗口编写测试。
是否可以使用TestStream类存储文件?
例如:
@Test
public void elementsAreInCorrectWindows() {
TestStream<FileIO.ReadableFile> testStream = TestStream.create(ReadableFileCoder.of())
.advanceWatermarkTo(start)
.addElements(readableFile1)
.advanceWatermarkTo(end)
.addElements(readableFile2)
.advanceWatermarkToInfinity();
}
但是ReadableFile的构造函数受到包装保护,因此我无法创建那些对象。
解决方法
我认为公开此Coder是合理的功能/请求。同时,您可以使用TestStream生成其他类型的元素,然后使用DoFn将其转换为ReadableFiles。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。