Вам следует рассмотреть возможность использования компонента tFlowToIterate
между tHDFSInput
и вспомогательным заданием с вашим tHiveInput
.
В приведенном ниже примере я генерирую поток, который содержит последовательность чисел, затем для каждого числа я делаю запрос к своей базе данных (я признаюсь, что это не tHiveInput, но я предполагаю, что это та же логика).
Вот конфигурация запроса, который я использую в моем tDBRow_1
:
Надеюсь, это поможет вам.