[streampipes] branch dev updated (7bd5f3e62 -> 58f920d0d)

[bo...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

bossenti pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/streampipes.git


    from 7bd5f3e62 ci: run e2e tests only when linting succeeds
     add 58f920d0d Add checkstyle to streampipes-wrapper-* modules (#820) (#883)

No new revisions were added by this update.

Summary of changes:
 .../processor/textfilter/TextFilterProcessor.java  |   2 +-
 streampipes-wrapper-distributed/pom.xml            |  11 +-
 .../distributed/runtime/DistributedRuntime.java    |  42 ++--
 streampipes-wrapper-flink/pom.xml                  |  11 +-
 .../wrapper/flink/FlinkDataProcessorDeclarer.java  |   4 +-
 .../wrapper/flink/FlinkDataProcessorRuntime.java   |  32 +--
 .../wrapper/flink/FlinkDataSinkDeclarer.java       |   4 +-
 .../wrapper/flink/FlinkDataSinkRuntime.java        |  15 +-
 .../flink/FlinkMiniClusterDeploymentConfig.java    |   6 +-
 .../streampipes/wrapper/flink/FlinkRuntime.java    |  78 ++++----
 .../wrapper/flink/FlinkSpMiniCluster.java          |   8 +-
 .../wrapper/flink/consumer/JmsFlinkConsumer.java   |   7 +-
 .../wrapper/flink/consumer/MqttFlinkConsumer.java  |   5 +-
 .../flink/converter/EventToMapConverter.java       |   5 +-
 .../flink/converter/MapToEventConverter.java       |  13 +-
 .../wrapper/flink/logger/StatisticLogger.java      |  23 ++-
 .../flink/serializer/ByteArrayDeserializer.java    |   3 +-
 .../flink/serializer/ByteArraySerializer.java      |   3 +-
 .../flink/serializer/SimpleJmsSerializer.java      |  34 ++--
 .../wrapper/flink/sink/JmsFlinkProducer.java       |   7 +-
 .../wrapper/flink/sink/MqttFlinkProducer.java      |   7 +-
 .../flink/status/PipelineElementStatusSender.java  |   3 +-
 .../status/PipelineElementStatusSenderFactory.java |  10 +-
 streampipes-wrapper-kafka-streams/pom.xml          |  11 +-
 .../kafka/KafkaStreamsDataProcessorDeclarer.java   |   4 +-
 .../kafka/KafkaStreamsDataProcessorRuntime.java    |  27 +--
 .../kafka/KafkaStreamsDataSinkDeclarer.java        |   4 +-
 .../wrapper/kafka/KafkaStreamsDataSinkRuntime.java |   6 +-
 .../wrapper/kafka/KafkaStreamsRuntime.java         |  22 +-
 .../wrapper/kafka/converter/JsonToMapFormat.java   |   7 +-
 streampipes-wrapper-python/README.md               |  22 +-
 streampipes-wrapper-python/pom.xml                 |  14 +-
 .../streampipes/api/templates/index.html           |  19 +-
 streampipes-wrapper-standalone/pom.xml             |  43 ++--
 .../AbstractConfiguredPipelineElement.java         |  14 +-
 .../standalone/ConfiguredEventProcessor.java       |   6 +-
 .../wrapper/standalone/ConfiguredEventSink.java    |   5 +-
 .../ConfiguredExternalEventProcessor.java          |   8 +-
 .../standalone/ConfiguredExternalEventSink.java    |   6 +-
 .../standalone/StreamPipesDataProcessor.java       |   6 +-
 .../wrapper/standalone/StreamPipesDataSink.java    |   3 +-
 .../StreamPipesExternalDataProcessor.java          | 222 +++++++++++----------
 .../StandaloneEventProcessingDeclarer.java         |  21 +-
 .../StandaloneEventProcessorDeclarerSingleton.java |  27 ++-
 .../declarer/StandaloneEventSinkDeclarer.java      |  20 +-
 .../StandaloneEventSinkDeclarerSingleton.java      |  20 +-
 .../StandaloneExternalEventProcessingDeclarer.java |  26 ++-
 .../StandaloneExternalEventSinkDeclarer.java       |  29 ++-
 .../standalone/function/StreamPipesFunction.java   |   3 +-
 .../standalone/manager/ProtocolManager.java        |  30 +--
 .../standalone/routing/StandaloneSpCollector.java  |  12 +-
 .../routing/StandaloneSpInputCollector.java        |  12 +-
 .../routing/StandaloneSpOutputCollector.java       |  11 +-
 .../runtime/StandaloneEventProcessorRuntime.java   |  11 +-
 .../runtime/StandaloneEventSinkRuntime.java        |  11 +-
 .../StandaloneExternalEventProcessorRuntime.java   |  10 +-
 .../StandaloneExternalEventSinkRuntime.java        |   9 +-
 .../runtime/StandalonePipelineElementRuntime.java  |  24 +--
 streampipes-wrapper/pom.xml                        |  81 ++++----
 .../context/SpEventProcessorRuntimeContext.java    |   2 +-
 .../wrapper/context/SpEventSinkRuntimeContext.java |   2 +-
 .../wrapper/declarer/EventProcessorDeclarer.java   |  31 +--
 .../wrapper/declarer/EventSinkDeclarer.java        |   8 +-
 .../wrapper/declarer/PipelineElementDeclarer.java  |  22 +-
 .../wrapper/params/binding/BindingParams.java      |  21 +-
 .../binding/EventProcessorBindingParams.java       |  13 +-
 .../wrapper/params/binding/InputStreamParams.java  |   6 +-
 .../wrapper/params/binding/OutputStreamParams.java |   4 +-
 .../runtime/EventProcessorRuntimeParams.java       |   6 +-
 .../params/runtime/EventSinkRuntimeParams.java     |   6 +-
 .../wrapper/params/runtime/RuntimeParams.java      |  24 +--
 .../wrapper/routing/PipelineElementCollector.java  |   4 +-
 .../wrapper/routing/SpInputCollector.java          |   2 +-
 .../wrapper/routing/SpOutputCollector.java         |   2 +-
 .../wrapper/runtime/EventProcessor.java            |   9 +-
 .../streampipes/wrapper/runtime/EventSink.java     |   8 +-
 .../wrapper/runtime/ExternalEventProcessor.java    |   8 +-
 .../wrapper/runtime/ExternalEventSink.java         |   8 +-
 .../wrapper/runtime/PipelineElement.java           |   4 +-
 .../wrapper/runtime/PipelineElementRuntime.java    |   3 +-
 tools/maven/suppressions.xml                       |   1 -
 81 files changed, 738 insertions(+), 595 deletions(-)