You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by gi...@apache.org on 2023/01/04 19:46:58 UTC
[streampipes] branch dependabot/npm_and_yarn/ui/codemirror-6.0.1 updated (89cc5cb1b -> 7a35c8ea6)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch dependabot/npm_and_yarn/ui/codemirror-6.0.1
in repository https://gitbox.apache.org/repos/asf/streampipes.git
discard 89cc5cb1b Bump codemirror from 5.65.11 to 6.0.1 in /ui
add 9cbc3cbfb Bump Spring versions, migrate Spring Security classes (#1015)
add 8afcce431 Merge branch 'dev' into SP-1015
add 9ace8caaf Bump Spring Boot to v3, use jakarta imports (#1015)
add 5a091c6ce Improve formatting of pom file
add 2b5c45b34 Bump @typescript-eslint/parser from 5.47.0 to 5.48.0 in /ui
add bfeb0a49a Bump archetype-packaging from 3.0.1 to 3.2.1
add 71714f3aa [hotfix] Update Java version in Jenkinsfile
add e7fa3019c Bump @typescript-eslint/eslint-plugin from 5.47.0 to 5.48.0 in /ui
add 60ebf2116 Sp 1026 (#1027) Fix unit test and activate them in actions
add a8eed61db Merge branch 'dev' into SP-1015
add 0d42d9a9d Resolve dependency convergence issues (#1015)
add e71e561f4 Fix dependency convergence in sinks-databases modules (#1015)
add 49d108127 [hotfix] Remove old connect-container-worker dependencies
add a329f87da [hotfix] Change dependency in service-extensions
add 8a67bdcce [hotfix] Properly serialize type
add 7e960ba1f Merge branch 'dev' of github.com:apache/streampipes into dev
add 4993474da [hotfix] Add checkstyle to module wrapper-siddhi (#1028)
add a19b5cc0a Merge branch 'dev' into SP-1015
add 8fd6e0800 Resolve dependency convergence (#1015)
add e8565e3f0 Merge pull request #1016 from apache/SP-1015
add 7a35c8ea6 Bump codemirror from 5.65.11 to 6.0.1 in /ui
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (89cc5cb1b)
\
N -- N -- N refs/heads/dependabot/npm_and_yarn/ui/codemirror-6.0.1 (7a35c8ea6)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/workflows/build.yml | 2 +-
.github/workflows/cypress-test.yml | 2 +-
.github/workflows/pr-validation.yml | 4 +-
.idea/runConfigurations/{backend.xml => core.xml} | 6 +-
Jenkinsfile | 2 +-
.../streampipes-archetype-extensions-jvm/pom.xml | 2 +-
.../pom.xml | 2 +-
.../streampipes-archetype-pe-sinks-flink/pom.xml | 2 +-
pom.xml | 2206 ++++++++++----------
streampipes-commons/pom.xml | 2 +-
streampipes-connect-management/pom.xml | 10 -
.../management/health/AdapterHealthCheckTest.java | 122 --
.../management/AdapterMasterManagementTest.java | 5 +-
.../management/DescriptionManagementTest.java | 65 -
.../management/UnitMasterManagementTest.java | 128 --
.../management/WorkerRestClientTest.java | 141 --
.../v4/params/SelectFromStatementParams.java | 1 +
streampipes-extensions-management/pom.xml | 5 -
.../adapter/format/json/arraykey/JsonParser.java | 5 +-
.../format/json/arraynokey/JsonArrayParser.java | 5 +-
.../connect/AdapterWorkerManagementTest.java | 19 +-
.../extensions/management/connect/Mock.java | 26 -
.../extensions/management/connect/Utils.java | 4 +-
.../connect/adapter/GroundingServiceTest.java | 80 -
.../format/json/arraykey/JsonParserTest.java | 7 +-
.../json/arraynokey/JsonArrayParserTest.java | 8 +-
.../adapter/format/json/geojson/GeoJsonTest.java | 362 ++--
.../format/json/object/JsonObjectParserTest.java | 6 +-
.../connect/adapter/format/json/xml/XmlTest.java | 511 ++---
.../schema/CreateNestedTransformationRuleTest.java | 1 +
.../schema/DeleteTransformationRuleTest.java | 3 +-
.../schema/MoveTransformationRuleTest.java | 1 +
.../schema/RenameTransformationRuleTest.java | 1 +
.../schema/SchemaEventTransformerTest.java | 16 +-
.../value/TimestampTransformRuleTest.java | 244 ---
.../transform/value/UnitTransformRuleTest.java | 13 +-
.../streampipes-connect-adapters-iiot/pom.xml | 23 +-
.../adapters/opcua/utils/OpcUaNodeVariants.java | 2 +-
.../streampipes-connect-adapters/pom.xml | 15 +-
.../connect/adapters/coindesk/model/Bpi.java | 3 +-
.../adapters/coindesk/model/CoindeskRawModel.java | 2 +-
.../connect/adapters/coindesk/model/EUR.java | 3 +-
.../connect/adapters/coindesk/model/GBP.java | 2 +-
.../connect/adapters/coindesk/model/Time.java | 2 +-
.../connect/adapters/coindesk/model/USD.java | 2 +-
.../connect/adapters/flic/FlicOutput.java | 2 +-
.../connect/adapters/iex/model/IexNewsData.java | 2 +-
.../connect/adapters/iex/model/IexStockData.java | 2 +-
.../connect/adapters/iss/model/IssModel.java | 2 +-
.../connect/adapters/iss/model/IssPosition.java | 2 +-
.../adapters/netio/model/NetioAllPowerOutputs.java | 2 +-
.../adapters/netio/model/NetioGlobalMeasure.java | 2 +-
.../adapters/netio/model/NetioPowerOutput.java | 2 +-
.../adapters/sensemap/model/CurrentLocation.java | 2 +-
.../connect/adapters/sensemap/model/Geometry.java | 2 +-
.../adapters/sensemap/model/LastMeasurement.java | 2 +-
.../connect/adapters/sensemap/model/Loc.java | 2 +-
.../connect/adapters/sensemap/model/SenseBox.java | 2 +-
.../connect/adapters/sensemap/model/Sensor.java | 2 +-
.../adapters/wikipedia/WikipediaSseConsumer.java | 6 +-
.../connect/adapters/wikipedia/model/Length.java | 2 +-
.../connect/adapters/wikipedia/model/Meta.java | 2 +-
.../connect/adapters/wikipedia/model/Revision.java | 2 +-
.../adapters/wikipedia/model/WikipediaModel.java | 2 +-
.../pom.xml | 25 -
.../processor/aggregation/AggregationTestData.java | 67 -
.../aggregation/TestTimeAggregationProgram.java | 82 -
.../flink/processor/count/TestCountProgram.java | 135 --
.../flink/processor/rate/TestRateProgram.java | 129 --
.../pom.xml | 14 -
.../detection/processor/absence/TestAbsence.java | 125 --
.../pattern/detection/processor/and/TestAnd.java | 135 --
.../pom.xml | 23 -
.../pom.xml | 15 -
.../processor/converter/TestConverterProgram.java | 95 -
.../flink/processor/hasher/TestFieldHasher.java | 124 --
.../hasher/TestFieldHasherController.java | 38 -
.../processor/hasher/TestFieldHasherProgram.java | 84 -
.../processor/hasher/TestFieldHasherUtils.java | 44 -
.../flink/processor/rename/TestRenameProgram.java | 102 -
.../transformation/flink/utils/DummyCollector.java | 48 -
.../elastic/Elasticsearch6ApiCallBridge.java | 4 +-
.../elastic/ElasticsearchApiCallBridge.java | 4 +-
.../streampipes-sinks-databases-jvm/pom.xml | 6 +
.../apache/streampipes/mail/AbstractMailer.java | 3 +-
streampipes-maven-plugin/pom.xml | 6 -
.../smp/extractor/TestDockerImageExtractor.java | 44 -
.../streampipes/model/client/user/Permission.java | 2 +
.../streampipes/manager/ThrowableCaptor.java | 42 -
.../manager/assets/TestImagePathReplacer.java | 31 +-
.../manager/matching/TestPipelineModification.java | 66 -
.../matching/TestPipelineValidationHandler.java | 64 -
.../streampipes/manager/matching/TestRdfId.java | 49 -
.../manager/matching/v2/ListPropertyMatchTest.java | 4 +-
.../manager/matching/v2/TestDatatypeMatch.java | 6 +-
.../matching/v2/TestDomainPropertyMatch.java | 9 +-
.../matching/v2/TestElementVerification.java | 41 -
.../manager/matching/v2/TestFormatMatch.java | 6 +-
.../manager/matching/v2/TestGroundingMatch.java | 21 +-
.../matching/v2/TestMeasurementUnitMatch.java | 5 +-
.../matching/v2/TestPrimitivePropertyMatch.java | 6 +-
.../manager/matching/v2/TestProtocolMatch.java | 6 +-
.../manager/matching/v2/TestSchemaMatch.java | 6 +-
.../streampipes/manager/matching/v2/TestUtils.java | 59 -
.../manager/pipeline/TestPipelineManager.java | 9 -
.../pipeline/TestPipelinesContainingElements.java | 89 -
.../manager/selector/TestPropertyRenaming.java | 1 -
.../streampipes/manager/selector/TestSelector.java | 9 +-
streampipes-platform-services/pom.xml | 2 +-
.../streampipes/ps/DataLakeImageResource.java | 10 +-
.../streampipes/ps/DataLakeMeasureResourceV3.java | 14 +-
.../streampipes/ps/DataLakeMeasureResourceV4.java | 20 +-
.../apache/streampipes/ps/DataLakeResourceV3.java | 10 +-
.../apache/streampipes/ps/DataLakeResourceV4.java | 30 +-
.../ps/PipelineElementTemplateResource.java | 22 +-
.../base/impl/AbstractAuthGuardedRestResource.java | 4 +-
.../rest/core/base/impl/AbstractRestResource.java | 2 +-
streampipes-rest-extensions/pom.xml | 6 +-
.../extensions/AbstractExtensionsResource.java | 2 +-
.../AbstractPipelineElementResource.java | 12 +-
.../streampipes/rest/extensions/WelcomePage.java | 8 +-
.../extensions/connect/AdapterAssetResource.java | 12 +-
.../extensions/connect/AdapterWorkerResource.java | 14 +-
.../rest/extensions/connect/GuessResource.java | 10 +-
.../connect/HttpServerAdapterResource.java | 8 +-
.../connect/RuntimeResolvableResource.java | 16 +-
.../extensions/monitoring/MonitoringResource.java | 10 +-
.../pe/DataProcessorPipelineElementResource.java | 2 +-
.../pe/DataSinkPipelineElementResource.java | 2 +-
.../pe/DataStreamPipelineElementResource.java | 24 +-
.../pe/InvocablePipelineElementResource.java | 30 +-
.../extensions/pe/PipelineTemplateResource.java | 2 +-
streampipes-rest-shared/pom.xml | 10 +-
.../rest/shared/annotation/JacksonSerialized.java | 2 +-
.../streampipes/rest/shared/api/CRUDResource.java | 2 +-
.../shared/impl/AbstractSharedRestInterface.java | 2 +-
.../serializer/JacksonSerializationProvider.java | 8 +-
.../rest/shared/serializer/JsonJerseyProvider.java | 10 +-
.../streampipes/rest/shared/util/SpMediaType.java | 2 +-
streampipes-rest/pom.xml | 2 +-
.../rest/filter/TokenAuthenticationFilter.java | 8 +-
.../rest/impl/AbstractMonitoringResource.java | 4 +-
.../rest/impl/AccountActivationResource.java | 14 +-
.../rest/impl/AdapterMonitoringResource.java | 12 +-
.../rest/impl/AssetDashboardResource.java | 18 +-
.../rest/impl/AssetManagementResource.java | 20 +-
.../streampipes/rest/impl/Authentication.java | 18 +-
.../apache/streampipes/rest/impl/AutoComplete.java | 12 +-
.../streampipes/rest/impl/CategoryResource.java | 20 +-
.../rest/impl/ContainerProvidedOptions.java | 12 +-
.../apache/streampipes/rest/impl/DataStream.java | 10 +-
.../streampipes/rest/impl/EmailResource.java | 10 +-
.../streampipes/rest/impl/FunctionsResource.java | 18 +-
.../rest/impl/GenericStorageResource.java | 20 +-
.../streampipes/rest/impl/LabelResource.java | 20 +-
.../rest/impl/MeasurementUnitResource.java | 12 +-
.../apache/streampipes/rest/impl/Notification.java | 22 +-
.../rest/impl/OntologyMeasurementUnit.java | 12 +-
.../streampipes/rest/impl/PipelineCache.java | 14 +-
.../rest/impl/PipelineCanvasMetadataCache.java | 14 +-
.../rest/impl/PipelineCanvasMetadataResource.java | 18 +-
.../streampipes/rest/impl/PipelineCategory.java | 18 +-
.../rest/impl/PipelineElementAsset.java | 12 +-
.../rest/impl/PipelineElementCategory.java | 10 +-
.../streampipes/rest/impl/PipelineElementFile.java | 20 +-
.../rest/impl/PipelineElementPreview.java | 18 +-
.../rest/impl/PipelineElementRuntimeInfo.java | 12 +-
.../streampipes/rest/impl/PipelineMonitoring.java | 12 +-
.../streampipes/rest/impl/PipelineResource.java | 27 +-
.../streampipes/rest/impl/PipelineTemplate.java | 14 +-
.../streampipes/rest/impl/ResetResource.java | 10 +-
.../rest/impl/RestorePasswordResource.java | 16 +-
.../org/apache/streampipes/rest/impl/Setup.java | 10 +-
.../apache/streampipes/rest/impl/UserResource.java | 22 +-
.../org/apache/streampipes/rest/impl/Version.java | 10 +-
.../streampipes/rest/impl/admin/ConsulConfig.java | 16 +-
.../rest/impl/admin/DataExportResource.java | 12 +-
.../rest/impl/admin/DataImportResource.java | 12 +-
.../impl/admin/EmailConfigurationResource.java | 16 +-
.../admin/ExtensionsServiceEndpointResource.java | 18 +-
.../impl/admin/GeneralConfigurationResource.java | 14 +-
.../rest/impl/admin/PermissionResource.java | 8 +-
.../rest/impl/admin/PipelineElementImport.java | 18 +-
.../rest/impl/admin/UserGroupResource.java | 14 +-
.../rest/impl/connect/AdapterResource.java | 20 +-
.../rest/impl/connect/DescriptionResource.java | 14 +-
.../rest/impl/connect/GuessResource.java | 12 +-
.../impl/connect/RuntimeResolvableResource.java | 14 +-
.../rest/impl/connect/SourcesResource.java | 16 +-
.../rest/impl/connect/UnitResource.java | 12 +-
.../impl/connect/WorkerAdministrationResource.java | 10 +-
.../impl/dashboard/AbstractDashboardResource.java | 18 +-
.../AbstractPipelineExtractionResource.java | 2 +-
.../streampipes/rest/impl/dashboard/Dashboard.java | 2 +-
.../rest/impl/dashboard/DashboardWidget.java | 20 +-
.../dashboard/VisualizablePipelineResource.java | 12 +-
.../impl/datalake/DataLakeDashboardResource.java | 2 +-
.../rest/impl/datalake/DataLakeWidgetResource.java | 20 +-
.../impl/datalake/PersistedDataStreamResource.java | 12 +-
.../rest/impl/pe/DataProcessorResource.java | 14 +-
.../streampipes/rest/impl/pe/DataSinkResource.java | 14 +-
.../rest/impl/pe/DataStreamResource.java | 14 +-
streampipes-service-base/pom.xml | 9 +
.../service/base/rest/ServiceHealthResource.java | 8 +-
.../security/UnauthorizedRequestEntryPoint.java | 4 +-
streampipes-service-core/pom.xml | 32 +-
.../core/StreamPipesBackendApplication.java | 4 +-
.../service/core/StreamPipesResourceConfig.java | 2 +-
.../service/core/WebSecurityConfig.java | 37 +-
streampipes-service-extensions/pom.xml | 2 +-
.../extensions/ExtensionsModelSubmitter.java | 2 +-
.../StreamPipesExtensionsServiceBase.java | 2 +-
.../security/TokenAuthenticationFilter.java | 8 +-
.../extensions/security/WebSecurityConfig.java | 42 +-
streampipes-wrapper-siddhi/pom.xml | 9 +-
.../wrapper/siddhi/SiddhiAppConfig.java | 4 +-
.../wrapper/siddhi/SiddhiAppConfigBuilder.java | 2 +-
.../wrapper/siddhi/SiddhiQueryBuilder.java | 12 +-
.../wrapper/siddhi/constants/SiddhiConstants.java | 1 -
.../wrapper/siddhi/engine/SiddhiEngine.java | 37 +-
.../wrapper/siddhi/engine/SiddhiEventEngine.java | 14 +-
.../siddhi/engine/SiddhiStatementGenerator.java | 4 +-
.../siddhi/engine/StreamPipesSiddhiProcessor.java | 11 +-
.../callback/SiddhiOutputStreamCallback.java | 29 +-
.../callback/SiddhiOutputStreamDebugCallback.java | 10 +-
.../engine/generator/EventTypeGenerator.java | 18 +-
.../engine/generator/InputStreamNameGenerator.java | 6 +-
.../engine/generator/SiddhiAppGenerator.java | 31 +-
.../generator/SiddhiInvocationConfigGenerator.java | 16 +-
.../siddhi/model/SiddhiProcessorParams.java | 20 +-
.../wrapper/siddhi/query/FromClause.java | 5 +-
.../wrapper/siddhi/query/GroupByClause.java | 2 +-
.../wrapper/siddhi/query/InsertIntoClause.java | 8 +-
.../wrapper/siddhi/query/LimitClause.java | 2 +-
.../wrapper/siddhi/query/OffsetClause.java | 2 +-
.../wrapper/siddhi/query/SelectClause.java | 4 +-
.../wrapper/siddhi/query/SiddhiQuery.java | 2 +-
.../siddhi/query/expression/Expressions.java | 8 +-
.../query/expression/PropertyRenameExpression.java | 10 +-
.../query/expression/RelationalOperator.java | 2 +-
.../expression/RelationalOperatorExpression.java | 12 +-
.../siddhi/query/expression/SiddhiTimeUnit.java | 2 +-
.../query/expression/StreamFilterExpression.java | 16 +-
.../siddhi/query/expression/WithinExpression.java | 10 +-
.../aggregation/AggregationFunction.java | 39 +-
.../expression/aggregation/AndExpression.java | 25 +-
.../expression/aggregation/AverageExpression.java | 24 +-
.../expression/aggregation/CountExpression.java | 10 +-
.../aggregation/DistinctCountExpression.java | 24 +-
.../expression/aggregation/MaxExpression.java | 25 +-
.../aggregation/MaxForeverExpression.java | 27 +-
.../expression/aggregation/MinExpression.java | 25 +-
.../aggregation/MinForeverExpression.java | 25 +-
.../query/expression/aggregation/OrExpression.java | 25 +-
.../aggregation/StandardDeviationExpression.java | 27 +-
.../expression/aggregation/SumExpression.java | 26 +-
.../expression/aggregation/UnionSetExpression.java | 25 +-
.../expression/list/CollectListExpression.java | 10 +-
.../expression/list/ContainsListExpression.java | 16 +-
.../query/expression/math/MathExpression.java | 12 +-
.../siddhi/query/expression/math/MathOperator.java | 2 +-
.../expression/orderby/OrderByExpression.java | 7 +-
.../query/expression/pattern/EveryExpression.java | 2 +-
.../expression/pattern/PatternCountExpression.java | 2 +-
.../expression/pattern/PatternCountOperator.java | 2 +-
.../expression/pattern/PatternExpression.java | 4 +-
.../expression/window/SortWindowExpression.java | 20 +-
.../window/TimeBatchWindowExpression.java | 2 +-
.../expression/window/TimeWindowExpression.java | 2 +-
.../wrapper/siddhi/utils/SiddhiUtils.java | 36 +-
tools/maven/checkstyle.xml | 2 +-
ui/package-lock.json | 176 +-
ui/package.json | 4 +-
273 files changed, 2832 insertions(+), 5438 deletions(-)
rename .idea/runConfigurations/{backend.xml => core.xml} (75%)
delete mode 100644 streampipes-connect-management/src/test/java/org/apache/streampipes/connect/management/health/AdapterHealthCheckTest.java
delete mode 100644 streampipes-connect-management/src/test/java/org/apache/streampipes/connect/management/management/DescriptionManagementTest.java
delete mode 100644 streampipes-connect-management/src/test/java/org/apache/streampipes/connect/management/management/UnitMasterManagementTest.java
delete mode 100644 streampipes-connect-management/src/test/java/org/apache/streampipes/connect/management/management/WorkerRestClientTest.java
delete mode 100644 streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/Mock.java
delete mode 100644 streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter/transform/value/TimestampTransformRuleTest.java
delete mode 100644 streampipes-extensions/streampipes-processors-aggregation-flink/src/test/java/org/apache/streampipes/processors/aggregation/flink/processor/aggregation/AggregationTestData.java
delete mode 100644 streampipes-extensions/streampipes-processors-aggregation-flink/src/test/java/org/apache/streampipes/processors/aggregation/flink/processor/aggregation/TestTimeAggregationProgram.java
delete mode 100644 streampipes-extensions/streampipes-processors-aggregation-flink/src/test/java/org/apache/streampipes/processors/aggregation/flink/processor/count/TestCountProgram.java
delete mode 100644 streampipes-extensions/streampipes-processors-aggregation-flink/src/test/java/org/apache/streampipes/processors/aggregation/flink/processor/rate/TestRateProgram.java
delete mode 100644 streampipes-extensions/streampipes-processors-pattern-detection-flink/src/test/java/org/apache/streampipes/processors/pattern/detection/processor/absence/TestAbsence.java
delete mode 100644 streampipes-extensions/streampipes-processors-pattern-detection-flink/src/test/java/org/apache/streampipes/processors/pattern/detection/processor/and/TestAnd.java
delete mode 100644 streampipes-extensions/streampipes-processors-transformation-flink/src/test/java/org/apache/streampipes/processors/transformation/flink/processor/converter/TestConverterProgram.java
delete mode 100644 streampipes-extensions/streampipes-processors-transformation-flink/src/test/java/org/apache/streampipes/processors/transformation/flink/processor/hasher/TestFieldHasher.java
delete mode 100644 streampipes-extensions/streampipes-processors-transformation-flink/src/test/java/org/apache/streampipes/processors/transformation/flink/processor/hasher/TestFieldHasherController.java
delete mode 100644 streampipes-extensions/streampipes-processors-transformation-flink/src/test/java/org/apache/streampipes/processors/transformation/flink/processor/hasher/TestFieldHasherProgram.java
delete mode 100644 streampipes-extensions/streampipes-processors-transformation-flink/src/test/java/org/apache/streampipes/processors/transformation/flink/processor/hasher/TestFieldHasherUtils.java
delete mode 100644 streampipes-extensions/streampipes-processors-transformation-flink/src/test/java/org/apache/streampipes/processors/transformation/flink/processor/rename/TestRenameProgram.java
delete mode 100644 streampipes-extensions/streampipes-processors-transformation-flink/src/test/java/org/apache/streampipes/processors/transformation/flink/utils/DummyCollector.java
delete mode 100644 streampipes-maven-plugin/src/test/java/org/apache/streampipes/smp/extractor/TestDockerImageExtractor.java
delete mode 100644 streampipes-pipeline-management/src/test/java/org/apache/streampipes/manager/ThrowableCaptor.java
delete mode 100644 streampipes-pipeline-management/src/test/java/org/apache/streampipes/manager/matching/TestPipelineModification.java
delete mode 100644 streampipes-pipeline-management/src/test/java/org/apache/streampipes/manager/matching/TestPipelineValidationHandler.java
delete mode 100644 streampipes-pipeline-management/src/test/java/org/apache/streampipes/manager/matching/TestRdfId.java
delete mode 100644 streampipes-pipeline-management/src/test/java/org/apache/streampipes/manager/matching/v2/TestElementVerification.java
delete mode 100644 streampipes-pipeline-management/src/test/java/org/apache/streampipes/manager/pipeline/TestPipelinesContainingElements.java