google-cloud-platform - 模式 PCollections 上的等值连接 - 不起作用

Question

我正在尝试根据 apache beam 文档（https://beam.apache.org/documentation/programming-guide/#transforms）加入两个 PCollection 交易和评论，如下所示

PCollection<Transaction> transactions = readTransactions();
PCollection<Review> reviews = readReviews();
PCollection<Row> joined = transactions.apply(
Join.innerJoin(reviews).using("userId", "productId"));

但是我遇到了编译错误，例如 apply needs apply(PTransform<? super PCollection, OutputT> t)

文档中的代码片段是正确的加入方式吗？请帮忙？

标签： google-cloud-platformcloudgoogle-cloud-dataflowapache-beam