Луч Apache Join.leftOuterJoin, как передать пустой TableRow?
Я хочу выполнить leftOuterJoin на 2 таблицах BigQuery в Apache Beam (JAVA Sdk).
Читаю таблицы (
leftTableCollection
&rightTableCollection
) и имеют типPCollection<TableRow>
.Преобразовал их в форму
PCollection<KV<String, TableRow>>
т.е. <ключ соединения, строка-таблица>Я использую
Join.leftOuterJoin
изorg.apache.beam.sdk.extensions.joinlibrary.Join
`
PCollection<KV<String, TableRow>> leftTableKVCollection =
leftTableCollection.apply(ParDo.of(new ExtractLeftTableDoFn()));
PCollection<KV<String, TableRow>> rightTableKVCollection =
rightTableCollection.apply(ParDo.of(new ExtractRightTableDoFn()));
TableRow rightTableNullValues = ???
PCollection<KV<String, KV<TableRow, TableRow>>> joinKvResults =
Join.leftOuterJoin(leftTableKVCollection, rightTableKVCollection, rightTableNullValues);
`
Я не понимаю, за что сойти за
rightTableNullValues
здесь?
Пробовал с
new TableRow()
который бросает
unable to serialize
ошибка.
Любые предложения будут очень полезны. TIA