java - 在 Apache Crunch 中，如何确定 PCollection 或 PTable 中是否包含任何元素？如果有，有多少？

Question

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

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

提前致谢。

Answer 1

与其依赖 PCollection.size() 方法来检查您的集合是否为空，您应该使用 PCollection.length()，它的作用正是你需要。