This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from af3b546e41 refactor: Migrate modules home, info, login, notifications
and profile to control flow syntax (#3984)
add b814989fb5 refactor(#3927): migrate all data sinks from
streampipesdatasink to istreampipesdatasink (#3928)
No new revisions were added by this update.
Summary of changes:
.../connectors/influx/sink/InfluxDbSink.java | 56 ++++++++++---------
.../jvm/bufferrest/BufferRestPublisherSink.java | 48 ++++++++--------
.../sinks/brokers/jvm/jms/JmsPublisherSink.java | 56 ++++++++++---------
.../jvm/rabbitmq/RabbitMqPublisherSink.java | 51 +++++++++--------
.../sinks/databases/jvm/couchdb/CouchDbSink.java | 45 ++++++++-------
.../sinks/databases/jvm/ditto/DittoSink.java | 55 ++++++++++---------
.../sinks/databases/jvm/iotdb/IotDbSink.java | 55 ++++++++++---------
.../sinks/databases/jvm/milvus/MilvusSink.java | 52 ++++++++++--------
.../sinks/databases/jvm/parquet/ParquetSink.java | 54 +++++++++---------
.../databases/jvm/postgresql/PostgreSqlSink.java | 59 +++++++++++---------
.../sinks/databases/jvm/redis/RedisSink.java | 64 ++++++++++++----------
.../sinks/databases/jvm/tsfile/TsFileSink.java | 54 +++++++++---------
.../sinks/internal/jvm/datalake/DataLakeSink.java | 62 +++++++++++----------
.../InternalStreamPipesNotificationSink.java | 23 ++++++--
.../sinks/notifications/jvm/email/EmailSink.java | 25 +++++++--
.../notifications/jvm/msteams/MSTeamsSink.java | 25 +++++++--
.../notifications/jvm/onesignal/OneSignalSink.java | 23 ++++++--
.../jvm/slack/SlackNotificationSink.java | 23 ++++++--
.../notifications/jvm/telegram/TelegramSink.java | 23 ++++++--
.../standalone/StreamPipesNotificationSink.java | 50 ++++++++---------
20 files changed, 516 insertions(+), 387 deletions(-)
