我正在尝试一个beam-google数据流管道示例，但是在mapeelements和方法singlefunction/serializablefunction调用方面遇到了一个异常。代码段如下所示：

static class ParseTableRowJson extends SimpleFunction<String, TableRow> {
    @Override
    public TableRow apply(String input) {
        try {
            return Transport.getJsonFactory().fromString(input, TableRow.class);
        } catch (IOException e) {
            throw new RuntimeException("Failed parsing table row json", e);
        }
    }
}
......
p.apply(TextIO.read().from(options.getInput()))
                .apply(MapElements.via(new ParseTableRowJson()))
                .apply(new ComputeTopSessions(samplingThreshold))
                .apply("Write", 
TextIO.write().withoutSharding().to(options.getOutput()));

例外情况是对以下方法的调用不明确：

Ambiguous method call. Both
via (SimpleFunction<String, TableRow>) in MapElements and
via (SerializableFunction)             in MapElements match

是否有其他人遇到了同样的例外情况并找到了解决办法？
完整的例子在github中(https://github.com/apache/beam/blob/master/examples/java/src/main/java/org/apache/beam/examples/complete/topwikipediasessions.java).
谢谢，
费尔南多