Подскажите, пожалуйста, как читать из Hive через Apache beam и сохранять его в формате строки PCollection?
Вы можете использовать HCatalogIO I / O для чтения и записи данных из Hive. Более подробную информацию можно найти здесь
HCatalogIO