Googleのデータフローでファイルを読み取るときに先頭行をスキップしています

Question

Googleのデータフローを使用してファイルを読み取っているときに先頭の行をスキップします。この機能は最新のバージョンで利用できますか？ ファイルはGoogleストレージに保存されています。 私は大きな質問にこれらのファイルを書いています。

bq loadコマンドには--skip_leading_rowsオプションがあります。このオプションは、ファイルから読み取るときに先頭の行をスキップします。

Googleのデータフローでこれと同様の機能が必要です。 私の入力は次の形式です。

私はGoogleのデータフローは、最初の行を無視して、この機能はデータフロー/パルドの中で直接サポートされていない大きなクエリに

Answer 1

を行だけ残りを書きたいです。

これを達成するには、Filter.byPredicate()を使用する必要があります。

PCollection<X> rows = ...; 
PCollection<X> nonHeaders = 
    rows.apply(Filter.by(new MatchIfNonHeader()));