Назначение
Этот блок представляет вход потока. Он выдаёт таблицу, переданную через «Вызвать поток» или «Вызов потоков». Один поток может иметь несколько таких входов. Параметры запуска передаются отдельно по имени и обрабатываются блоком «Параметры запуска».
Порты и схема
Входных портов нет; out передаёт данные следующим преобразованиям. fields задаёт ожидаемые столбцы; пустой список сохраняет все переданные поля. Имена должны быть уникальными и не длиннее 256 символов; не используйте зарезервированный префикс __bridge_ .
Другой способ запуска
direct=empty выдаёт пустую таблицу объявленных полей, если поток запущен не другим потоком. direct=refuse останавливает такой запуск с пояснением. Вызов подпотока выбирает свой вход; остальные входы получают пустые данные для этого вызова. Ранее сохранённое ограничение конкретным вызывающим потоком может сохраняться; панель показывает его и предлагает разрешить приём от любого потока.
Настройка входа
- Добавьте блок и назовите по назначению таблицы.
- Введите ожидаемые поля по одному на строку или примите список из обнаруженного вызывающего блока.
- Выберите пустые данные или отказ для других способов запуска.
- Подключите блоки обработки и опубликуйте.
- В родителе выберите этот вход, передайте таблицу и проверьте её схему.
Проверки контракта
Сохраните поток, чтобы увидеть другие блоки «Вызов потоков», запускающие его. Проверьте, передают ли они данные и какие поля. Одинаковые имена параметров и столбцов не делают их одним объектом. Пустой результат прямого запуска не доказывает отсутствия данных у родителя.
Пример общей обработки
Создайте вход «Sales» с Product, Period и Amount. Подключите нормализацию товаров, фильтр периода и группировку. Разные родители передают данные разных источников через этот контракт; выход подпотока возвращает единую структуру.