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/09 16:30:57 UTC
[streampipes] branch dev updated (cf75ca04a -> 49da23c6a)
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 cf75ca04a [release] Use next development version 0.91.0-SNAPSHOT
add 928e812cd [#820] enable checkstyle for some extension modules
add 4e4eb90ed [hotfix] Update checkstyle plugin in extensions as described in #851
add 338cd0b84 [#820] Enable checkstyle for streampipes-processors-geo-jvm
add 647ae8f4f [hotfix] Fix failing e2e tests
add 7da2c1f0d [#820] enable checkstyle for three more modules
add 5a56d293f Merge branch 'dev' into extension-modules-checkstyle-enablements
add 5e67aca52 [#820] Enable checkstyle for all extension modules
add eaa4c6c46 [#820] Enable checkstyle for all extension modules
add 303387d37 [hotfix] Add documentation assets to cusum and welford processor
add 03dc0cfcf Merge branch 'dev' into extension-modules-checkstyle-enablements
add 425ccdbe4 Merge branch 'dev' into extension-modules-checkstyle-enablements
add 703208794 [#820] Fix final checkstyle issues in extensions module
add 22fa255aa Merge branch 'dev' into extension-modules-checkstyle-enablements
new 49da23c6a Merge pull request #850 from apache/extension-modules-checkstyle-enablements
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
streampipes-extensions/pom.xml | 3 -
.../opcua/configuration/SpOpcUaConfig.java | 25 +-
.../opcua/configuration/SpOpcUaConfigBuilder.java | 10 +-
.../connect/iiot/protocol/set/HttpProtocol.java | 10 +-
.../connect/iiot/protocol/stream/NatsProtocol.java | 4 +-
.../streampipes/connect/adapters/PullAdapter.java | 1 +
.../connect/adapters/coindesk/model/EUR.java | 1 -
.../connect/adapters/netio/NetioUtils.java | 28 +-
.../connect/adapters/sensemap/model/SenseBox.java | 8 +-
.../connect/adapters/sensemap/model/Sensor.java | 8 +-
.../connect/adapters/slack/SlackAdapter.java | 4 +-
.../adapters/wikipedia/WikipediaSseConsumer.java | 1 +
.../connect/config/ConnectWorkerConfig.java | 8 +-
.../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-extensions-all-iiot/pom.xml | 13 -
.../streampipes-extensions-all-jvm/pom.xml | 13 -
.../pom.xml | 13 -
.../streampipes-pipeline-elements-all-jvm/pom.xml | 13 -
.../streampipes/pe/jvm/config/ConfigKeys.java | 6 +-
.../pom.xml | 13 -
.../pe/simulator/StreamPipesSimulationRunner.java | 4 +-
.../streampipes-pipeline-elements-shared/pom.xml | 13 -
.../pe/shared/config/kafka/KafkaConnectUtils.java | 12 +-
.../config/kafka/kafka/KafkaConnectUtils.java | 12 +-
.../pom.xml | 13 -
.../pom.xml | 13 -
.../changedetection/jvm/cusum/CusumController.java | 3 +-
.../jvm/welford/WelfordChangeDetection.java | 3 +-
.../documentation.md | 19 +-
.../documentation.md | 17 +-
.../streampipes-processors-enricher-flink/pom.xml | 13 -
.../streampipes-processors-enricher-jvm/pom.xml | 13 -
.../processors/enricher/jvm/EnricherJvmInit.java | 2 +-
.../ValueChangeProcessor.java | 4 +-
.../documentation.md | 0
.../strings.en | 4 +-
.../streampipes-processors-filters-jvm/pom.xml | 13 -
.../jvm/processor/compose/ComposeProcessor.java | 4 +-
.../filters/jvm/processor/merge/StreamBuffer.java | 6 +-
.../streampipes-processors-filters-siddhi/pom.xml | 13 -
.../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 +--
.../streampipes-processors-geo-flink/pom.xml | 14 -
.../SpatialGridEnrichmentController.java | 9 +-
.../streampipes-processors-geo-jvm/pom.xml | 12 +-
.../streampipes/processors/geo/jvm/GeoJvmInit.java | 8 +-
.../processors/geo/jvm/config/ConfigKeys.java | 2 +-
.../geo/jvm/jts/helper/SpGeometryBuilder.java | 28 +-
.../geo/jvm/jts/helper/SpTrajectoryBuilder.java | 161 +++--
.../{latLngToGeo => latlngtogeo}/LatLngToGeo.java | 29 +-
.../LatLngToGeoController.java | 22 +-
.../LatLngToGeoParameter.java | 2 +-
.../processor/{setEPSG => setepsg}/SetEPSG.java | 11 +-
.../{setEPSG => setepsg}/SetEpsgController.java | 25 +-
.../{setEPSG => setepsg}/SetEpsgParameter.java | 2 +-
.../trajectory/CreateTrajectoryFromPoints.java | 26 +-
.../CreateTrajectoryFromPointsController.java | 50 +-
.../CreateTrajectoryFromPointsParameter.java | 3 +-
.../distancecalculator/DistanceCalculator.java | 5 +-
.../DistanceCalculatorController.java | 52 +-
.../DistanceCalculatorParameters.java | 3 +-
.../processor/geocoder/GoogleMapsGeocoding.java | 25 +-
.../geocoder/GoogleMapsGeocodingController.java | 33 +-
.../processor/revgeocoder/ReverseGeocoding.java | 12 +-
.../revgeocoder/ReverseGeocodingController.java | 38 +-
.../jvm/processor/revgeocoder/geocode/GeoName.java | 138 ++--
.../revgeocoder/geocode/ReverseGeoCode.java | 2 +-
.../revgeocoder/geocode/kdtree/KDNode.java | 17 +-
.../geocode/kdtree/KDNodeComparator.java | 19 +-
.../revgeocoder/geocode/kdtree/KDTree.java | 67 +-
.../geo/jvm/processor/speed/SpeedCalculator.java | 34 +-
.../processor/speed/SpeedCalculatorController.java | 81 +--
.../processor/speed/SpeedCalculatorParameters.java | 26 +-
.../StaticDistanceCalculator.java | 31 +-
.../StaticDistanceCalculatorController.java | 82 +--
.../StaticDistanceCalculatorParameters.java | 26 +-
.../staticgeocoder/StaticGoogleMapsGeocoder.java | 23 +-
.../StaticGoogleMapsGeocodingController.java | 39 +-
.../geo/jvm/processor/util/DistanceUtil.java | 38 +-
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 4 +-
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 4 +-
.../strings.en | 2 +-
.../pom.xml | 10 +
.../jvm/ImageProcessingJvmInit.java | 30 +-
.../jvm/processor/commons/ImageTransformer.java | 8 +-
.../processor/commons/PlainImageTransformer.java | 4 +-
.../jvm/processor/commons/RequiredBoxStream.java | 19 +-
.../GenericImageClassification.java | 22 +-
.../GenericImageClassificationController.java | 44 +-
.../jvm/processor/imagecropper/ImageCropper.java | 5 +-
.../imagecropper/ImageCropperController.java | 23 +-
.../imagecropper/ImageCropperParameters.java | 3 +-
.../processor/imageenrichment/BoxCoordinates.java | 23 +-
.../jvm/processor/imageenrichment/ColorUtil.java | 43 +-
.../processor/imageenrichment/ImageEnricher.java | 19 +-
.../imageenrichment/ImageEnrichmentController.java | 21 +-
.../imageenrichment/ImageEnrichmentParameters.java | 10 +-
.../jvm/processor/qrreader/QrCodeReader.java | 18 +-
.../processor/qrreader/QrCodeReaderController.java | 37 +-
.../processor/qrreader/QrCodeReaderParameters.java | 2 +-
.../documentation.md | 2 +-
.../documentation.md | 4 +-
.../documentation.md | 8 +-
.../documentation.md | 4 +-
.../pom.xml | 25 +-
.../flink/AbstractPatternDetectionProgram.java | 18 +-
.../detection/flink/PatternDetectionFlinkInit.java | 46 +-
.../pattern/detection/flink/config/ConfigKeys.java | 8 +-
.../flink/processor/absence/AbsenceController.java | 38 +-
.../flink/processor/absence/AbsenceParameters.java | 49 +-
.../flink/processor/absence/AbsenceProgram.java | 84 +--
.../flink/processor/and/AndController.java | 46 +-
.../flink/processor/and/AndParameters.java | 3 +-
.../detection/flink/processor/and/AndProgram.java | 65 +-
.../flink/processor/common/TimestampExtractor.java | 3 +-
.../processor/peak/PeakDetectionCalculator.java | 15 +-
.../processor/peak/PeakDetectionController.java | 48 +-
.../processor/peak/PeakDetectionParameters.java | 6 +-
.../flink/processor/peak/PeakDetectionProgram.java | 30 +-
.../processor/peak/utils/SlidingBatchWindow.java | 8 +-
.../flink/processor/sequence/Sequence.java | 9 +-
.../processor/sequence/SequenceController.java | 26 +-
.../flink/processor/sequence/SequenceProgram.java | 12 +-
.../detection/processor/absence/TestAbsence.java | 24 +-
.../pattern/detection/processor/and/TestAnd.java | 32 +-
.../pom.xml | 4 +
.../flink/AbstractStatisticsProgram.java | 13 +-
.../statistics/flink/StatisticsFlinkInit.java | 38 +-
.../statistics/flink/config/ConfigKeys.java | 8 +-
.../flink/extensions/MapKeySelector.java | 3 +-
.../flink/extensions/SlidingBatchWindow.java | 8 +-
.../flink/extensions/SlidingEventTimeWindow.java | 22 +-
.../flink/extensions/TimestampMappingFunction.java | 4 +-
.../stat/summary/StatisticsSummaryCalculator.java | 9 +-
.../stat/summary/StatisticsSummaryController.java | 49 +-
.../stat/summary/StatisticsSummaryProgram.java | 3 +-
.../window/StatisticsSummaryCalculatorWindow.java | 11 +-
.../window/StatisticsSummaryControllerWindow.java | 91 +--
.../window/StatisticsSummaryParametersWindow.java | 3 +-
.../StatisticsSummaryParamsSerializable.java | 2 +-
.../window/StatisticsSummaryProgramWindow.java | 37 +-
.../pom.xml | 4 +
.../flink/AbstractTextMiningProgram.java | 13 +-
.../textmining/flink/TextMiningFlinkInit.java | 34 +-
.../textmining/flink/config/ConfigKeys.java | 8 +-
.../processor/language/LanguageDetection.java | 11 +-
.../language/LanguageDetectionController.java | 48 +-
.../language/LanguageDetectionParameters.java | 3 +-
.../language/LanguageDetectionProgram.java | 5 +-
.../processor/wordcount/WordCountController.java | 45 +-
.../processor/wordcount/WordCountParameters.java | 27 +-
.../processor/wordcount/WordCountProgram.java | 13 +-
.../flink/processor/wordcount/WordSplitter.java | 3 +-
.../processor/wordcount/WordToEventConverter.java | 11 +-
.../streampipes-processors-text-mining-jvm/pom.xml | 11 +-
.../textmining/jvm/TextMiningJvmInit.java | 32 +-
.../textmining/jvm/processor/TextMiningUtil.java | 41 +-
.../textmining/jvm/processor/chunker/Chunker.java | 12 +-
.../jvm/processor/chunker/ChunkerController.java | 61 +-
.../jvm/processor/chunker/ChunkerParameters.java | 37 +-
.../jvm/processor/language/LanguageDetection.java | 15 +-
.../language/LanguageDetectionController.java | 54 +-
.../language/LanguageDetectionParameters.java | 27 +-
.../jvm/processor/namefinder/NameFinder.java | 11 +-
.../processor/namefinder/NameFinderController.java | 45 +-
.../processor/namefinder/NameFinderParameters.java | 28 +-
.../jvm/processor/partofspeech/PartOfSpeech.java | 11 +-
.../partofspeech/PartOfSpeechController.java | 53 +-
.../partofspeech/PartOfSpeechParameters.java | 27 +-
.../sentencedetection/SentenceDetection.java | 12 +-
.../SentenceDetectionController.java | 37 +-
.../SentenceDetectionParameters.java | 27 +-
.../jvm/processor/tokenizer/Tokenizer.java | 11 +-
.../processor/tokenizer/TokenizerController.java | 41 +-
.../processor/tokenizer/TokenizerParameters.java | 27 +-
.../pom.xml | 4 +
.../boilerpipe/BoilerpipeDocumentSource.java | 10 +-
.../boilerpipe/BoilerpipeExtractor.java | 23 +-
.../kohlschutter/boilerpipe/BoilerpipeFilter.java | 12 +-
.../kohlschutter/boilerpipe/BoilerpipeInput.java | 12 +-
.../boilerpipe/conditions/TextBlockCondition.java | 14 +-
.../kohlschutter/boilerpipe/document/Image.java | 14 +-
.../boilerpipe/document/TextBlock.java | 34 +-
.../boilerpipe/document/TextDocument.java | 29 +-
.../document/TextDocumentStatistics.java | 16 +-
.../boilerpipe/estimators/SimpleEstimator.java | 16 +-
.../boilerpipe/extractors/ArticleExtractor.java | 34 +-
.../extractors/ArticleSentencesExtractor.java | 14 +-
.../boilerpipe/extractors/CanolaExtractor.java | 20 +-
.../boilerpipe/extractors/CommonExtractors.java | 10 +-
.../boilerpipe/extractors/DefaultExtractor.java | 16 +-
.../boilerpipe/extractors/ExtractorBase.java | 35 +-
.../extractors/KeepEverythingExtractor.java | 10 +-
.../KeepEverythingWithMinKWordsExtractor.java | 10 +-
.../extractors/LargestContentExtractor.java | 10 +-
.../extractors/NumWordsRulesExtractor.java | 10 +-
.../boilerpipe/filters/debug/PrintDebugFilter.java | 18 +-
.../filters/english/DensityRulesClassifier.java | 16 +-
.../filters/english/HeuristicFilterBase.java | 10 +-
.../english/IgnoreBlocksAfterContentFilter.java | 18 +-
.../english/KeepLargestFulltextBlockFilter.java | 18 +-
.../filters/english/MinFulltextWordsFilter.java | 10 +-
.../filters/english/NumWordsRulesClassifier.java | 16 +-
.../filters/english/TerminatingBlocksFinder.java | 14 +-
.../boilerpipe/filters/english/package-info.java | 2 +-
.../heuristics/AddPrecedingLabelsFilter.java | 22 +-
.../filters/heuristics/ArticleMetadataFilter.java | 19 +-
.../filters/heuristics/BlockProximityFusion.java | 22 +-
.../filters/heuristics/ContentFusion.java | 20 +-
.../heuristics/DocumentTitleMatchClassifier.java | 20 +-
.../heuristics/ExpandTitleToContentFilter.java | 12 +-
.../filters/heuristics/KeepLargestBlockFilter.java | 22 +-
.../boilerpipe/filters/heuristics/LabelFusion.java | 24 +-
.../LargeBlockSameTagLevelToContentFilter.java | 10 +-
.../filters/heuristics/ListAtEndFilter.java | 10 +-
.../heuristics/SimpleBlockFusionProcessor.java | 18 +-
.../TrailingHeadlineToBoilerplateFilter.java | 18 +-
.../filters/simple/BoilerplateBlockFilter.java | 18 +-
.../boilerpipe/filters/simple/InvertedFilter.java | 14 +-
.../filters/simple/LabelToBoilerplateFilter.java | 13 +-
.../filters/simple/LabelToContentFilter.java | 13 +-
.../simple/MarkEverythingBoilerplateFilter.java | 10 +-
.../simple/MarkEverythingContentFilter.java | 10 +-
.../filters/simple/MinClauseWordsFilter.java | 20 +-
.../boilerpipe/filters/simple/MinWordsFilter.java | 10 +-
.../filters/simple/SplitParagraphBlocksFilter.java | 22 +-
.../filters/simple/SurroundingToContentFilter.java | 18 +-
.../boilerpipe/labels/ConditionalLabelAction.java | 10 +-
.../boilerpipe/labels/DefaultLabels.java | 10 +-
.../boilerpipe/labels/LabelAction.java | 16 +-
.../sax/BoilerpipeHTMLContentHandler.java | 33 +-
.../boilerpipe/sax/BoilerpipeHTMLParser.java | 14 +-
.../boilerpipe/sax/BoilerpipeSAXInput.java | 23 +-
.../boilerpipe/sax/CommonTagActions.java | 62 +-
.../boilerpipe/sax/DefaultTagActionMap.java | 14 +-
.../kohlschutter/boilerpipe/sax/HTMLDocument.java | 14 +-
.../kohlschutter/boilerpipe/sax/HTMLFetcher.java | 12 +-
.../boilerpipe/sax/HTMLHighlighter.java | 56 +-
.../boilerpipe/sax/ImageExtractor.java | 46 +-
.../boilerpipe/sax/InputSourceable.java | 10 +-
.../boilerpipe/sax/MarkupTagAction.java | 25 +-
.../com/kohlschutter/boilerpipe/sax/TagAction.java | 21 +-
.../kohlschutter/boilerpipe/sax/TagActionMap.java | 16 +-
.../boilerpipe/util/UnicodeTokenizer.java | 12 +-
.../flink/AbstractFlinkTransformationProgram.java | 13 +-
.../flink/TransformationFlinkInit.java | 53 +-
.../transformation/flink/config/ConfigKeys.java | 8 +-
.../boilerplate/BoilerplateController.java | 120 ++--
.../boilerplate/BoilerplateParameters.java | 45 +-
.../processor/boilerplate/BoilerplateProgram.java | 25 +-
.../processor/boilerplate/BoilerplateRemover.java | 104 +--
.../flink/processor/boilerplate/ExtractorMode.java | 10 +-
.../flink/processor/boilerplate/OutputMode.java | 6 +-
.../flink/processor/converter/FieldConverter.java | 39 +-
.../converter/FieldConverterController.java | 49 +-
.../processor/converter/FieldConverterProgram.java | 3 +-
.../flink/processor/hasher/FieldHasher.java | 10 +-
.../processor/hasher/FieldHasherController.java | 33 +-
.../processor/hasher/FieldHasherParameters.java | 37 +-
.../flink/processor/hasher/FieldHasherProgram.java | 31 +-
.../processor/hasher/algorithm/HashAlgorithm.java | 2 +-
.../hasher/algorithm/HashAlgorithmType.java | 20 +-
.../hasher/algorithm/Md5HashAlgorithm.java | 10 +-
.../hasher/algorithm/Sha1HashAlgorithm.java | 10 +-
.../hasher/algorithm/Sha2HashAlgorithm.java | 10 +-
.../flink/processor/mapper/FieldMapper.java | 6 +-
.../processor/mapper/FieldMapperController.java | 26 +-
.../flink/processor/mapper/FieldMapperProgram.java | 5 +-
.../MeasurementUnitConverterProgram.java | 42 --
.../MeasurementUnitConverter.java | 51 +-
.../MeasurementUnitConverterController.java | 73 +-
.../MeasurementUnitConverterParameters.java | 51 +-
.../MeasurementUnitConverterProgram.java} | 21 +-
.../flink/processor/rename/FieldRenamer.java | 5 +-
.../processor/rename/FieldRenamerController.java | 32 +-
.../processor/rename/FieldRenamerParameters.java | 52 +-
.../processor/rename/FieldRenamerProgram.java | 25 +-
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 4 +-
.../processor/converter/TestConverterProgram.java | 23 +-
.../flink/processor/hasher/TestFieldHasher.java | 10 +-
.../hasher/TestFieldHasherController.java | 3 +-
.../processor/hasher/TestFieldHasherProgram.java | 31 +-
.../processor/hasher/TestFieldHasherUtils.java | 4 +-
.../flink/processor/rename/TestRenameProgram.java | 23 +-
.../transformation/flink/utils/DummyCollector.java | 3 +-
.../pom.xml | 9 +
.../transformation/jvm/TransformationJvmInit.java | 68 +-
.../jvm/processor/array/count/CountArray.java | 35 +-
.../array/count/CountArrayController.java | 29 +-
.../array/count/CountArrayParameters.java | 16 +-
.../jvm/processor/array/split/SplitArray.java | 25 +-
.../array/split/SplitArrayController.java | 44 +-
.../array/split/SplitArrayParameters.java | 26 +-
.../booloperator/counter/BooleanCounter.java | 55 +-
.../counter/BooleanCounterController.java | 39 +-
.../counter/BooleanCounterParameters.java | 38 +-
.../booloperator/edge/SignalEdgeFilter.java | 23 +-
.../edge/SignalEdgeFilterController.java | 41 +-
.../edge/SignalEdgeFilterParameters.java | 71 +-
.../booloperator/inverter/BooleanInverter.java | 5 +-
.../inverter/BooleanInverterController.java | 31 +-
.../inverter/BooleanInverterParameters.java | 16 +-
.../logical/BooleanOperationInputConfigs.java | 24 +-
.../logical/BooleanOperatorProcessor.java | 141 ++--
.../logical/enums/BooleanOperatorType.java | 68 +-
.../logical/operations/ANDBoolOperation.java | 8 +-
.../logical/operations/IBoolOperation.java | 17 +-
.../logical/operations/NORBoolOperation.java | 8 +-
.../logical/operations/NOTBooleanOperation.java | 8 +-
.../logical/operations/ORBooleanOperation.java | 8 +-
.../logical/operations/XNORBoolOperation.java | 8 +-
.../logical/operations/XORBooleanOperation.java | 8 +-
.../operations/factory/BoolOperationFactory.java | 32 +-
.../booloperator/state/BooleanToState.java | 8 +-
.../state/BooleanToStateController.java | 58 +-
.../state/BooleanToStateParameters.java | 69 +-
.../timekeeping/BooleanTimekeeping.java | 96 +--
.../timekeeping/BooleanTimekeepingController.java | 61 +-
.../timekeeping/BooleanTimekeepingParameters.java | 37 +-
.../processor/booloperator/timer/BooleanTimer.java | 4 +-
.../booloperator/timer/BooleanTimerController.java | 44 +-
.../booloperator/timer/BooleanTimerParameters.java | 37 +-
.../csvmetadata/CsvMetadataEnrichment.java | 25 +-
.../CsvMetadataEnrichmentController.java | 94 +--
.../csvmetadata/CsvMetadataEnrichmentUtils.java | 17 +-
.../fieldrename/FiledRenameProcessor.java | 78 ++-
.../jvm/processor/hasher/FieldHasherProcessor.java | 33 +-
.../processor/hasher/algorithm/HashAlgorithm.java | 2 +-
.../hasher/algorithm/HashAlgorithmType.java | 20 +-
.../hasher/algorithm/Md5HashAlgorithm.java | 10 +-
.../hasher/algorithm/Sha1HashAlgorithm.java | 10 +-
.../hasher/algorithm/Sha2HashAlgorithm.java | 10 +-
.../jvm/processor/mapper/FieldMapperProcessor.java | 27 +-
.../MeasurementUnitConverterProcessor.java | 68 +-
.../jvm/processor/state/StateUtils.java | 84 +--
.../jvm/processor/state/buffer/StateBuffer.java | 25 +-
.../state/buffer/StateBufferController.java | 61 +-
.../state/buffer/StateBufferParameters.java | 71 +-
.../jvm/processor/state/labeler/LabelerUtils.java | 35 +-
.../state/labeler/buffer/StateBufferLabeler.java | 22 +-
.../buffer/StateBufferLabelerController.java | 93 ++-
.../buffer/StateBufferLabelerParameters.java | 176 ++---
.../processor/state/labeler/model/Statement.java | 46 +-
.../state/labeler/model/StatementUtils.java | 203 +++---
.../state/labeler/number/NumberLabeler.java | 14 +-
.../labeler/number/NumberLabelerController.java | 72 +-
.../labeler/number/NumberLabelerParameters.java | 104 +--
.../stringoperator/counter/StringCounter.java | 38 +-
.../counter/StringCounterController.java | 44 +-
.../counter/StringCounterParameters.java | 16 +-
.../stringoperator/state/StringToState.java | 4 +-
.../state/StringToStateController.java | 33 +-
.../state/StringToStateParameters.java | 22 +-
.../stringoperator/timer/StringTimer.java | 42 +-
.../timer/StringTimerController.java | 49 +-
.../timer/StringTimerParameters.java | 37 +-
.../jvm/processor/task/TaskDuration.java | 5 +-
.../jvm/processor/task/TaskDurationController.java | 49 +-
.../processor/timestampextractor/OutputFields.java | 38 +-
.../timestampextractor/TimestampExtractor.java | 126 ++--
.../TimestampExtractorController.java | 67 +-
.../TimestampExtractorParameters.java | 26 +-
.../transformtoboolean/TransformToBoolean.java | 76 +-
.../TransformToBooleanController.java | 131 ++--
.../TransformToBooleanParameters.java | 16 +-
.../value/change/ChangedValueDetection.java | 8 +-
.../change/ChangedValueDetectionController.java | 27 +-
.../change/ChangedValueDetectionParameters.java | 26 +-
.../value/duration/CalculateDuration.java | 10 +-
.../duration/CalculateDurationController.java | 39 +-
.../duration/CalculateDurationParameters.java | 64 +-
.../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 +-
.../streampipes-sinks-brokers-jvm/pom.xml | 8 +
.../sinks/brokers/jvm/BrokersJvmInit.java | 42 +-
.../sinks/brokers/jvm/bufferrest/BufferRest.java | 16 +-
.../jvm/bufferrest/BufferRestController.java | 61 +-
.../jvm/bufferrest/BufferRestParameters.java | 3 +-
.../jvm/bufferrest/buffer/BufferListener.java | 2 +-
.../jvm/bufferrest/buffer/MessageBuffer.java | 89 +--
.../sinks/brokers/jvm/jms/JmsController.java | 25 +-
.../sinks/brokers/jvm/jms/JmsPublisher.java | 8 +-
.../sinks/brokers/jvm/kafka/KafkaController.java | 47 +-
.../sinks/brokers/jvm/kafka/KafkaParameters.java | 13 +-
.../sinks/brokers/jvm/kafka/KafkaPublisher.java | 31 +-
.../sinks/brokers/jvm/mqtt/MqttClient.java | 252 +++----
.../sinks/brokers/jvm/mqtt/MqttPublisherSink.java | 212 +++---
.../sinks/brokers/jvm/mqtt/common/MqttOptions.java | 290 ++++----
.../sinks/brokers/jvm/mqtt/common/MqttUtils.java | 73 +-
.../sinks/brokers/jvm/nats/NatsController.java | 142 ++--
.../sinks/brokers/jvm/nats/NatsParameters.java | 18 +-
.../sinks/brokers/jvm/nats/NatsPublisher.java | 77 ++-
.../sinks/brokers/jvm/pulsar/PulsarParameters.java | 4 +-
.../brokers/jvm/pulsar/PulsarPublisherSink.java | 142 ++--
.../brokers/jvm/rabbitmq/RabbitMqConsumer.java | 10 +-
.../brokers/jvm/rabbitmq/RabbitMqController.java | 3 +-
.../brokers/jvm/rabbitmq/RabbitMqPublisher.java | 1 -
.../sinks/brokers/jvm/rest/RestController.java | 23 +-
.../sinks/brokers/jvm/rest/RestPublisher.java | 17 +-
.../jvm/rocketmq/RocketMQPublisherSink.java | 144 ++--
.../sinks/brokers/jvm/websocket/SocketServer.java | 68 +-
.../brokers/jvm/websocket/WebsocketServerSink.java | 70 +-
.../documentation.md | 2 +-
.../brokers/jvm/pulsar/TestPulsarParameters.java | 44 +-
.../jvm/pulsar/TestPulsarPublisherSink.java | 113 +--
.../jvm/rocketmq/TestRocketMQPublisherSink.java | 80 ++-
.../streampipes-sinks-databases-flink/pom.xml | 25 +-
.../sinks/databases/flink/DatabasesFlinkInit.java | 40 +-
.../sinks/databases/flink/config/ConfigKeys.java | 12 +-
.../elasticsearch/ElasticSearchController.java | 23 +-
.../flink/elasticsearch/ElasticSearchProgram.java | 120 ++--
.../ElasticsearchIndexRequestBuilder.java | 16 +-
.../elastic/ActionRequestFailureHandler.java | 60 +-
.../elastic/BulkProcessorIndexer.java | 38 +-
.../elastic/Elasticsearch6ApiCallBridge.java | 150 ++--
.../elastic/ElasticsearchApiCallBridge.java | 37 +-
.../elasticsearch/elastic/ElasticsearchSink.java | 57 +-
.../elastic/ElasticsearchSinkBase.java | 769 +++++++++++----------
.../elastic/ElasticsearchSinkFunction.java | 49 +-
.../elasticsearch/elastic/NoOpFailureHandler.java | 13 +-
.../elasticsearch/elastic/RequestIndexer.java | 12 +-
.../streampipes-sinks-databases-jvm/pom.xml | 9 +
.../sinks/databases/jvm/DatabasesJvmInit.java | 36 +-
.../sinks/databases/jvm/couchdb/CouchDb.java | 21 +-
.../databases/jvm/couchdb/CouchDbController.java | 24 +-
.../databases/jvm/couchdb/CouchDbParameters.java | 3 +-
.../sinks/databases/jvm/ditto/Ditto.java | 26 +-
.../sinks/databases/jvm/ditto/DittoController.java | 28 +-
.../sinks/databases/jvm/influxdb/InfluxDb.java | 11 +-
.../databases/jvm/influxdb/InfluxDbClient.java | 126 ++--
.../databases/jvm/influxdb/InfluxDbController.java | 54 +-
.../sinks/databases/jvm/iotdb/IotDb.java | 38 +-
.../sinks/databases/jvm/iotdb/IotDbController.java | 44 +-
.../sinks/databases/jvm/iotdb/IotDbParameters.java | 20 +-
.../sinks/databases/jvm/jdbcclient/JdbcClient.java | 468 +++++++------
.../jvm/jdbcclient/model/DbDataTypeFactory.java | 362 +++++-----
.../jvm/jdbcclient/model/DbDataTypes.java | 62 +-
.../jvm/jdbcclient/model/DbDescription.java | 86 +--
.../jdbcclient/model/JdbcConnectionParameters.java | 114 +--
.../jvm/jdbcclient/model/ParameterInformation.java | 24 +-
.../jvm/jdbcclient/model/StatementHandler.java | 275 ++++----
.../jvm/jdbcclient/model/SupportedDbEngines.java | 40 +-
.../jvm/jdbcclient/model/TableDescription.java | 235 ++++---
.../jvm/jdbcclient/utils/SQLStatementUtils.java | 122 ++--
.../jvm/jdbcclient/utils/StatementUtils.java | 73 +-
.../sinks/databases/jvm/opcua/OpcUa.java | 333 ++++-----
.../sinks/databases/jvm/opcua/UpcUaController.java | 34 +-
.../sinks/databases/jvm/postgresql/PostgreSql.java | 23 +-
.../jvm/postgresql/PostgreSqlController.java | 6 +-
.../jvm/postgresql/PostgreSqlParameters.java | 23 +-
.../sinks/databases/jvm/redis/Redis.java | 156 +++--
.../sinks/databases/jvm/redis/RedisController.java | 120 ++--
.../sinks/databases/jvm/redis/RedisParameters.java | 176 ++---
.../streampipes-sinks-internal-jvm/pom.xml | 9 +
.../sinks/internal/jvm/SinksInternalJvmInit.java | 30 +-
.../sinks/internal/jvm/datalake/DataLakeSink.java | 66 +-
.../jvm/notification/NotificationProducer.java | 24 +-
.../streampipes-sinks-notifications-jvm/pom.xml | 8 +
.../jvm/SinksNotificationsJvmInit.java | 28 +-
.../sinks/notifications/jvm/config/ConfigKeys.java | 2 +-
.../notifications/jvm/email/EmailController.java | 27 +-
.../notifications/jvm/email/EmailParameters.java | 64 +-
.../notifications/jvm/email/EmailPublisher.java | 62 +-
.../jvm/onesignal/OneSignalController.java | 53 +-
.../jvm/onesignal/OneSignalParameters.java | 42 +-
.../jvm/onesignal/OneSignalProducer.java | 81 +--
.../notifications/jvm/slack/SlackNotification.java | 112 +--
.../jvm/slack/SlackNotificationController.java | 43 +-
.../jvm/slack/SlackNotificationParameters.java | 64 +-
.../jvm/telegram/TelegramController.java | 54 +-
.../jvm/telegram/TelegramParameters.java | 50 +-
.../jvm/telegram/TelegramPublisher.java | 104 +--
.../vehicle/simulator/VehicleSimulatorInit.java | 8 +-
.../vehicle/simulator/config/ConfigKeys.java | 4 +-
.../simulator/simulator/VehicleDataSimulator.java | 29 +-
.../simulator/vehicle/streams/VehicleStream.java | 32 +-
.../pom.xml | 11 +-
.../simulator/WatertankSimulatorInit.java | 6 +-
.../watertank/simulator/config/ConfigKeys.java | 4 +-
.../simulator/utils/WatertankDataSimulator.java | 32 +-
.../simulator/vocabulary/WaterTankVocabulary.java | 2 +-
.../watertank/streams/FlowRate1Stream.java | 66 +-
.../watertank/streams/FlowRate2Stream.java | 102 +--
.../watertank/streams/PressureTankStream.java | 48 +-
.../watertank/streams/WaterLevel1Stream.java | 74 +-
.../watertank/streams/WaterLevel2Stream.java | 60 +-
tools/maven/suppressions.xml | 2 +
525 files changed, 9483 insertions(+), 8919 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%)
rename streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/{latLngToGeo => latlngtogeo}/LatLngToGeo.java (77%)
rename streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/{latLngToGeo => latlngtogeo}/LatLngToGeoController.java (83%)
rename streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/{latLngToGeo => latlngtogeo}/LatLngToGeoParameter.java (99%)
rename streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/{setEPSG => setepsg}/SetEPSG.java (89%)
rename streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/{setEPSG => setepsg}/SetEpsgController.java (80%)
rename streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/{setEPSG => setepsg}/SetEpsgParameter.java (99%)
rename streampipes-extensions/streampipes-processors-geo-jvm/src/main/resources/{org.apache.streampipes.processors.geo.jvm.jts.processor.latLngToGeo => org.apache.streampipes.processors.geo.jvm.jts.processor.latlngtogeo}/documentation.md (100%)
rename streampipes-extensions/streampipes-processors-geo-jvm/src/main/resources/{org.apache.streampipes.processors.geo.jvm.jts.processor.latLngToGeo => org.apache.streampipes.processors.geo.jvm.jts.processor.latlngtogeo}/icon.png (100%)
rename streampipes-extensions/streampipes-processors-geo-jvm/src/main/resources/{org.apache.streampipes.processors.geo.jvm.jts.processor.latLngToGeo => org.apache.streampipes.processors.geo.jvm.jts.processor.latlngtogeo}/strings.en (79%)
rename streampipes-extensions/streampipes-processors-geo-jvm/src/main/resources/{org.apache.streampipes.processors.geo.jvm.jts.processor.setEPSG => org.apache.streampipes.processors.geo.jvm.jts.processor.setepsg}/documentation.md (100%)
rename streampipes-extensions/streampipes-processors-geo-jvm/src/main/resources/{org.apache.streampipes.processors.geo.jvm.jts.processor.setEPSG => org.apache.streampipes.processors.geo.jvm.jts.processor.setepsg}/icon.png (100%)
rename streampipes-extensions/streampipes-processors-geo-jvm/src/main/resources/{org.apache.streampipes.processors.geo.jvm.jts.processor.setEPSG => org.apache.streampipes.processors.geo.jvm.jts.processor.setepsg}/strings.en (87%)
delete mode 100644 streampipes-extensions/streampipes-processors-transformation-flink/src/main/java/org/apache/streampipes/processors/transformation/flink/processor/measurementUnitConverter/MeasurementUnitConverterProgram.java
rename streampipes-extensions/streampipes-processors-transformation-flink/src/main/java/org/apache/streampipes/processors/transformation/flink/processor/{measurementUnitConverter => measurementunitonverter}/MeasurementUnitConverter.java (54%)
rename streampipes-extensions/streampipes-processors-transformation-flink/src/main/java/org/apache/streampipes/processors/transformation/flink/processor/{measurementUnitConverter => measurementunitonverter}/MeasurementUnitConverterController.java (66%)
rename streampipes-extensions/streampipes-processors-transformation-flink/src/main/java/org/apache/streampipes/processors/transformation/flink/processor/{measurementUnitConverter => measurementunitonverter}/MeasurementUnitConverterParameters.java (63%)
copy streampipes-extensions/streampipes-processors-transformation-flink/src/main/java/org/apache/streampipes/processors/transformation/flink/processor/{mapper/FieldMapperProgram.java => measurementunitonverter/MeasurementUnitConverterProgram.java} (66%)
rename streampipes-extensions/streampipes-processors-transformation-flink/src/main/resources/{org.apache.streampipes.processors.transformation.flink.measurement-unit-converter => org.apache.streampipes.processors.transformation.flink.measurementunitconverter}/documentation.md (100%)
rename streampipes-extensions/streampipes-processors-transformation-flink/src/main/resources/{org.apache.streampipes.processors.transformation.flink.measurement-unit-converter => org.apache.streampipes.processors.transformation.flink.measurementunitconverter}/icon.png (100%)
rename streampipes-extensions/streampipes-processors-transformation-flink/src/main/resources/{org.apache.streampipes.processors.transformation.flink.measurement-unit-converter => org.apache.streampipes.processors.transformation.flink.measurementunitconverter}/strings.en (84%)
[streampipes] 01/01: Merge pull request #850 from apache/extension-modules-checkstyle-enablements
Posted by ze...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/streampipes.git
commit 49da23c6ac196cce18a3b3fd975fc9b31a4908a3
Merge: cf75ca04a 22fa255aa
Author: Philipp Zehnder <te...@users.noreply.github.com>
AuthorDate: Fri Dec 9 17:30:51 2022 +0100
Merge pull request #850 from apache/extension-modules-checkstyle-enablements
[#820] enable checkstyle for some extension modules
streampipes-extensions/pom.xml | 3 -
.../opcua/configuration/SpOpcUaConfig.java | 25 +-
.../opcua/configuration/SpOpcUaConfigBuilder.java | 10 +-
.../connect/iiot/protocol/set/HttpProtocol.java | 10 +-
.../connect/iiot/protocol/stream/NatsProtocol.java | 4 +-
.../streampipes/connect/adapters/PullAdapter.java | 1 +
.../connect/adapters/coindesk/model/EUR.java | 1 -
.../connect/adapters/netio/NetioUtils.java | 28 +-
.../connect/adapters/sensemap/model/SenseBox.java | 8 +-
.../connect/adapters/sensemap/model/Sensor.java | 8 +-
.../connect/adapters/slack/SlackAdapter.java | 4 +-
.../adapters/wikipedia/WikipediaSseConsumer.java | 1 +
.../connect/config/ConnectWorkerConfig.java | 8 +-
.../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-extensions-all-iiot/pom.xml | 13 -
.../streampipes-extensions-all-jvm/pom.xml | 13 -
.../pom.xml | 13 -
.../streampipes-pipeline-elements-all-jvm/pom.xml | 13 -
.../streampipes/pe/jvm/config/ConfigKeys.java | 6 +-
.../pom.xml | 13 -
.../pe/simulator/StreamPipesSimulationRunner.java | 4 +-
.../streampipes-pipeline-elements-shared/pom.xml | 13 -
.../pe/shared/config/kafka/KafkaConnectUtils.java | 12 +-
.../config/kafka/kafka/KafkaConnectUtils.java | 12 +-
.../pom.xml | 13 -
.../pom.xml | 13 -
.../changedetection/jvm/cusum/CusumController.java | 3 +-
.../jvm/welford/WelfordChangeDetection.java | 3 +-
.../documentation.md | 19 +-
.../documentation.md | 17 +-
.../streampipes-processors-enricher-flink/pom.xml | 13 -
.../streampipes-processors-enricher-jvm/pom.xml | 13 -
.../processors/enricher/jvm/EnricherJvmInit.java | 2 +-
.../ValueChangeProcessor.java | 4 +-
.../documentation.md | 0
.../strings.en | 4 +-
.../streampipes-processors-filters-jvm/pom.xml | 13 -
.../jvm/processor/compose/ComposeProcessor.java | 4 +-
.../filters/jvm/processor/merge/StreamBuffer.java | 6 +-
.../streampipes-processors-filters-siddhi/pom.xml | 13 -
.../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 +--
.../streampipes-processors-geo-flink/pom.xml | 14 -
.../SpatialGridEnrichmentController.java | 9 +-
.../streampipes-processors-geo-jvm/pom.xml | 12 +-
.../streampipes/processors/geo/jvm/GeoJvmInit.java | 8 +-
.../processors/geo/jvm/config/ConfigKeys.java | 2 +-
.../geo/jvm/jts/helper/SpGeometryBuilder.java | 28 +-
.../geo/jvm/jts/helper/SpTrajectoryBuilder.java | 161 +++--
.../{latLngToGeo => latlngtogeo}/LatLngToGeo.java | 29 +-
.../LatLngToGeoController.java | 22 +-
.../LatLngToGeoParameter.java | 2 +-
.../processor/{setEPSG => setepsg}/SetEPSG.java | 11 +-
.../{setEPSG => setepsg}/SetEpsgController.java | 25 +-
.../{setEPSG => setepsg}/SetEpsgParameter.java | 2 +-
.../trajectory/CreateTrajectoryFromPoints.java | 26 +-
.../CreateTrajectoryFromPointsController.java | 50 +-
.../CreateTrajectoryFromPointsParameter.java | 3 +-
.../distancecalculator/DistanceCalculator.java | 5 +-
.../DistanceCalculatorController.java | 52 +-
.../DistanceCalculatorParameters.java | 3 +-
.../processor/geocoder/GoogleMapsGeocoding.java | 25 +-
.../geocoder/GoogleMapsGeocodingController.java | 33 +-
.../processor/revgeocoder/ReverseGeocoding.java | 12 +-
.../revgeocoder/ReverseGeocodingController.java | 38 +-
.../jvm/processor/revgeocoder/geocode/GeoName.java | 138 ++--
.../revgeocoder/geocode/ReverseGeoCode.java | 2 +-
.../revgeocoder/geocode/kdtree/KDNode.java | 17 +-
.../geocode/kdtree/KDNodeComparator.java | 19 +-
.../revgeocoder/geocode/kdtree/KDTree.java | 67 +-
.../geo/jvm/processor/speed/SpeedCalculator.java | 34 +-
.../processor/speed/SpeedCalculatorController.java | 81 +--
.../processor/speed/SpeedCalculatorParameters.java | 26 +-
.../StaticDistanceCalculator.java | 31 +-
.../StaticDistanceCalculatorController.java | 82 +--
.../StaticDistanceCalculatorParameters.java | 26 +-
.../staticgeocoder/StaticGoogleMapsGeocoder.java | 23 +-
.../StaticGoogleMapsGeocodingController.java | 39 +-
.../geo/jvm/processor/util/DistanceUtil.java | 38 +-
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 4 +-
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 4 +-
.../strings.en | 2 +-
.../pom.xml | 10 +
.../jvm/ImageProcessingJvmInit.java | 30 +-
.../jvm/processor/commons/ImageTransformer.java | 8 +-
.../processor/commons/PlainImageTransformer.java | 4 +-
.../jvm/processor/commons/RequiredBoxStream.java | 19 +-
.../GenericImageClassification.java | 22 +-
.../GenericImageClassificationController.java | 44 +-
.../jvm/processor/imagecropper/ImageCropper.java | 5 +-
.../imagecropper/ImageCropperController.java | 23 +-
.../imagecropper/ImageCropperParameters.java | 3 +-
.../processor/imageenrichment/BoxCoordinates.java | 23 +-
.../jvm/processor/imageenrichment/ColorUtil.java | 43 +-
.../processor/imageenrichment/ImageEnricher.java | 19 +-
.../imageenrichment/ImageEnrichmentController.java | 21 +-
.../imageenrichment/ImageEnrichmentParameters.java | 10 +-
.../jvm/processor/qrreader/QrCodeReader.java | 18 +-
.../processor/qrreader/QrCodeReaderController.java | 37 +-
.../processor/qrreader/QrCodeReaderParameters.java | 2 +-
.../documentation.md | 2 +-
.../documentation.md | 4 +-
.../documentation.md | 8 +-
.../documentation.md | 4 +-
.../pom.xml | 25 +-
.../flink/AbstractPatternDetectionProgram.java | 18 +-
.../detection/flink/PatternDetectionFlinkInit.java | 46 +-
.../pattern/detection/flink/config/ConfigKeys.java | 8 +-
.../flink/processor/absence/AbsenceController.java | 38 +-
.../flink/processor/absence/AbsenceParameters.java | 49 +-
.../flink/processor/absence/AbsenceProgram.java | 84 +--
.../flink/processor/and/AndController.java | 46 +-
.../flink/processor/and/AndParameters.java | 3 +-
.../detection/flink/processor/and/AndProgram.java | 65 +-
.../flink/processor/common/TimestampExtractor.java | 3 +-
.../processor/peak/PeakDetectionCalculator.java | 15 +-
.../processor/peak/PeakDetectionController.java | 48 +-
.../processor/peak/PeakDetectionParameters.java | 6 +-
.../flink/processor/peak/PeakDetectionProgram.java | 30 +-
.../processor/peak/utils/SlidingBatchWindow.java | 8 +-
.../flink/processor/sequence/Sequence.java | 9 +-
.../processor/sequence/SequenceController.java | 26 +-
.../flink/processor/sequence/SequenceProgram.java | 12 +-
.../detection/processor/absence/TestAbsence.java | 24 +-
.../pattern/detection/processor/and/TestAnd.java | 32 +-
.../pom.xml | 4 +
.../flink/AbstractStatisticsProgram.java | 13 +-
.../statistics/flink/StatisticsFlinkInit.java | 38 +-
.../statistics/flink/config/ConfigKeys.java | 8 +-
.../flink/extensions/MapKeySelector.java | 3 +-
.../flink/extensions/SlidingBatchWindow.java | 8 +-
.../flink/extensions/SlidingEventTimeWindow.java | 22 +-
.../flink/extensions/TimestampMappingFunction.java | 4 +-
.../stat/summary/StatisticsSummaryCalculator.java | 9 +-
.../stat/summary/StatisticsSummaryController.java | 49 +-
.../stat/summary/StatisticsSummaryProgram.java | 3 +-
.../window/StatisticsSummaryCalculatorWindow.java | 11 +-
.../window/StatisticsSummaryControllerWindow.java | 91 +--
.../window/StatisticsSummaryParametersWindow.java | 3 +-
.../StatisticsSummaryParamsSerializable.java | 2 +-
.../window/StatisticsSummaryProgramWindow.java | 37 +-
.../pom.xml | 4 +
.../flink/AbstractTextMiningProgram.java | 13 +-
.../textmining/flink/TextMiningFlinkInit.java | 34 +-
.../textmining/flink/config/ConfigKeys.java | 8 +-
.../processor/language/LanguageDetection.java | 11 +-
.../language/LanguageDetectionController.java | 48 +-
.../language/LanguageDetectionParameters.java | 3 +-
.../language/LanguageDetectionProgram.java | 5 +-
.../processor/wordcount/WordCountController.java | 45 +-
.../processor/wordcount/WordCountParameters.java | 27 +-
.../processor/wordcount/WordCountProgram.java | 13 +-
.../flink/processor/wordcount/WordSplitter.java | 3 +-
.../processor/wordcount/WordToEventConverter.java | 11 +-
.../streampipes-processors-text-mining-jvm/pom.xml | 11 +-
.../textmining/jvm/TextMiningJvmInit.java | 32 +-
.../textmining/jvm/processor/TextMiningUtil.java | 41 +-
.../textmining/jvm/processor/chunker/Chunker.java | 12 +-
.../jvm/processor/chunker/ChunkerController.java | 61 +-
.../jvm/processor/chunker/ChunkerParameters.java | 37 +-
.../jvm/processor/language/LanguageDetection.java | 15 +-
.../language/LanguageDetectionController.java | 54 +-
.../language/LanguageDetectionParameters.java | 27 +-
.../jvm/processor/namefinder/NameFinder.java | 11 +-
.../processor/namefinder/NameFinderController.java | 45 +-
.../processor/namefinder/NameFinderParameters.java | 28 +-
.../jvm/processor/partofspeech/PartOfSpeech.java | 11 +-
.../partofspeech/PartOfSpeechController.java | 53 +-
.../partofspeech/PartOfSpeechParameters.java | 27 +-
.../sentencedetection/SentenceDetection.java | 12 +-
.../SentenceDetectionController.java | 37 +-
.../SentenceDetectionParameters.java | 27 +-
.../jvm/processor/tokenizer/Tokenizer.java | 11 +-
.../processor/tokenizer/TokenizerController.java | 41 +-
.../processor/tokenizer/TokenizerParameters.java | 27 +-
.../pom.xml | 4 +
.../boilerpipe/BoilerpipeDocumentSource.java | 10 +-
.../boilerpipe/BoilerpipeExtractor.java | 23 +-
.../kohlschutter/boilerpipe/BoilerpipeFilter.java | 12 +-
.../kohlschutter/boilerpipe/BoilerpipeInput.java | 12 +-
.../boilerpipe/conditions/TextBlockCondition.java | 14 +-
.../kohlschutter/boilerpipe/document/Image.java | 14 +-
.../boilerpipe/document/TextBlock.java | 34 +-
.../boilerpipe/document/TextDocument.java | 29 +-
.../document/TextDocumentStatistics.java | 16 +-
.../boilerpipe/estimators/SimpleEstimator.java | 16 +-
.../boilerpipe/extractors/ArticleExtractor.java | 34 +-
.../extractors/ArticleSentencesExtractor.java | 14 +-
.../boilerpipe/extractors/CanolaExtractor.java | 20 +-
.../boilerpipe/extractors/CommonExtractors.java | 10 +-
.../boilerpipe/extractors/DefaultExtractor.java | 16 +-
.../boilerpipe/extractors/ExtractorBase.java | 35 +-
.../extractors/KeepEverythingExtractor.java | 10 +-
.../KeepEverythingWithMinKWordsExtractor.java | 10 +-
.../extractors/LargestContentExtractor.java | 10 +-
.../extractors/NumWordsRulesExtractor.java | 10 +-
.../boilerpipe/filters/debug/PrintDebugFilter.java | 18 +-
.../filters/english/DensityRulesClassifier.java | 16 +-
.../filters/english/HeuristicFilterBase.java | 10 +-
.../english/IgnoreBlocksAfterContentFilter.java | 18 +-
.../english/KeepLargestFulltextBlockFilter.java | 18 +-
.../filters/english/MinFulltextWordsFilter.java | 10 +-
.../filters/english/NumWordsRulesClassifier.java | 16 +-
.../filters/english/TerminatingBlocksFinder.java | 14 +-
.../boilerpipe/filters/english/package-info.java | 2 +-
.../heuristics/AddPrecedingLabelsFilter.java | 22 +-
.../filters/heuristics/ArticleMetadataFilter.java | 19 +-
.../filters/heuristics/BlockProximityFusion.java | 22 +-
.../filters/heuristics/ContentFusion.java | 20 +-
.../heuristics/DocumentTitleMatchClassifier.java | 20 +-
.../heuristics/ExpandTitleToContentFilter.java | 12 +-
.../filters/heuristics/KeepLargestBlockFilter.java | 22 +-
.../boilerpipe/filters/heuristics/LabelFusion.java | 24 +-
.../LargeBlockSameTagLevelToContentFilter.java | 10 +-
.../filters/heuristics/ListAtEndFilter.java | 10 +-
.../heuristics/SimpleBlockFusionProcessor.java | 18 +-
.../TrailingHeadlineToBoilerplateFilter.java | 18 +-
.../filters/simple/BoilerplateBlockFilter.java | 18 +-
.../boilerpipe/filters/simple/InvertedFilter.java | 14 +-
.../filters/simple/LabelToBoilerplateFilter.java | 13 +-
.../filters/simple/LabelToContentFilter.java | 13 +-
.../simple/MarkEverythingBoilerplateFilter.java | 10 +-
.../simple/MarkEverythingContentFilter.java | 10 +-
.../filters/simple/MinClauseWordsFilter.java | 20 +-
.../boilerpipe/filters/simple/MinWordsFilter.java | 10 +-
.../filters/simple/SplitParagraphBlocksFilter.java | 22 +-
.../filters/simple/SurroundingToContentFilter.java | 18 +-
.../boilerpipe/labels/ConditionalLabelAction.java | 10 +-
.../boilerpipe/labels/DefaultLabels.java | 10 +-
.../boilerpipe/labels/LabelAction.java | 16 +-
.../sax/BoilerpipeHTMLContentHandler.java | 33 +-
.../boilerpipe/sax/BoilerpipeHTMLParser.java | 14 +-
.../boilerpipe/sax/BoilerpipeSAXInput.java | 23 +-
.../boilerpipe/sax/CommonTagActions.java | 62 +-
.../boilerpipe/sax/DefaultTagActionMap.java | 14 +-
.../kohlschutter/boilerpipe/sax/HTMLDocument.java | 14 +-
.../kohlschutter/boilerpipe/sax/HTMLFetcher.java | 12 +-
.../boilerpipe/sax/HTMLHighlighter.java | 56 +-
.../boilerpipe/sax/ImageExtractor.java | 46 +-
.../boilerpipe/sax/InputSourceable.java | 10 +-
.../boilerpipe/sax/MarkupTagAction.java | 25 +-
.../com/kohlschutter/boilerpipe/sax/TagAction.java | 21 +-
.../kohlschutter/boilerpipe/sax/TagActionMap.java | 16 +-
.../boilerpipe/util/UnicodeTokenizer.java | 12 +-
.../flink/AbstractFlinkTransformationProgram.java | 13 +-
.../flink/TransformationFlinkInit.java | 53 +-
.../transformation/flink/config/ConfigKeys.java | 8 +-
.../boilerplate/BoilerplateController.java | 120 ++--
.../boilerplate/BoilerplateParameters.java | 45 +-
.../processor/boilerplate/BoilerplateProgram.java | 25 +-
.../processor/boilerplate/BoilerplateRemover.java | 104 +--
.../flink/processor/boilerplate/ExtractorMode.java | 10 +-
.../flink/processor/boilerplate/OutputMode.java | 6 +-
.../flink/processor/converter/FieldConverter.java | 39 +-
.../converter/FieldConverterController.java | 49 +-
.../processor/converter/FieldConverterProgram.java | 3 +-
.../flink/processor/hasher/FieldHasher.java | 10 +-
.../processor/hasher/FieldHasherController.java | 33 +-
.../processor/hasher/FieldHasherParameters.java | 37 +-
.../flink/processor/hasher/FieldHasherProgram.java | 31 +-
.../processor/hasher/algorithm/HashAlgorithm.java | 2 +-
.../hasher/algorithm/HashAlgorithmType.java | 20 +-
.../hasher/algorithm/Md5HashAlgorithm.java | 10 +-
.../hasher/algorithm/Sha1HashAlgorithm.java | 10 +-
.../hasher/algorithm/Sha2HashAlgorithm.java | 10 +-
.../flink/processor/mapper/FieldMapper.java | 6 +-
.../processor/mapper/FieldMapperController.java | 26 +-
.../flink/processor/mapper/FieldMapperProgram.java | 5 +-
.../MeasurementUnitConverterProgram.java | 42 --
.../MeasurementUnitConverter.java | 51 +-
.../MeasurementUnitConverterController.java | 73 +-
.../MeasurementUnitConverterParameters.java | 51 +-
.../MeasurementUnitConverterProgram.java} | 21 +-
.../flink/processor/rename/FieldRenamer.java | 5 +-
.../processor/rename/FieldRenamerController.java | 32 +-
.../processor/rename/FieldRenamerParameters.java | 52 +-
.../processor/rename/FieldRenamerProgram.java | 25 +-
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 4 +-
.../processor/converter/TestConverterProgram.java | 23 +-
.../flink/processor/hasher/TestFieldHasher.java | 10 +-
.../hasher/TestFieldHasherController.java | 3 +-
.../processor/hasher/TestFieldHasherProgram.java | 31 +-
.../processor/hasher/TestFieldHasherUtils.java | 4 +-
.../flink/processor/rename/TestRenameProgram.java | 23 +-
.../transformation/flink/utils/DummyCollector.java | 3 +-
.../pom.xml | 9 +
.../transformation/jvm/TransformationJvmInit.java | 68 +-
.../jvm/processor/array/count/CountArray.java | 35 +-
.../array/count/CountArrayController.java | 29 +-
.../array/count/CountArrayParameters.java | 16 +-
.../jvm/processor/array/split/SplitArray.java | 25 +-
.../array/split/SplitArrayController.java | 44 +-
.../array/split/SplitArrayParameters.java | 26 +-
.../booloperator/counter/BooleanCounter.java | 55 +-
.../counter/BooleanCounterController.java | 39 +-
.../counter/BooleanCounterParameters.java | 38 +-
.../booloperator/edge/SignalEdgeFilter.java | 23 +-
.../edge/SignalEdgeFilterController.java | 41 +-
.../edge/SignalEdgeFilterParameters.java | 71 +-
.../booloperator/inverter/BooleanInverter.java | 5 +-
.../inverter/BooleanInverterController.java | 31 +-
.../inverter/BooleanInverterParameters.java | 16 +-
.../logical/BooleanOperationInputConfigs.java | 24 +-
.../logical/BooleanOperatorProcessor.java | 141 ++--
.../logical/enums/BooleanOperatorType.java | 68 +-
.../logical/operations/ANDBoolOperation.java | 8 +-
.../logical/operations/IBoolOperation.java | 17 +-
.../logical/operations/NORBoolOperation.java | 8 +-
.../logical/operations/NOTBooleanOperation.java | 8 +-
.../logical/operations/ORBooleanOperation.java | 8 +-
.../logical/operations/XNORBoolOperation.java | 8 +-
.../logical/operations/XORBooleanOperation.java | 8 +-
.../operations/factory/BoolOperationFactory.java | 32 +-
.../booloperator/state/BooleanToState.java | 8 +-
.../state/BooleanToStateController.java | 58 +-
.../state/BooleanToStateParameters.java | 69 +-
.../timekeeping/BooleanTimekeeping.java | 96 +--
.../timekeeping/BooleanTimekeepingController.java | 61 +-
.../timekeeping/BooleanTimekeepingParameters.java | 37 +-
.../processor/booloperator/timer/BooleanTimer.java | 4 +-
.../booloperator/timer/BooleanTimerController.java | 44 +-
.../booloperator/timer/BooleanTimerParameters.java | 37 +-
.../csvmetadata/CsvMetadataEnrichment.java | 25 +-
.../CsvMetadataEnrichmentController.java | 94 +--
.../csvmetadata/CsvMetadataEnrichmentUtils.java | 17 +-
.../fieldrename/FiledRenameProcessor.java | 78 ++-
.../jvm/processor/hasher/FieldHasherProcessor.java | 33 +-
.../processor/hasher/algorithm/HashAlgorithm.java | 2 +-
.../hasher/algorithm/HashAlgorithmType.java | 20 +-
.../hasher/algorithm/Md5HashAlgorithm.java | 10 +-
.../hasher/algorithm/Sha1HashAlgorithm.java | 10 +-
.../hasher/algorithm/Sha2HashAlgorithm.java | 10 +-
.../jvm/processor/mapper/FieldMapperProcessor.java | 27 +-
.../MeasurementUnitConverterProcessor.java | 68 +-
.../jvm/processor/state/StateUtils.java | 84 +--
.../jvm/processor/state/buffer/StateBuffer.java | 25 +-
.../state/buffer/StateBufferController.java | 61 +-
.../state/buffer/StateBufferParameters.java | 71 +-
.../jvm/processor/state/labeler/LabelerUtils.java | 35 +-
.../state/labeler/buffer/StateBufferLabeler.java | 22 +-
.../buffer/StateBufferLabelerController.java | 93 ++-
.../buffer/StateBufferLabelerParameters.java | 176 ++---
.../processor/state/labeler/model/Statement.java | 46 +-
.../state/labeler/model/StatementUtils.java | 203 +++---
.../state/labeler/number/NumberLabeler.java | 14 +-
.../labeler/number/NumberLabelerController.java | 72 +-
.../labeler/number/NumberLabelerParameters.java | 104 +--
.../stringoperator/counter/StringCounter.java | 38 +-
.../counter/StringCounterController.java | 44 +-
.../counter/StringCounterParameters.java | 16 +-
.../stringoperator/state/StringToState.java | 4 +-
.../state/StringToStateController.java | 33 +-
.../state/StringToStateParameters.java | 22 +-
.../stringoperator/timer/StringTimer.java | 42 +-
.../timer/StringTimerController.java | 49 +-
.../timer/StringTimerParameters.java | 37 +-
.../jvm/processor/task/TaskDuration.java | 5 +-
.../jvm/processor/task/TaskDurationController.java | 49 +-
.../processor/timestampextractor/OutputFields.java | 38 +-
.../timestampextractor/TimestampExtractor.java | 126 ++--
.../TimestampExtractorController.java | 67 +-
.../TimestampExtractorParameters.java | 26 +-
.../transformtoboolean/TransformToBoolean.java | 76 +-
.../TransformToBooleanController.java | 131 ++--
.../TransformToBooleanParameters.java | 16 +-
.../value/change/ChangedValueDetection.java | 8 +-
.../change/ChangedValueDetectionController.java | 27 +-
.../change/ChangedValueDetectionParameters.java | 26 +-
.../value/duration/CalculateDuration.java | 10 +-
.../duration/CalculateDurationController.java | 39 +-
.../duration/CalculateDurationParameters.java | 64 +-
.../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 +-
.../streampipes-sinks-brokers-jvm/pom.xml | 8 +
.../sinks/brokers/jvm/BrokersJvmInit.java | 42 +-
.../sinks/brokers/jvm/bufferrest/BufferRest.java | 16 +-
.../jvm/bufferrest/BufferRestController.java | 61 +-
.../jvm/bufferrest/BufferRestParameters.java | 3 +-
.../jvm/bufferrest/buffer/BufferListener.java | 2 +-
.../jvm/bufferrest/buffer/MessageBuffer.java | 89 +--
.../sinks/brokers/jvm/jms/JmsController.java | 25 +-
.../sinks/brokers/jvm/jms/JmsPublisher.java | 8 +-
.../sinks/brokers/jvm/kafka/KafkaController.java | 47 +-
.../sinks/brokers/jvm/kafka/KafkaParameters.java | 13 +-
.../sinks/brokers/jvm/kafka/KafkaPublisher.java | 31 +-
.../sinks/brokers/jvm/mqtt/MqttClient.java | 252 +++----
.../sinks/brokers/jvm/mqtt/MqttPublisherSink.java | 212 +++---
.../sinks/brokers/jvm/mqtt/common/MqttOptions.java | 290 ++++----
.../sinks/brokers/jvm/mqtt/common/MqttUtils.java | 73 +-
.../sinks/brokers/jvm/nats/NatsController.java | 142 ++--
.../sinks/brokers/jvm/nats/NatsParameters.java | 18 +-
.../sinks/brokers/jvm/nats/NatsPublisher.java | 77 ++-
.../sinks/brokers/jvm/pulsar/PulsarParameters.java | 4 +-
.../brokers/jvm/pulsar/PulsarPublisherSink.java | 142 ++--
.../brokers/jvm/rabbitmq/RabbitMqConsumer.java | 10 +-
.../brokers/jvm/rabbitmq/RabbitMqController.java | 3 +-
.../brokers/jvm/rabbitmq/RabbitMqPublisher.java | 1 -
.../sinks/brokers/jvm/rest/RestController.java | 23 +-
.../sinks/brokers/jvm/rest/RestPublisher.java | 17 +-
.../jvm/rocketmq/RocketMQPublisherSink.java | 144 ++--
.../sinks/brokers/jvm/websocket/SocketServer.java | 68 +-
.../brokers/jvm/websocket/WebsocketServerSink.java | 70 +-
.../documentation.md | 2 +-
.../brokers/jvm/pulsar/TestPulsarParameters.java | 44 +-
.../jvm/pulsar/TestPulsarPublisherSink.java | 113 +--
.../jvm/rocketmq/TestRocketMQPublisherSink.java | 80 ++-
.../streampipes-sinks-databases-flink/pom.xml | 25 +-
.../sinks/databases/flink/DatabasesFlinkInit.java | 40 +-
.../sinks/databases/flink/config/ConfigKeys.java | 12 +-
.../elasticsearch/ElasticSearchController.java | 23 +-
.../flink/elasticsearch/ElasticSearchProgram.java | 120 ++--
.../ElasticsearchIndexRequestBuilder.java | 16 +-
.../elastic/ActionRequestFailureHandler.java | 60 +-
.../elastic/BulkProcessorIndexer.java | 38 +-
.../elastic/Elasticsearch6ApiCallBridge.java | 150 ++--
.../elastic/ElasticsearchApiCallBridge.java | 37 +-
.../elasticsearch/elastic/ElasticsearchSink.java | 57 +-
.../elastic/ElasticsearchSinkBase.java | 769 +++++++++++----------
.../elastic/ElasticsearchSinkFunction.java | 49 +-
.../elasticsearch/elastic/NoOpFailureHandler.java | 13 +-
.../elasticsearch/elastic/RequestIndexer.java | 12 +-
.../streampipes-sinks-databases-jvm/pom.xml | 9 +
.../sinks/databases/jvm/DatabasesJvmInit.java | 36 +-
.../sinks/databases/jvm/couchdb/CouchDb.java | 21 +-
.../databases/jvm/couchdb/CouchDbController.java | 24 +-
.../databases/jvm/couchdb/CouchDbParameters.java | 3 +-
.../sinks/databases/jvm/ditto/Ditto.java | 26 +-
.../sinks/databases/jvm/ditto/DittoController.java | 28 +-
.../sinks/databases/jvm/influxdb/InfluxDb.java | 11 +-
.../databases/jvm/influxdb/InfluxDbClient.java | 126 ++--
.../databases/jvm/influxdb/InfluxDbController.java | 54 +-
.../sinks/databases/jvm/iotdb/IotDb.java | 38 +-
.../sinks/databases/jvm/iotdb/IotDbController.java | 44 +-
.../sinks/databases/jvm/iotdb/IotDbParameters.java | 20 +-
.../sinks/databases/jvm/jdbcclient/JdbcClient.java | 468 +++++++------
.../jvm/jdbcclient/model/DbDataTypeFactory.java | 362 +++++-----
.../jvm/jdbcclient/model/DbDataTypes.java | 62 +-
.../jvm/jdbcclient/model/DbDescription.java | 86 +--
.../jdbcclient/model/JdbcConnectionParameters.java | 114 +--
.../jvm/jdbcclient/model/ParameterInformation.java | 24 +-
.../jvm/jdbcclient/model/StatementHandler.java | 275 ++++----
.../jvm/jdbcclient/model/SupportedDbEngines.java | 40 +-
.../jvm/jdbcclient/model/TableDescription.java | 235 ++++---
.../jvm/jdbcclient/utils/SQLStatementUtils.java | 122 ++--
.../jvm/jdbcclient/utils/StatementUtils.java | 73 +-
.../sinks/databases/jvm/opcua/OpcUa.java | 333 ++++-----
.../sinks/databases/jvm/opcua/UpcUaController.java | 34 +-
.../sinks/databases/jvm/postgresql/PostgreSql.java | 23 +-
.../jvm/postgresql/PostgreSqlController.java | 6 +-
.../jvm/postgresql/PostgreSqlParameters.java | 23 +-
.../sinks/databases/jvm/redis/Redis.java | 156 +++--
.../sinks/databases/jvm/redis/RedisController.java | 120 ++--
.../sinks/databases/jvm/redis/RedisParameters.java | 176 ++---
.../streampipes-sinks-internal-jvm/pom.xml | 9 +
.../sinks/internal/jvm/SinksInternalJvmInit.java | 30 +-
.../sinks/internal/jvm/datalake/DataLakeSink.java | 66 +-
.../jvm/notification/NotificationProducer.java | 24 +-
.../streampipes-sinks-notifications-jvm/pom.xml | 8 +
.../jvm/SinksNotificationsJvmInit.java | 28 +-
.../sinks/notifications/jvm/config/ConfigKeys.java | 2 +-
.../notifications/jvm/email/EmailController.java | 27 +-
.../notifications/jvm/email/EmailParameters.java | 64 +-
.../notifications/jvm/email/EmailPublisher.java | 62 +-
.../jvm/onesignal/OneSignalController.java | 53 +-
.../jvm/onesignal/OneSignalParameters.java | 42 +-
.../jvm/onesignal/OneSignalProducer.java | 81 +--
.../notifications/jvm/slack/SlackNotification.java | 112 +--
.../jvm/slack/SlackNotificationController.java | 43 +-
.../jvm/slack/SlackNotificationParameters.java | 64 +-
.../jvm/telegram/TelegramController.java | 54 +-
.../jvm/telegram/TelegramParameters.java | 50 +-
.../jvm/telegram/TelegramPublisher.java | 104 +--
.../vehicle/simulator/VehicleSimulatorInit.java | 8 +-
.../vehicle/simulator/config/ConfigKeys.java | 4 +-
.../simulator/simulator/VehicleDataSimulator.java | 29 +-
.../simulator/vehicle/streams/VehicleStream.java | 32 +-
.../pom.xml | 11 +-
.../simulator/WatertankSimulatorInit.java | 6 +-
.../watertank/simulator/config/ConfigKeys.java | 4 +-
.../simulator/utils/WatertankDataSimulator.java | 32 +-
.../simulator/vocabulary/WaterTankVocabulary.java | 2 +-
.../watertank/streams/FlowRate1Stream.java | 66 +-
.../watertank/streams/FlowRate2Stream.java | 102 +--
.../watertank/streams/PressureTankStream.java | 48 +-
.../watertank/streams/WaterLevel1Stream.java | 74 +-
.../watertank/streams/WaterLevel2Stream.java | 60 +-
tools/maven/suppressions.xml | 2 +
525 files changed, 9483 insertions(+), 8919 deletions(-)