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/14 07:22:57 UTC
[streampipes] branch dependabot/maven/org.springframework-spring-web-6.0.0 updated (fe750a657 -> 30edf385c)
This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a change to branch dependabot/maven/org.springframework-spring-web-6.0.0
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from fe750a657 Bump spring-web from 5.3.20 to 6.0.0
add 00f239196 Add example files python client (#846)
add 61f854009 Checkstyle enablements (#865)
add cf33668a0 Some more checkstyle enablements (#847)
add 4d2a58d7a Enable checkstyle for streampipes-config
add 7e7eb4b45 Merge pull request #863 from RobertIndie/iss-820
add be6fa8d1d Enable checkstyle for streampipes-dataformat-*
add 5602010f1 Merge pull request #864 from RobertIndie/iss-820-2
add 56d903e06 Merge branch 'dev' into dependabot/maven/org.springframework-spring-web-6.0.0
add e673aa5ab Add checkstyle configuration (#866)
add 30edf385c Merge branch 'dev' into dependabot/maven/org.springframework-spring-web-6.0.0
No new revisions were added by this update.
Summary of changes:
pom.xml | 13 +-
streampipes-client-python/README.md | 34 +-
...introduction-to-streampipes-python-client.ipynb | 214 +++++++++++
...cting-data-from-the-streampipes-data-lake.ipynb | 392 +++++++++++++++++++++
.../docs/getting-started/installation.md | 2 +-
.../docs/getting-started/quickstart.md | 19 +-
streampipes-client-python/mkdocs.yml | 4 +
streampipes-client-python/setup.py | 1 +
.../streampipes_client/client/client.py | 37 ++
.../model/resource/data_lake_measure.py | 6 +-
.../tests/client/test_client.py | 46 ++-
.../tests/client/test_endpoint.py | 44 ++-
streampipes-config/pom.xml | 12 +-
.../streampipes/config/backend/BackendConfig.java | 50 +--
.../config/backend/MessagingSettings.java | 6 +-
streampipes-data-explorer-commons/pom.xml | 14 +-
.../dataexplorer/commons/DataExplorerUtils.java | 82 ++---
.../dataexplorer/commons/DataExplorerWriter.java | 54 +--
.../dataexplorer/commons/TimeSeriesStore.java | 72 ++--
.../commons/configs/CouchDbConfigurations.java | 14 +-
.../commons/configs/CouchDbEnvKeys.java | 6 +-
.../configs/DataExplorerConfigurations.java | 27 +-
.../commons/configs/DataExplorerEnvKeys.java | 12 +-
.../dataexplorer/commons/image/ImageStore.java | 33 +-
.../commons/image/ImageStoreUtils.java | 14 +-
.../commons/influx/InfluxConnectionSettings.java | 23 +-
.../commons/influx/InfluxDbReservedKeywords.java | 150 ++++----
.../commons/influx/InfluxNameSanitizer.java | 12 +-
.../dataexplorer/commons/influx/InfluxStore.java | 8 +-
streampipes-data-explorer/pom.xml | 13 +-
.../dataexplorer/DataLakeManagementV4.java | 378 ++++++++++----------
.../dataexplorer/DataLakeNoUserManagementV3.java | 20 +-
.../dataexplorer/param/QueryParams.java | 8 +-
.../param/RetentionPolicyQueryParams.java | 22 +-
.../dataexplorer/query/DataExplorerQuery.java | 14 +-
.../query/DataExplorerQueryBuilder.java | 8 +-
.../dataexplorer/query/DeleteDataQuery.java | 1 +
.../query/EditRetentionPolicyQuery.java | 77 ++--
.../query/ParameterizedDataExplorerQuery.java | 6 +-
.../query/ShowRetentionPolicyQuery.java | 46 +--
.../dataexplorer/sdk/DataLakeQueryBuilder.java | 29 +-
.../dataexplorer/sdk/DataLakeQueryOrdering.java | 2 +-
.../dataexplorer/template/QueryTemplates.java | 6 +-
.../dataexplorer/utils/DataExplorerUtils.java | 15 +-
.../dataexplorer/v4/AutoAggregationHandler.java | 23 +-
.../dataexplorer/v4/ProvidedQueryParams.java | 4 +-
.../v4/SupportedDataLakeQueryParameters.java | 36 +-
.../v4/params/DeleteFromStatementParams.java | 12 +-
.../dataexplorer/v4/params/FillParams.java | 21 +-
.../v4/params/GroupingByTagsParams.java | 26 +-
.../v4/params/GroupingByTimeParams.java | 22 +-
.../v4/params/ItemLimitationParams.java | 22 +-
.../dataexplorer/v4/params/OffsetParams.java | 22 +-
.../v4/params/OrderingByTimeParams.java | 22 +-
.../dataexplorer/v4/params/QueryParamsV4.java | 14 +-
.../dataexplorer/v4/params/SelectColumn.java | 41 +--
.../v4/params/SelectFromStatementParams.java | 99 +++---
.../dataexplorer/v4/params/TimeBoundaryParams.java | 32 +-
.../dataexplorer/v4/params/WhereCondition.java | 8 +-
.../v4/params/WhereStatementParams.java | 52 +--
.../dataexplorer/v4/query/DataExplorerQueryV4.java | 287 ++++++++-------
.../dataexplorer/v4/query/QueryBuilder.java | 51 +--
.../dataexplorer/v4/query/QueryResultProvider.java | 4 +-
.../v4/query/StreamedQueryResultProvider.java | 3 +-
.../v4/query/elements/DeleteFromStatement.java | 14 +-
.../v4/query/elements/FillStatement.java | 14 +-
.../v4/query/elements/GroupingByTags.java | 30 +-
.../v4/query/elements/GroupingByTime.java | 14 +-
.../v4/query/elements/ItemLimitation.java | 14 +-
.../dataexplorer/v4/query/elements/Offset.java | 14 +-
.../v4/query/elements/OrderingByTime.java | 14 +-
.../v4/query/elements/QueryElement.java | 18 +-
.../v4/query/elements/SelectFromStatement.java | 2 +-
.../v4/query/elements/TimeBoundary.java | 24 +-
.../query/writer/ConfiguredJsonOutputWriter.java | 3 +-
.../v4/query/writer/ConfiguredOutputWriter.java | 4 +-
.../v4/query/writer/item/ItemGenerator.java | 2 +-
.../dataexplorer/v4/template/QueryTemplatesV4.java | 124 +++----
.../v4/utils/DataLakeManagementUtils.java | 60 +++-
.../dataexplorer/v4/utils/TimeParser.java | 4 +-
.../writer/TestConfiguredCsvOutputWriter.java | 3 +-
.../writer/TestConfiguredJsonOutputWriter.java | 5 +-
.../v4/query/writer/item/TestCsvItemWriter.java | 1 +
.../v4/query/writer/item/TestJsonItemWriter.java | 5 +-
streampipes-dataformat-cbor/pom.xml | 13 +-
.../dataformat/cbor/CborDataFormatDefinition.java | 5 +-
streampipes-dataformat-fst/pom.xml | 13 +-
.../dataformat/fst/FstDataFormatDefinition.java | 3 +-
streampipes-dataformat-json/pom.xml | 14 +-
.../dataformat/json/JsonDataFormatDefinition.java | 5 +-
streampipes-dataformat-smile/pom.xml | 13 +-
.../smile/SmileDataFormatDefinition.java | 5 +-
streampipes-dataformat/pom.xml | 14 +-
.../dataformat/SpDataFormatManager.java | 18 +-
streampipes-logging/pom.xml | 11 +-
.../apache/streampipes/logging/LoggerFactory.java | 6 +-
.../org/apache/streampipes/logging/api/Logger.java | 10 +-
.../logging/impl/EventStatisticLogger.java | 8 +-
.../apache/streampipes/logging/impl/PeLogger.java | 52 +--
.../streampipes/logging/model/LogRequest.java | 42 +--
streampipes-model-client/pom.xml | 158 +++++----
.../apache/streampipes/model/client/Category.java | 65 ++--
.../model/client/RunningVisualization.java | 6 +-
.../model/client/connection/Connection.java | 49 ++-
.../client/deployment/DeploymentConfiguration.java | 214 +++++------
.../model/client/deployment/DeploymentType.java | 2 +-
.../model/client/deployment/ElementType.java | 2 +-
.../model/client/deployment/OutputType.java | 2 +-
.../model/client/deployment/RuntimeType.java | 2 +-
.../client/endpoint/ExtensionsServiceEndpoint.java | 52 +--
.../endpoint/ExtensionsServiceEndpointItem.java | 172 ++++-----
.../exception/InvalidConnectionException.java | 26 +-
.../client/matching/MatchingResultFactory.java | 16 +-
.../client/matching/MatchingResultMessage.java | 166 ++++-----
.../model/client/matching/MatchingResultType.java | 57 +--
.../model/client/monitoring/JobReport.java | 65 ++--
.../model/client/monitoring/TaskReport.java | 66 ++--
.../monitoring/pipeline/AbstractBurrowInfo.java | 40 +--
.../pipeline/BurrowConsumerGroupStatus.java | 116 +++---
.../pipeline/BurrowConsumerGroupStatusInfo.java | 24 +-
.../monitoring/pipeline/BurrowConsumerInfo.java | 34 +-
.../monitoring/pipeline/BurrowTopicInfo.java | 26 +-
.../streampipes/model/client/ontology/Concept.java | 51 ++-
.../streampipes/model/client/ontology/Context.java | 80 ++---
.../model/client/ontology/ElementHeader.java | 101 +++---
.../model/client/ontology/ElementType.java | 2 +-
.../model/client/ontology/EnumeratedRange.java | 38 +-
.../model/client/ontology/EnumeratedValue.java | 51 +--
.../model/client/ontology/Instance.java | 47 ++-
.../model/client/ontology/Namespace.java | 50 +--
.../model/client/ontology/NodeType.java | 2 +-
.../model/client/ontology/OntologyElement.java | 76 ++--
.../model/client/ontology/OntologyNode.java | 177 +++++-----
.../model/client/ontology/OntologyQuery.java | 58 +--
.../model/client/ontology/OntologyQueryItem.java | 49 +--
.../client/ontology/OntologyQueryResponse.java | 71 ++--
.../model/client/ontology/PrimitiveRange.java | 60 ++--
.../model/client/ontology/Property.java | 123 +++----
.../client/ontology/QuantitativeValueRange.java | 74 ++--
.../streampipes/model/client/ontology/Range.java | 71 ++--
.../model/client/ontology/RangeType.java | 2 +-
.../model/client/ontology/RdfFormat.java | 2 +-
.../model/client/ontology/Resource.java | 69 ++--
.../model/client/ontology/Statement.java | 57 +--
.../model/client/setup/InitialSettings.java | 116 +++---
.../model/client/user/ChangePasswordRequest.java | 8 +-
.../streampipes/model/client/user/Element.java | 55 ++-
.../streampipes/model/client/user/Group.java | 13 +-
.../client/user/JwtAuthenticationResponse.java | 26 +-
.../model/client/user/LoginRequest.java | 57 +--
.../model/client/user/PasswordRecoveryToken.java | 18 +-
.../streampipes/model/client/user/Permission.java | 13 +-
.../model/client/user/PermissionBuilder.java | 20 +-
.../model/client/user/PermissionEntry.java | 8 +-
.../streampipes/model/client/user/Principal.java | 231 ++++++------
.../model/client/user/RegistrationData.java | 84 ++---
.../apache/streampipes/model/client/user/Role.java | 76 ++--
.../model/client/user/ServiceAccount.java | 12 +-
.../streampipes/model/client/user/Token.java | 53 ++-
.../streampipes/model/client/user/UserAccount.java | 263 +++++++-------
.../model/client/user/UserActivationToken.java | 16 +-
streampipes-model-shared/pom.xml | 9 +-
streampipes-model/pom.xml | 7 +-
.../org/apache/streampipes/model/AdapterType.java | 17 +-
.../apache/streampipes/model/ApplicationLink.java | 105 +++---
.../streampipes/model/DataProcessorType.java | 79 +++--
.../org/apache/streampipes/model/DataSinkType.java | 13 +-
.../streampipes/model/NotificationCount.java | 26 +-
.../org/apache/streampipes/model/Response.java | 155 ++++----
.../org/apache/streampipes/model/SpDataSet.java | 20 +-
.../org/apache/streampipes/model/SpDataStream.java | 30 +-
.../streampipes/model/SpDataStreamContainer.java | 4 +-
.../streampipes/model/StreamPipesErrorMessage.java | 23 +-
.../java/org/apache/streampipes/model/Tuple2.java | 30 +-
.../apache/streampipes/model/VirtualSensor.java | 52 ++-
.../apache/streampipes/model/assets/AssetLink.java | 8 +-
.../streampipes/model/assets/AssetLinkType.java | 3 +-
.../streampipes/model/assets/SpAssetModel.java | 5 +-
.../model/base/AbstractStreamPipesEntity.java | 49 +--
.../model/base/InvocableStreamPipesEntity.java | 4 +-
.../model/base/NamedStreamPipesEntity.java | 30 +-
.../model/canvas/PipelineCanvasMetadata.java | 3 +-
.../model/connect/adapter/AdapterDescription.java | 16 +-
.../connect/adapter/AdapterSetDescription.java | 45 +--
.../connect/adapter/AdapterStreamDescription.java | 64 ++--
.../connect/adapter/GenericAdapterDescription.java | 8 +-
.../adapter/GenericAdapterSetDescription.java | 68 ++--
.../adapter/GenericAdapterStreamDescription.java | 20 +-
.../adapter/SpecificAdapterSetDescription.java | 10 +-
.../model/connect/grounding/FormatDescription.java | 104 +++---
.../connect/grounding/ProtocolDescription.java | 88 ++---
.../connect/grounding/ProtocolSetDescription.java | 22 +-
.../grounding/ProtocolStreamDescription.java | 22 +-
.../model/connect/guess/FieldStatusInfo.java | 6 +-
.../model/connect/guess/GuessSchema.java | 83 ++---
.../connect/rules/DebugSinkRuleDescription.java | 6 +-
.../rules/TransformationRuleDescription.java | 48 +--
.../rules/schema/DeleteRuleDescription.java | 36 +-
.../rules/schema/RenameRuleDescription.java | 54 +--
.../SchemaTransformationRuleDescription.java | 12 +-
.../EventRateTransformationRuleDescription.java | 44 +--
...oveDuplicatesTransformationRuleDescription.java | 28 +-
.../StreamTransformationRuleDescription.java | 19 +-
.../rules/value/AddTimestampRuleDescription.java | 28 +-
.../AddValueTransformationRuleDescription.java | 44 +--
...rrectionValueTransformationRuleDescription.java | 74 ++--
.../TimestampTranfsformationRuleDescription.java | 90 ++---
.../value/TimestampTransformationRuleMode.java | 4 +-
.../rules/value/UnitTransformRuleDescription.java | 72 ++--
.../value/ValueTransformationRuleDescription.java | 25 +-
.../model/connect/unit/UnitDescription.java | 40 +--
.../model/dashboard/DashboardEntity.java | 7 +-
.../streampipes/model/dashboard/DashboardItem.java | 2 +-
.../model/dashboard/DashboardModel.java | 3 +-
.../model/dashboard/DashboardWidgetModel.java | 2 +-
.../model/datalake/DataExplorerWidgetModel.java | 10 +-
.../model/datalake/DataLakeConfiguration.java | 83 ++---
.../model/datalake/DataLakeMeasure.java | 22 +-
.../model/datalake/DataLakeRetentionPolicy.java | 89 +++--
.../streampipes/model/datalake/DataSeries.java | 64 ++--
.../model/datalake/LabelDefinition.java | 36 +-
.../streampipes/model/datalake/PageResult.java | 39 +-
.../streampipes/model/datalake/SpQueryResult.java | 126 +++----
.../streampipes/model/datalake/SpQueryStatus.java | 4 +-
.../streampipes/model/file/FileMetadata.java | 9 +-
.../model/function/FunctionDefinition.java | 8 +-
.../streampipes/model/function/FunctionId.java | 23 +-
.../model/graph/DataProcessorDescription.java | 4 +-
.../model/graph/DataProcessorInvocation.java | 5 +-
.../model/graph/DataSinkDescription.java | 66 ++--
.../model/graph/DataSinkInvocation.java | 2 +-
.../model/graph/DataSourceDescription.java | 10 +-
.../model/graph/PipelineElementContainer.java | 3 +-
.../model/grounding/EventGrounding.java | 103 +++---
.../model/grounding/JmsTransportProtocol.java | 63 ++--
.../model/grounding/KafkaTransportProtocol.java | 11 +-
.../model/grounding/MqttTransportProtocol.java | 26 +-
.../model/grounding/NatsTransportProtocol.java | 25 +-
.../model/grounding/TopicDefinition.java | 7 +-
.../model/grounding/TransportFormat.java | 59 ++--
.../model/grounding/TransportProtocol.java | 80 ++---
.../streampipes/model/labeling/Category.java | 95 ++---
.../apache/streampipes/model/labeling/Label.java | 109 +++---
.../org/apache/streampipes/model/mail/SpEmail.java | 16 +-
.../model/message/DataSetModificationMessage.java | 2 +-
.../model/message/EdgeValidationStatus.java | 2 +-
.../streampipes/model/message/ErrorMessage.java | 31 +-
.../apache/streampipes/model/message/Message.java | 129 ++++---
.../model/message/NotificationType.java | 143 ++++----
.../streampipes/model/message/Notifications.java | 70 ++--
.../model/message/PipelineEdgeValidation.java | 22 +-
.../model/message/PipelineModificationMessage.java | 128 +++----
.../model/message/PipelineStatusMessage.java | 88 ++---
.../model/message/PipelineStatusMessageType.java | 46 +--
.../model/message/SetupStatusMessage.java | 19 +-
.../streampipes/model/message/SuccessMessage.java | 30 +-
.../monitoring/ElementStatusInfoSettings.java | 2 +-
.../model/monitoring/MessageCounter.java | 16 +-
.../streampipes/model/monitoring/SpLogEntry.java | 20 +-
.../output/CustomTransformOutputStrategy.java | 3 +-
.../streampipes/model/output/OutputStrategy.java | 19 +-
.../model/output/TransformOperation.java | 2 +-
.../streampipes/model/pipeline/Pipeline.java | 5 +-
.../model/pipeline/PipelineCategory.java | 107 +++---
.../pipeline/PipelineElementRecommendation.java | 111 +++---
.../PipelineElementRecommendationMessage.java | 84 +++--
.../model/pipeline/PipelineElementStatus.java | 75 ++--
.../pipeline/PipelineElementValidationInfo.java | 64 ++--
.../model/pipeline/PipelineOperationStatus.java | 132 ++++---
.../apache/streampipes/model/quality/Accuracy.java | 49 ++-
.../quality/EventPropertyQualityDefinition.java | 29 +-
.../quality/EventPropertyQualityRequirement.java | 106 +++---
.../quality/EventStreamQualityDefinition.java | 18 +-
.../quality/EventStreamQualityRequirement.java | 64 ++--
.../streampipes/model/quality/Frequency.java | 59 ++--
.../apache/streampipes/model/quality/Latency.java | 80 ++---
.../model/quality/MeasurementCapability.java | 54 +--
.../model/quality/MeasurementObject.java | 54 +--
.../model/quality/MeasurementProperty.java | 23 +-
.../model/quality/MeasurementRange.java | 74 ++--
.../streampipes/model/quality/Precision.java | 48 +--
.../streampipes/model/quality/Resolution.java | 48 +--
.../apache/streampipes/model/runtime/Event.java | 13 +-
.../streampipes/model/runtime/EventConverter.java | 7 +-
.../streampipes/model/runtime/EventFactory.java | 35 +-
.../streampipes/model/runtime/SchemaInfo.java | 8 +-
.../model/runtime/field/AbstractField.java | 12 +-
.../model/runtime/field/FieldParser.java | 4 +-
.../streampipes/model/runtime/field/ListField.java | 16 +-
.../streampipes/model/schema/Enumeration.java | 102 +++---
.../streampipes/model/schema/EventProperty.java | 77 ++--
.../model/schema/EventPropertyNested.java | 67 ++--
.../model/schema/EventPropertyPrimitive.java | 5 +-
.../streampipes/model/schema/EventSchema.java | 13 +-
.../streampipes/model/schema/PropertyScope.java | 7 +-
.../model/schema/QuantitativeValue.java | 100 +++---
.../model/schema/ValueSpecification.java | 25 +-
.../model/staticproperty/AnyStaticProperty.java | 2 +-
.../staticproperty/CollectionStaticProperty.java | 8 +-
.../model/staticproperty/DomainStaticProperty.java | 6 +-
.../staticproperty/FreeTextStaticProperty.java | 16 +-
.../model/staticproperty/MappingProperty.java | 11 +-
.../model/staticproperty/MappingPropertyNary.java | 2 +-
.../model/staticproperty/MappingPropertyUnary.java | 2 +-
.../staticproperty/MatchingStaticProperty.java | 80 ++---
.../model/staticproperty/OneOfStaticProperty.java | 2 +-
.../streampipes/model/staticproperty/Option.java | 125 ++++---
.../staticproperty/PropertyValueSpecification.java | 104 +++---
.../staticproperty/RemoteOneOfStaticProperty.java | 7 +-
.../RuntimeResolvableAnyStaticProperty.java | 3 +-
.../RuntimeResolvableOneOfStaticProperty.java | 6 +-
.../model/staticproperty/SecretStaticProperty.java | 7 +-
.../staticproperty/SelectionStaticProperty.java | 22 +-
.../model/staticproperty/StaticProperty.java | 52 ++-
.../staticproperty/StaticPropertyAlternative.java | 2 +-
.../staticproperty/StaticPropertyAlternatives.java | 8 +-
.../model/staticproperty/StaticPropertyGroup.java | 19 +-
.../model/staticproperty/StaticPropertyType.java | 38 +-
.../model/staticproperty/TreeInputNode.java | 3 +-
.../model/template/PipelineElementTemplate.java | 8 +-
.../template/PipelineElementTemplateConfig.java | 8 +-
.../template/PipelineTemplateDescription.java | 3 +-
.../PipelineTemplateDescriptionContainer.java | 2 +-
.../model/template/PipelineTemplateInvocation.java | 4 +-
.../org/apache/streampipes/model/util/Cloner.java | 92 +++--
.../streampipes/model/util/ElementIdGenerator.java | 6 +-
.../apache/streampipes/model/util/EventUtils.java | 2 +-
.../apache/streampipes/model/util/ModelUtils.java | 75 ++--
.../streampipes/model/util/PropertyUtils.java | 4 +-
.../apache/streampipes/model/util/SchemaUtils.java | 15 +-
.../connect/adapter/AdapterDescriptionTest.java | 65 ++--
.../model/datalake/DataLakeMeasureTest.java | 25 +-
.../model/runtime/RuntimeTestUtils.java | 8 +-
.../streampipes/model/runtime/TestEvent.java | 27 +-
.../model/runtime/TestEventConverter.java | 6 +-
.../model/runtime/TestEventFactory.java | 4 +-
.../model/runtime/TestFieldAddition.java | 6 +-
.../streampipes/model/runtime/TestListField.java | 6 +-
.../model/runtime/TestPropertyRenaming.java | 8 +-
.../streampipes/model/runtime/TestSubset.java | 6 +-
.../manager/data/PipelineGraphBuilder.java | 4 +-
.../manager/matching/ConnectionValidator.java | 2 +-
.../matching/PipelineModificationGenerator.java | 10 +-
.../matching/PipelineVerificationHandlerV2.java | 2 +-
.../pipeline/AbstractPipelineValidationStep.java | 9 +-
.../matching/v2/pipeline/ApplyGroundingStep.java | 8 +-
.../matching/v2/pipeline/ComputeOutputStep.java | 6 +-
.../matching/v2/pipeline/SchemaValidationStep.java | 2 +-
.../manager/preview/ActivePipelinePreviews.java | 2 +-
.../manager/preview/PipelinePreview.java | 2 +-
.../manager/recommender/AllElementsProvider.java | 2 +-
.../manager/template/PipelineGenerator.java | 10 +-
.../PipelineTemplateInvocationGenerator.java | 4 +-
.../PipelineTemplateInvocationHandler.java | 4 +-
.../apache/streampipes/manager/util/TreeUtils.java | 4 +-
.../streampipes/manager/matching/v2/TestUtils.java | 8 +-
.../apache/streampipes/ps/DataLakeResourceV4.java | 2 +-
streampipes-serializers-json/pom.xml | 12 +-
.../serializers/json/JacksonSerializer.java | 3 +-
.../serializers/json/TestJacksonSerializer.java | 28 +-
streampipes-storage-api/pom.xml | 11 +-
.../streampipes/storage/api/CRUDStorage.java | 12 +-
.../streampipes/storage/api/IAdapterStorage.java | 10 +-
.../streampipes/storage/api/ICategoryStorage.java | 11 +-
.../streampipes/storage/api/IDataLakeStorage.java | 10 +-
.../api/IExtensionsServiceEndpointStorage.java | 6 +-
.../streampipes/storage/api/ILabelStorage.java | 14 +-
.../storage/api/IOntologyContextStorage.java | 14 +-
.../storage/api/IPipelineCategoryStorage.java | 16 +-
.../api/IPipelineElementConnectionStorage.java | 8 +-
.../api/IPipelineElementDescriptionStorage.java | 150 ++++----
.../api/IPipelineMonitoringDataStorage.java | 18 +-
.../streampipes/storage/api/IPipelineStorage.java | 20 +-
.../streampipes/storage/api/IUserStorage.java | 4 +-
.../storage/api/IVisualizationStorage.java | 6 +-
streampipes-storage-couchdb/pom.xml | 11 +-
.../storage/couchdb/CouchDbStorageManager.java | 71 +++-
.../storage/couchdb/dao/AbstractDao.java | 3 +-
.../streampipes/storage/couchdb/dao/CrudDao.java | 5 +-
.../storage/couchdb/dao/CrudViewDao.java | 14 +-
.../streampipes/storage/couchdb/dao/DbCommand.java | 14 +-
.../storage/couchdb/dao/FindAllCommand.java | 4 +-
.../storage/couchdb/dao/PersistCommand.java | 1 +
.../impl/AdapterDescriptionStorageImpl.java | 57 +--
.../couchdb/impl/AdapterInstanceStorageImpl.java | 61 ++--
.../storage/couchdb/impl/CategoryStorageImpl.java | 56 +--
.../couchdb/impl/ConnectionStorageImpl.java | 35 +-
.../couchdb/impl/DashboardWidgetStorageImpl.java | 2 +-
.../impl/DataExplorerWidgetStorageImpl.java | 7 +-
.../storage/couchdb/impl/DataLakeStorageImpl.java | 58 +--
.../couchdb/impl/DataProcessorStorageImpl.java | 8 +-
.../storage/couchdb/impl/DataSinkStorageImpl.java | 8 +-
.../couchdb/impl/DataStreamStorageImpl.java | 8 +-
.../impl/ExtensionsServiceEndpointStorageImpl.java | 3 +-
.../couchdb/impl/FileMetadataStorageImpl.java | 15 +-
.../storage/couchdb/impl/GenericStorageImpl.java | 13 +-
.../storage/couchdb/impl/ImageStorageImpl.java | 1 +
.../storage/couchdb/impl/LabelStorageImpl.java | 74 ++--
.../couchdb/impl/MonitoringDataStorageImpl.java | 60 ++--
.../couchdb/impl/NotificationStorageImpl.java | 57 +--
.../couchdb/impl/PermissionStorageImpl.java | 20 +-
.../impl/PipelineCanvasMetadataStorageImpl.java | 10 +-
.../couchdb/impl/PipelineCategoryStorageImpl.java | 36 +-
.../impl/PipelineElementTemplateStorageImpl.java | 9 +-
.../storage/couchdb/impl/PipelineStorageImpl.java | 30 +-
.../storage/couchdb/impl/UserGroupStorageImpl.java | 2 +-
.../storage/couchdb/impl/UserStorage.java | 17 +-
.../couchdb/impl/VisualizationStorageImpl.java | 75 ++--
.../couchdb/serializer/AdapterSerializer.java | 15 +-
.../couchdb/serializer/AdapterTypeAdapter.java | 3 +-
.../storage/couchdb/serializer/EcTypeAdapter.java | 3 +-
.../storage/couchdb/serializer/EpaTypeAdapter.java | 43 ++-
.../storage/couchdb/serializer/GsonSerializer.java | 89 +++--
.../couchdb/serializer/PrincipalDeserializer.java | 13 +-
.../couchdb/serializer/RangeSerializer.java | 23 +-
.../serializer/RuntimeTypeAdapterFactory.java | 26 +-
.../storage/couchdb/serializer/UriSerializer.java | 16 +-
.../storage/couchdb/utils/CouchDbConfig.java | 58 +--
.../couchdb/utils/CouchDbViewGenerator.java | 31 +-
.../streampipes/storage/couchdb/utils/Filter.java | 6 +-
.../streampipes/storage/couchdb/utils/Utils.java | 23 +-
.../couchdb/serializer/TestGsonSerializer.java | 21 +-
streampipes-storage-management/pom.xml | 11 +-
streampipes-test-utils/pom.xml | 13 +-
.../test/generator/EventStreamGenerator.java | 10 +-
.../test/generator/InvocationGraphGenerator.java | 3 +-
.../generator/pipeline/DummyPipelineGenerator.java | 26 +-
.../pipelineelement/DummyProcessorGenerator.java | 10 +-
.../pipelineelement/DummySinkGenerator.java | 10 +-
.../pipelineelement/DummyStreamGenerator.java | 24 +-
tools/maven/checkstyle.xml | 4 +
431 files changed, 8370 insertions(+), 7093 deletions(-)
create mode 100644 streampipes-client-python/docs/examples/1-introduction-to-streampipes-python-client.ipynb
create mode 100644 streampipes-client-python/docs/examples/2-extracting-data-from-the-streampipes-data-lake.ipynb