В StreamPipes элементы конвейера являются автономными компонентами (можно вспомнить микросервисы, которые содержат логику обработки процессора данных или приемника данных).Элементы конвейера инкапсулируют свои зависимости и полагаются на одну из нескольких доступных оболочек времени выполнения (например, в кластере Apache Flink или в качестве оболочек JVM для одного хоста).
Элементы конвейера, установленные по умолчанию, можно найти на Github .Файл README содержит краткое описание каждого элемента конвейера.
Вы также можете использовать встроенный SDK для создания своих собственных элементов конвейера, см. Учебник для быстрого ознакомления.
Надеюсь, что этопомогает!