Имена отдельных блоков#

Каждый блок файла .conf имеет поле name. Задает имя блока.

Пример:

# Блок агрегации
  aggregationStep: {
    name: "aggregation step for transfer card to card" # Это имя данного блока
    ...
  }

Имена должны быть содержательными и включать в себя имя потока/интеграции (поле name блока flow), так как при возникновении ошибок Flink логирует только имя блока, на котором она произошла.

Имена блоков применяются при ветвлениях потока. Для этого в файле трансформации используется структура headers.BranchName.

Пример:

headers[0].BranchName = "aggregation step for transfer card to card" # Указанная строковая константа впоследствии сравнивается с именами блоков, чтобы узнать, по какой ветви потока нужно направить сообщение