我有一个用例，我曾经通过流（kinesis）获取数据，并希望对其执行一些转换。在转换过程中，我需要查找mongodb/documentdb/redis，其中存储了我们的参考数据。我正在通过apachebeam实现这个用例。
我需要使用这些数据库（mongodb/documentdb/redis）中的集合/表作为辅助输入，这样我就可以加载它一次并从那里进行查找。我想一次加载所有记录，并使其可用于侧输入。
我试过了，但是我的错误率越来越低了-
样本代码-

final PCollectionView<Map<String, String>> mongoInput = pipeline.apply("Read from MongoDB", MongoDbIO.read().withUri("mongodb://URL")
                .withDatabase("dbname").withCollection("collection_name"))
                .apply("Document to String", ParDo.of(new MongoToKeyValueDoFn()))
                .apply("create a view for side input", View.<String, String>asMap());

在mongotokeyvaluedofn类中，我将键和值放入hashmap并发出它。
错误-

The method apply(String, PTransform<? super PCollection<Map<String,String>>,OutputT>) in the type PCollection<Map<String,String>> is not applicable for the arguments (String, View.AsMap<String,String>)

有人能告诉我在输入端加载数据吗？