0

我试图在监视窗口中放置一个断点并执行以下操作：检查 .getSize() 应该返回以字节为单位的大小。和 .materialize() 看看我是否可以查看 java 对象。

.getSize() 确实显示了一个 >0 的数字，但我怀疑这是否应该是 PTable 具有元素的指标。.materialize() 没有显示任何内容来表明元素的存在。

提前致谢。

4

2 回答 2

3

而不是依靠PCollection.size()方法来检查您的集合是否为空，您应该使用PCollection.length()，这正是您所需要的。

于 2014-11-11T13:53:54.660 回答
1

我有时会遇到这个问题，像物化这样的 API 方法并没有真正给出令人满意的结果。我建议创建一个简单的 DoFn，以这个 PCollection 作为输入并使用记录器来查看它是否有元素。并且 PCollection getSize() 方法将有助于了解它有多少元素。

于 2017-05-11T11:50:09.253 回答