相关疑难解决方法(0)

我正在关注这篇文章和文档的答案，以便在管道结束时对我的数据执行动态窗口写入。这是我到目前为止所拥有的：

static void applyWindowedWrite(PCollection<String> stream) {
    stream.apply(
        FileIO.<String, String>writeDynamic()
            .by(Event::getKey)
            .via(TextIO.sink())
            .to("gs://some_bucket/events/")
            .withNaming(key -> defaultNaming(key, ".json")));
}

但是 NetBeans 在最后一行警告我语法错误：

FileNaming is not public in Write; cannot be accessed outside package

如何使defaultNaming我的管道可用，以便我可以将其用于动态写入。或者，如果这不可能，我应该做什么？