Я знаю, что в настоящее время порядка нет в BeamSQL, есть ли обходной путь для этого

Question

Это присутствует

PCollection<BeamRecord> rec = rec_out.apply(BeamSql.query(
  "SELECT bnk_name,state_name,val from PCOLLECTION order by val desc limit 2"));

Но мне нужно

PCollection<BeamRecord> rec = rec_out.apply(BeamSql.query(
  "SELECT bnk_name,state_name,val from PCOLLECTION order by val desc "));

Answer 1

Это на самом деле не поможет.PCollections неупорядочены в Beam, поэтому вы не можете применить порядок ко всему выводу.

Beam не имеет порядка, потому что это обычно не нужно, часто невозможно.Большинство проблем, где используется упорядочение, имеют другое решение, которое не требует глобальной сортировки.

Если вы опишете больше о том, что вы будете делать с выводом SQL-запроса, я обновлю свой ответ советом.

Если вы не можете поделиться больше, тогда у вас есть возможность использовать расширение сортировщика Beam вне SQL-запроса, но опять-таки оно не для глобальной сортировки, а для порядка ключей после тасования.