kotlin - 如何使用Apache Beam在Kotlin中扩展DoFn？

Question

尝试将Kotlin用于利用Apache Beam的应用程序，我得到以下警告:

 @ProcessElement processElement(String, OutputReceiver), parameter of type DoFn.OutputReceiver<Map<String, String>> at index 1: OutputReceiver should be parameterized by java.util.Map<java.lang.String, ? extends java.lang.String>

我假设它们在实现中的某个地方使用反射来确定所使用的特定类型。在Kotlin中有没有一种可以干净地使用它的方法？还是我需要围绕此类函数创建包装器以进行转换？

Answer 1

没有看到整个类很难做出响应，但是我认为可以通过使用别名导入java map来避免包装器。
import java.util.Map as JavaMap
然后返回一个JavaMap

内部的Apache光束反射仅考虑Java集合类型，因此Iterables或Collection等也可能发生这种情况。