Мой вариант использования такой. У меня есть несколько X-таблиц, которые нужно извлечь из MySQL. Я разделяю их с помощью SplitText
, чтобы поместить каждую таблицу в отдельный файл потока и извлекать с помощью GenerateTableFetch
и ExecuteSQL
.
И я хочу получить уведомление или выполнить какое-либо другое действие, когда импорт будет выполнен для всех таблиц. В текстовом процессоре SplitText
я перенаправил original
отношение к Wait
на ${filename}
с целевым количеством ${fragment.count}
. Это будет отслеживать, сколько таблиц сделано.
Но теперь я не могу понять, как узнать, когда конкретная таблица сделана. GenerateTableFetch
разветвляет файл потока на несколько в зависимости от размера раздела. Но он не записывает такие атрибуты, как fragment.count, которые я могу использовать для ожидания каждой таблицы.
Есть ли способ добиться этого? Или, может быть, есть способ узнать в конце всего потока, были ли обработаны все файлы потока в потоке, и ничего не находится в очереди или не обрабатывается?