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/06 21:32:46 UTC
[streampipes] branch extension-modules-checkstyle-enablements updated (5a56d293f -> 5e67aca52)
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 5a56d293f Merge branch 'dev' into extension-modules-checkstyle-enablements
add 5e67aca52 [#820] Enable checkstyle for all extension modules
No new revisions were added by this update.
Summary of changes:
.../flink/AbstractTextMiningProgram.java | 6 +-
.../streampipes-processors-text-mining-jvm/pom.xml | 12 +-
.../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 | 36 +-
.../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 | 11 +-
.../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 | 64 +-
.../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 | 2 +-
.../processor/hasher/TestFieldHasherProgram.java | 2 +-
.../flink/processor/rename/TestRenameProgram.java | 2 +-
.../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 | 30 +-
.../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 | 10 +-
.../state/BooleanToStateParameters.java | 69 +-
.../timekeeping/BooleanTimekeeping.java | 96 +--
.../timekeeping/BooleanTimekeepingController.java | 61 +-
.../timekeeping/BooleanTimekeepingParameters.java | 37 +-
.../booloperator/timer/BooleanTimerController.java | 7 +-
.../booloperator/timer/BooleanTimerParameters.java | 37 +-
.../csvmetadata/CsvMetadataEnrichment.java | 19 +-
.../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 | 63 +-
.../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 | 92 ++-
.../buffer/StateBufferLabelerParameters.java | 176 ++---
.../processor/state/labeler/model/Statement.java | 46 +-
.../state/labeler/model/StatementUtils.java | 204 +++---
.../state/labeler/number/NumberLabeler.java | 8 +-
.../labeler/number/NumberLabelerController.java | 72 +-
.../labeler/number/NumberLabelerParameters.java | 104 +--
.../stringoperator/counter/StringCounter.java | 38 +-
.../counter/StringCounterController.java | 44 +-
.../counter/StringCounterParameters.java | 16 +-
.../state/StringToStateController.java | 33 +-
.../state/StringToStateParameters.java | 22 +-
.../stringoperator/timer/StringTimer.java | 38 +-
.../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 | 62 +-
.../TimestampExtractorParameters.java | 26 +-
.../transformtoboolean/TransformToBoolean.java | 76 +-
.../TransformToBooleanController.java | 130 ++--
.../TransformToBooleanParameters.java | 16 +-
.../value/change/ChangedValueDetection.java | 8 +-
.../change/ChangedValueDetectionController.java | 27 +-
.../change/ChangedValueDetectionParameters.java | 26 +-
.../value/duration/CalculateDuration.java | 10 +-
.../duration/CalculateDurationController.java | 38 +-
.../duration/CalculateDurationParameters.java | 64 +-
.../streampipes-sinks-brokers-jvm/pom.xml | 9 +
.../sinks/brokers/jvm/BrokersJvmInit.java | 42 +-
.../sinks/brokers/jvm/bufferrest/BufferRest.java | 2 +-
.../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 | 29 +-
.../sinks/brokers/jvm/mqtt/MqttClient.java | 251 +++----
.../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 | 70 +-
.../sinks/brokers/jvm/pulsar/PulsarParameters.java | 4 +-
.../brokers/jvm/pulsar/PulsarPublisherSink.java | 131 ++--
.../brokers/jvm/rabbitmq/RabbitMqConsumer.java | 7 +-
.../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 +-
.../brokers/jvm/pulsar/TestPulsarParameters.java | 43 +-
.../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 | 25 +-
.../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 | 50 +-
.../sinks/databases/jvm/iotdb/IotDb.java | 32 +-
.../sinks/databases/jvm/iotdb/IotDbController.java | 44 +-
.../sinks/databases/jvm/iotdb/IotDbParameters.java | 20 +-
.../sinks/databases/jvm/jdbcclient/JdbcClient.java | 467 +++++++------
.../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 | 267 +++----
.../jvm/jdbcclient/model/SupportedDbEngines.java | 40 +-
.../jvm/jdbcclient/model/TableDescription.java | 234 ++++---
.../jvm/jdbcclient/utils/SQLStatementUtils.java | 122 ++--
.../jvm/jdbcclient/utils/StatementUtils.java | 73 +-
.../sinks/databases/jvm/opcua/OpcUa.java | 335 ++++-----
.../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 | 9 +
.../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 | 28 +-
.../pom.xml | 11 +-
.../simulator/WatertankSimulatorInit.java | 6 +-
.../watertank/simulator/config/ConfigKeys.java | 4 +-
.../simulator/utils/WatertankDataSimulator.java | 28 +-
.../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 +-
325 files changed, 7471 insertions(+), 7056 deletions(-)
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 (72%)
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%)