• 如果您觉得本站非常有看点,那么赶紧使用Ctrl+D 收藏吧

标签:beam

apache-beam

PCollection的笛卡尔积与自身

PCollection的笛卡尔积与自身
假设我有一个KV<String, Integer>类型的有界PCollection p。假定p无法容纳在内存中,因此不能是DoFn的侧面输入。 示例p: ("foo", 0) ("bar", 1) ("baz", 2) 我该如何取p及其自身的笛卡尔积? 例如, p x p可能如下所示: ("foo+foo", [("foo", 0), ("……继续阅读 »