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 2021/10/11 14:26:34 UTC
[incubator-streampipes] 01/01: Merge branch 'STREAMPIPES-438' into
dev
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/incubator-streampipes.git
commit 7ac34e68ecbc4aaba9e1b1554cd862297ebfba2e
Merge: a23865b 3e4aec4
Author: Philipp Zehnder <ze...@fzi.de>
AuthorDate: Mon Oct 11 16:26:24 2021 +0200
Merge branch 'STREAMPIPES-438' into dev
.../backend/StreamPipesResourceConfig.java | 1 -
.../master/health/AdapterHealthCheck.java | 129 +
.../master/management/AdapterMasterManagement.java | 206 +-
.../AdapterTemplateMasterManagement.java | 106 -
.../master/management/DescriptionManagement.java | 56 +-
.../master/management/SourcesManagement.java | 157 +-
.../master/management/UnitMasterManagement.java | 7 +-
.../management/WorkerAdministrationManagement.java | 73 +-
.../master/management/WorkerRestClient.java | 77 +-
.../master/management/WorkerUrlProvider.java | 61 +-
.../master/util/AdapterEncryptionService.java | 7 +-
.../connect/container/master/util/Utils.java | 29 -
.../connect/container/master/util/WorkerPaths.java | 36 +-
.../master/health/AdapterHealthCheckTest.java | 87 +
.../management/AdapterMasterManagementTest.java | 16 +-
.../AdapterTemplateMasterManagementTest.java | 58 -
.../management/DescriptionManagementTest.java | 10 +-
.../master/management/SourcesManagementTest.java | 78 +-
.../master/management/WorkerRestClientTest.java | 10 +-
.../init/AdapterServiceResourceProvider.java | 7 +-
.../worker/init/AdapterWorkerContainer.java | 64 -
.../init/ConnectWorkerDescriptionProvider.java | 75 +-
.../init/ConnectWorkerRegistrationService.java | 7 +-
.../worker/management/AdapterWorkerManagement.java | 87 +-
.../worker/management/GuessManagement.java | 8 -
.../management/HttpServerAdapterManagement.java | 3 +-
.../worker/management/MasterRestClient.java | 8 +-
...pterResource.java => AdapterAssetResource.java} | 28 +-
...kerResource.java => AdapterWorkerResource.java} | 30 +-
.../container/worker/rest/GuessResource.java | 5 +-
.../container/worker/rest/ProtocolResource.java | 75 -
.../container/worker/rest/WelcomePageWorker.java | 108 -
.../container/worker/utils/AdapterUtils.java | 28 +-
.../management/AdapterWorkerManagementTest.java | 26 +-
.../container/worker/utils/AdapterUtilsTest.java | 60 -
.../connect/container/worker/utils/Utils.java | 6 +-
.../connect/RunningAdapterInstances.java | 21 +-
.../adapter/guess/PropertyGuessResults.java | 40 -
.../connect/adapter/guess/PropertyGuesses.java | 54 -
.../connect/adapter/guess/SchemaGuesser.java | 101 +-
.../model/generic/GenericDataSetAdapter.java | 4 +-
.../model/generic/GenericDataStreamAdapter.java | 4 +-
.../streampipes/connect/adapter/guess/Mock.java | 26 -
.../connect/adapter/guess/SchemaGuesserTest.java | 132 -
.../extensions/ExtensionsModelSubmitter.java | 2 +-
.../standalone/init/StandaloneModelSubmitter.java | 1 +
.../container/util/ServiceDefinitionUtil.java | 2 +-
.../org/apache/streampipes/model/SpDataSet.java | 1 +
.../org/apache/streampipes/model/SpDataStream.java | 1 +
.../model/connect/adapter/AdapterDescription.java | 38 +-
.../connect/adapter/AdapterDescriptionList.java | 49 -
.../connect/adapter/AdapterSetDescription.java | 11 +-
.../connect/adapter/AdapterStreamDescription.java | 7 +-
.../adapter/GenericAdapterSetDescription.java | 2 +-
.../adapter/GenericAdapterStreamDescription.java | 1 -
.../model/connect/grounding/FormatDescription.java | 46 -
.../connect/grounding/FormatDescriptionList.java | 63 -
.../connect/grounding/ProtocolDescription.java | 2 -
.../connect/grounding/ProtocolDescriptionList.java | 58 -
.../connect/guess/DomainPropertyProbability.java | 53 -
.../guess/DomainPropertyProbabilityList.java | 56 -
.../model/connect/guess/GuessSchema.java | 30 +-
.../connect/worker/ConnectWorkerContainer.java | 95 -
streampipes-pipeline-management/pom.xml | 2 +-
.../manager/execution/http/GraphSubmitter.java | 2 +-
.../manager/execution/http/PipelineExecutor.java | 6 +-
.../manager/setup/CouchDbInstallationStep.java | 3 +-
.../apache/streampipes/rest/ResetManagement.java | 6 +-
.../streampipes/rest/impl/PipelineTemplate.java | 2 +-
.../rest/impl/connect/AdapterResource.java | 35 +-
.../rest/impl/connect/AdapterTemplateResource.java | 88 -
.../rest/impl/connect/DescriptionResource.java | 50 +-
.../rest/impl/connect/GuessResource.java | 3 +-
.../impl/connect/RuntimeResolvableResource.java | 4 +-
.../rest/impl/connect/SourcesResource.java | 54 +-
.../rest/impl/connect/WelcomePageMaster.java | 4 +-
.../impl/connect/WorkerAdministrationResource.java | 11 +-
.../builder/adapter/AdapterDescriptionBuilder.java | 9 +-
.../sdk/builder/adapter/GuessSchemaBuilder.java | 10 -
.../serializers/json/AdapterSerializer.java | 4 +-
.../svcdiscovery/api/model/SpServiceTagPrefix.java | 1 -
.../api/model/SpServiceUrlProvider.java | 3 +-
.../storage/api/IAdapterTemplateStorage.java | 36 -
.../api/IConnectWorkerContainerStorage.java | 35 -
.../streampipes/storage/api/INoSqlStorage.java | 4 +-
.../storage/couchdb/CouchDbStorageManager.java | 9 +-
...mpl.java => AdapterDescriptionStorageImpl.java} | 14 +-
...geImpl.java => AdapterInstanceStorageImpl.java} | 10 +-
.../couchdb/impl/AdapterTemplateStorageImpl.java | 70 -
.../impl/ConnectionWorkerContainerStorageImpl.java | 71 -
.../streampipes/storage/couchdb/utils/Utils.java | 8 +-
ui/cypress/tests/adapter/InfluxDbAdapter.ts | 4 +-
ui/cypress/tests/adapter/KafkaAdapter.ts | 3 +-
ui/cypress/tests/adapter/MqttAdapter.ts | 3 +-
ui/cypress/tests/adapter/MySQLDbAdapter.ts | 5 +-
ui/cypress/tests/adapter/machineDataSimulator.ts | 14 +-
ui/cypress/tests/adapter/persistInDataLake.ts | 16 +-
.../tests/pipelineElement/AllPipelineElements.ts | 1 -
.../adapter-description.component.html | 16 +-
.../adapter-description.component.ts | 78 +-
.../data-marketplace.component.html | 10 +-
.../data-marketplace/data-marketplace.component.ts | 373 +-
.../format-configuration.component.ts | 5 +-
.../start-adapter-configuration.component.html | 9 +-
.../start-adapter-configuration.component.ts | 15 +-
.../adapter-started-dialog.component.ts | 112 +-
.../adapter-upload-dialog.component.ts | 60 +-
.../connect/services/data-marketplace.service.ts | 146 +-
ui/src/app/connect/services/rest.service.ts | 85 +-
ui/src/app/core-model/gen/streampipes-model.ts | 4971 ++++++++++----------
110 files changed, 3531 insertions(+), 5678 deletions(-)