You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ze...@apache.org on 2022/12/07 18:06:29 UTC
[streampipes] branch extension-modules-checkstyle-enablements updated (303387d37 -> 703208794)
This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a change to branch extension-modules-checkstyle-enablements
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from 303387d37 [hotfix] Add documentation assets to cusum and welford processor
add 81e081c43 Fix the checkstyle plugin doesn't fail on violation
add d8687e56f Set inherited of parent pom to false
add 03dc0cfcf Merge branch 'dev' into extension-modules-checkstyle-enablements
add 83a51757d [#820] enable checkstyle for adapters in extensions
add fd20ba661 [hotfix] Update checkstyle plugin as described in #851
add 425ccdbe4 Merge branch 'dev' into extension-modules-checkstyle-enablements
add 703208794 [#820] Fix final checkstyle issues in extensions module
No new revisions were added by this update.
Summary of changes:
pom.xml | 5 +-
streampipes-extensions/pom.xml | 3 -
.../streampipes-connect-adapters-iiot/pom.xml | 7 +-
.../connect/iiot/ConnectAdapterIiotInit.java | 63 +-
.../connect/iiot/adapters/PullAdapter.java | 120 ++--
.../connect/iiot/adapters/PullRestAdapter.java | 65 +-
.../iiot/adapters/influxdb/InfluxDbClient.java | 493 ++++++++--------
.../iiot/adapters/influxdb/InfluxDbSetAdapter.java | 256 ++++----
.../adapters/influxdb/InfluxDbStreamAdapter.java | 306 +++++-----
.../opcua/MiloOpcUaConfigurationProvider.java | 52 +-
.../connect/iiot/adapters/opcua/OpcNode.java | 195 +++---
.../connect/iiot/adapters/opcua/OpcUaAdapter.java | 412 ++++++-------
.../iiot/adapters/opcua/OpcUaNodeBrowser.java | 18 +-
.../connect/iiot/adapters/opcua/SpOpcUaClient.java | 228 +++----
.../opcua/configuration/SpOpcUaConfig.java | 68 ++-
.../opcua/configuration/SpOpcUaConfigBuilder.java | 46 +-
.../adapters/opcua/utils/OpcUaNodeVariants.java | 39 +-
.../iiot/adapters/opcua/utils/OpcUaTypes.java | 57 +-
.../iiot/adapters/opcua/utils/OpcUaUtil.java | 35 +-
.../adapters/plc4x/modbus/ModbusConfigFile.java | 78 +--
.../adapters/plc4x/modbus/Plc4xModbusAdapter.java | 590 +++++++++---------
.../plc4x/passive/Plc4xPassiveAdapter.java | 157 ++---
.../iiot/adapters/plc4x/s7/Plc4xS7Adapter.java | 568 +++++++++---------
.../iiot/adapters/ros/RosBridgeAdapter.java | 326 +++++-----
.../simulator/machine/MachineDataSimulator.java | 235 ++++----
.../machine/MachineDataSimulatorUtils.java | 205 +++----
.../machine/MachineDataStreamAdapter.java | 99 ++--
.../connect/iiot/protocol/set/FileProtocol.java | 195 +++---
.../connect/iiot/protocol/set/HttpProtocol.java | 172 +++---
.../iiot/protocol/stream/BrokerEventProcessor.java | 3 +-
.../iiot/protocol/stream/FileStreamProtocol.java | 130 ++--
.../iiot/protocol/stream/HttpServerProtocol.java | 47 +-
.../iiot/protocol/stream/HttpStreamProtocol.java | 211 +++----
.../iiot/protocol/stream/KafkaProtocol.java | 353 +++++------
.../connect/iiot/protocol/stream/MqttProtocol.java | 19 +-
.../connect/iiot/protocol/stream/NatsProtocol.java | 19 +-
.../connect/iiot/protocol/stream/PullProtocol.java | 105 ++--
.../protocol/stream/pulsar/PulsarProtocol.java | 69 ++-
.../iiot/protocol/stream/pulsar/PulsarUtils.java | 4 +-
.../protocol/stream/rocketmq/RocketMQConsumer.java | 6 +-
.../protocol/stream/rocketmq/RocketMQProtocol.java | 229 +++----
.../protocol/stream/rocketmq/RocketMQUtils.java | 17 +-
.../connect/iiot/utils/FileProtocolUtils.java | 69 +--
.../streampipes-connect-adapters/pom.xml | 7 +-
.../streampipes/connect/ConnectAdapterInit.java | 38 +-
.../streampipes/connect/adapters/PullAdapter.java | 107 ++--
.../connect/adapters/PullRestAdapter.java | 66 ++-
.../adapters/coindesk/CoindeskBitcoinAdapter.java | 30 +-
.../connect/adapters/coindesk/model/Bpi.java | 60 +-
.../adapters/coindesk/model/CoindeskRawModel.java | 64 +-
.../connect/adapters/coindesk/model/EUR.java | 104 ++--
.../connect/adapters/coindesk/model/GBP.java | 100 ++--
.../connect/adapters/coindesk/model/Time.java | 60 +-
.../connect/adapters/coindesk/model/USD.java | 100 ++--
.../connect/adapters/flic/FlicMQTTAdapter.java | 214 +++----
.../connect/adapters/flic/FlicOutput.java | 41 +-
.../connect/adapters/flic/FlicUtils.java | 62 +-
.../connect/adapters/gdelt/GdeltAdapter.java | 327 +++++-----
.../connect/adapters/iex/IexCloudAdapter.java | 12 +-
.../connect/adapters/iex/IexCloudNewsAdapter.java | 60 +-
.../connect/adapters/iex/IexCloudStockAdapter.java | 34 +-
.../connect/adapters/iex/model/IexNewsData.java | 180 +++---
.../connect/adapters/iex/model/IexStockData.java | 656 ++++++++++-----------
.../connect/adapters/image/ImageZipAdapter.java | 113 ++--
.../connect/adapters/image/ImageZipUtils.java | 16 +-
.../adapters/image/ZipFileImageIterator.java | 117 ++--
.../adapters/image/set/ImageSetAdapter.java | 117 ++--
.../adapters/image/stream/ImageStreamAdapter.java | 119 ++--
.../connect/adapters/iss/IssAdapter.java | 211 +++----
.../connect/adapters/iss/model/IssModel.java | 60 +-
.../connect/adapters/iss/model/IssPosition.java | 40 +-
.../connect/adapters/netio/NetioMQTTAdapter.java | 239 ++++----
.../connect/adapters/netio/NetioRestAdapter.java | 334 ++++++-----
.../connect/adapters/netio/NetioUtils.java | 282 ++++-----
.../adapters/netio/model/NetioAllPowerOutputs.java | 32 +-
.../adapters/netio/model/NetioGlobalMeasure.java | 96 +--
.../adapters/netio/model/NetioPowerOutput.java | 144 ++---
.../adapters/sensemap/OpenSenseMapAdapter.java | 578 +++++++++---------
.../connect/adapters/sensemap/SensorNames.java | 213 ++++---
.../adapters/sensemap/model/CurrentLocation.java | 52 +-
.../connect/adapters/sensemap/model/Geometry.java | 52 +-
.../adapters/sensemap/model/LastMeasurement.java | 40 +-
.../connect/adapters/sensemap/model/Loc.java | 40 +-
.../connect/adapters/sensemap/model/SenseBox.java | 184 +++---
.../connect/adapters/sensemap/model/Sensor.java | 120 ++--
.../simulator/random/RandomDataSetAdapter.java | 19 +-
.../simulator/random/RandomDataSimulatorUtils.java | 22 +-
.../simulator/random/RandomDataStreamAdapter.java | 21 +-
.../connect/adapters/slack/SlackAdapter.java | 35 +-
.../connect/adapters/slack/SlackConsumer.java | 3 +-
.../connect/adapters/ti/TISensorTag.java | 325 +++++-----
.../adapters/wikipedia/WikipediaAdapter.java | 104 ++--
.../wikipedia/WikipediaEditedArticlesAdapter.java | 8 +-
.../wikipedia/WikipediaModelConverter.java | 17 +-
.../wikipedia/WikipediaNewArticlesAdapter.java | 8 +-
.../adapters/wikipedia/WikipediaSseConsumer.java | 3 +-
.../connect/adapters/wikipedia/model/Length.java | 40 +-
.../connect/adapters/wikipedia/model/Meta.java | 180 +++---
.../connect/adapters/wikipedia/model/Revision.java | 40 +-
.../adapters/wikipedia/model/WikipediaModel.java | 338 +++++------
.../streampipes/connect/config/ConfigKeys.java | 12 +-
.../connect/config/ConnectWorkerConfig.java | 6 +-
.../streampipes/connect/adapters/generic/Mock.java | 4 +-
.../connect/adapters/generic/UtilTest.java | 29 +-
.../generic/elements/AddTimestampTest.java | 17 +-
.../generic/elements/DuplicateFilterTest.java | 84 +--
.../generic/protocol/set/HttpProtocolTest.java | 7 +-
.../adapters/sensemap/OpenSenseMapAdapterTest.java | 3 +-
.../connect/adapters/sensemap/SensorNamesTest.java | 54 +-
.../connect/adapters/ti/TISensorTagTest.java | 68 +--
.../streampipes/pe/jvm/config/ConfigKeys.java | 6 +-
.../pe/simulator/StreamPipesSimulationRunner.java | 4 +-
.../pe/shared/config/kafka/KafkaConnectUtils.java | 12 +-
.../config/kafka/kafka/KafkaConnectUtils.java | 12 +-
.../processors/enricher/jvm/EnricherJvmInit.java | 2 +-
.../ValueChangeProcessor.java | 4 +-
.../documentation.md | 0
.../strings.en | 4 +-
.../jvm/processor/compose/ComposeProcessor.java | 4 +-
.../filters/jvm/processor/merge/StreamBuffer.java | 6 +-
.../processors/siddhi/filter/NumericalFilter.java | 3 +-
.../siddhi/filter/NumericalFilterController.java | 5 +-
.../frequencychange/FrequencyChangeController.java | 5 +-
.../streampipes/processors/siddhi/trend/Trend.java | 8 +-
.../siddhi/trend/TestTrendProcessor.java | 87 +--
.../SpatialGridEnrichmentController.java | 9 +-
.../CreateTrajectoryFromPointsController.java | 5 +-
.../revgeocoder/ReverseGeocodingController.java | 5 +-
.../staticgeocoder/StaticGoogleMapsGeocoder.java | 4 +-
.../flink/AbstractPatternDetectionProgram.java | 6 +-
.../processor/peak/utils/SlidingBatchWindow.java | 8 +-
.../SentenceDetectionController.java | 5 +-
.../flink/AbstractFlinkTransformationProgram.java | 6 +-
.../processor/boilerplate/BoilerplateRemover.java | 10 +-
.../MeasurementUnitConverterController.java | 9 +-
.../processor/converter/TestConverterProgram.java | 21 +-
.../flink/processor/hasher/TestFieldHasher.java | 10 +-
.../hasher/TestFieldHasherController.java | 3 +-
.../processor/hasher/TestFieldHasherProgram.java | 29 +-
.../processor/hasher/TestFieldHasherUtils.java | 4 +-
.../flink/processor/rename/TestRenameProgram.java | 21 +-
.../transformation/flink/utils/DummyCollector.java | 3 +-
.../inverter/BooleanInverterController.java | 5 +-
.../state/BooleanToStateController.java | 48 +-
.../timekeeping/BooleanTimekeeping.java | 4 +-
.../processor/booloperator/timer/BooleanTimer.java | 4 +-
.../booloperator/timer/BooleanTimerController.java | 37 +-
.../csvmetadata/CsvMetadataEnrichment.java | 6 +-
.../MeasurementUnitConverterProcessor.java | 5 +-
.../buffer/StateBufferLabelerController.java | 5 +-
.../state/labeler/model/StatementUtils.java | 1 -
.../state/labeler/number/NumberLabeler.java | 6 +-
.../stringoperator/state/StringToState.java | 4 +-
.../stringoperator/timer/StringTimer.java | 4 +-
.../timestampextractor/TimestampExtractor.java | 4 +-
.../TimestampExtractorController.java | 9 +-
.../TransformToBooleanController.java | 5 +-
.../duration/CalculateDurationController.java | 5 +-
.../documentation.md | 12 +-
.../documentation.md | 2 +-
.../documentation.md | 2 +-
.../documentation.md | 8 +-
.../documentation.md | 8 +-
.../documentation.md | 5 +-
.../documentation.md | 2 +-
.../documentation.md | 11 +-
.../documentation.md | 2 +-
.../documentation.md | 9 +-
.../documentation.md | 5 +-
.../documentation.md | 9 +-
.../documentation.md | 2 +-
.../documentation.md | 11 +-
.../documentation.md | 9 +-
.../documentation.md | 14 +-
.../documentation.md | 10 +-
.../documentation.md | 2 +-
.../documentation.md | 2 +-
.../documentation.md | 2 +-
.../documentation.md | 5 +-
.../documentation.md | 12 +-
.../documentation.md | 11 +-
.../documentation.md | 5 +-
.../sinks/brokers/jvm/bufferrest/BufferRest.java | 14 +-
.../sinks/brokers/jvm/jms/JmsPublisher.java | 4 +-
.../sinks/brokers/jvm/kafka/KafkaPublisher.java | 8 +-
.../sinks/brokers/jvm/mqtt/MqttClient.java | 1 +
.../sinks/brokers/jvm/nats/NatsPublisher.java | 17 +-
.../brokers/jvm/pulsar/PulsarPublisherSink.java | 11 +-
.../brokers/jvm/rabbitmq/RabbitMqConsumer.java | 5 +-
.../brokers/jvm/rabbitmq/RabbitMqController.java | 3 +-
.../brokers/jvm/websocket/WebsocketServerSink.java | 2 +-
.../documentation.md | 2 +-
.../brokers/jvm/pulsar/TestPulsarParameters.java | 1 +
.../elastic/ActionRequestFailureHandler.java | 36 --
.../sinks/databases/jvm/ditto/Ditto.java | 1 +
.../databases/jvm/influxdb/InfluxDbController.java | 8 +-
.../sinks/databases/jvm/iotdb/IotDb.java | 8 +-
.../sinks/databases/jvm/jdbcclient/JdbcClient.java | 11 +-
.../jvm/jdbcclient/model/StatementHandler.java | 20 +-
.../jvm/jdbcclient/model/TableDescription.java | 7 +-
.../sinks/databases/jvm/opcua/OpcUa.java | 26 +-
.../notifications/jvm/slack/SlackNotification.java | 6 +-
.../simulator/vehicle/streams/VehicleStream.java | 16 +-
.../watertank/simulator/config/ConfigKeys.java | 4 +-
.../simulator/utils/WatertankDataSimulator.java | 8 +-
tools/maven/suppressions.xml | 2 +
206 files changed, 7279 insertions(+), 6916 deletions(-)
rename streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/{valueChange => valuechange}/ValueChangeProcessor.java (98%)
rename streampipes-extensions/streampipes-processors-enricher-jvm/src/main/resources/{org.apache.streampipes.processors.enricher.jvm.valueChange => org.apache.streampipes.processors.enricher.jvm.valuechange}/documentation.md (100%)
rename streampipes-extensions/streampipes-processors-enricher-jvm/src/main/resources/{org.apache.streampipes.processors.enricher.jvm.valueChange => org.apache.streampipes.processors.enricher.jvm.valuechange}/strings.en (90%)