This is an automated email from the ASF dual-hosted git repository.
riemer pushed a commit to branch support-output-strategies-in-pipeline-code
in repository https://gitbox.apache.org/repos/asf/streampipes.git
The following commit(s) were added to
refs/heads/support-output-strategies-in-pipeline-code by this push:
new e16655202e Update ts model
e16655202e is described below
commit e16655202e02adef2f039f1e17db6d8008118565
Author: Dominik Riemer <[email protected]>
AuthorDate: Tue Oct 29 10:08:45 2024 +0100
Update ts model
---
.../src/lib/model/gen/streampipes-model.ts | 63 +++++++++++++++-------
.../adapter-started-dialog.component.ts | 1 +
2 files changed, 44 insertions(+), 20 deletions(-)
diff --git
a/ui/projects/streampipes/platform-services/src/lib/model/gen/streampipes-model.ts
b/ui/projects/streampipes/platform-services/src/lib/model/gen/streampipes-model.ts
index cf07248af8..0a6058fed6 100644
---
a/ui/projects/streampipes/platform-services/src/lib/model/gen/streampipes-model.ts
+++
b/ui/projects/streampipes/platform-services/src/lib/model/gen/streampipes-model.ts
@@ -1,26 +1,7 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
/* tslint:disable */
/* eslint-disable */
// @ts-nocheck
-// Generated using typescript-generator version 3.2.1263 on 2024-10-11
10:41:46.
+// Generated using typescript-generator version 3.2.1263 on 2024-10-29
10:04:46.
export class NamedStreamPipesEntity implements Storable {
'@class':
@@ -844,6 +825,7 @@ export class CompactPipelineElement {
configuration: { [index: string]: any }[];
connectedTo: string[];
id: string;
+ output: OutputConfiguration;
ref: string;
type: string;
@@ -862,6 +844,7 @@ export class CompactPipelineElement {
data.connectedTo,
);
instance.id = data.id;
+ instance.output = OutputConfiguration.fromData(data.output);
instance.ref = data.ref;
instance.type = data.type;
return instance;
@@ -2605,6 +2588,26 @@ export class Option {
}
}
+export class OutputConfiguration {
+ keep: string[];
+ userDefined: UserDefinedOutput[];
+
+ static fromData(
+ data: OutputConfiguration,
+ target?: OutputConfiguration,
+ ): OutputConfiguration {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new OutputConfiguration();
+ instance.keep = __getCopyArrayFn(__identity<string>())(data.keep);
+ instance.userDefined = __getCopyArrayFn(UserDefinedOutput.fromData)(
+ data.userDefined,
+ );
+ return instance;
+ }
+}
+
export class Pipeline implements Storable {
_id: string;
_rev: string;
@@ -4056,6 +4059,26 @@ export class UnitTransformRuleDescription extends
ValueTransformationRuleDescrip
}
}
+export class UserDefinedOutput {
+ fieldName: string;
+ runtimeType: string;
+ semanticType: string;
+
+ static fromData(
+ data: UserDefinedOutput,
+ target?: UserDefinedOutput,
+ ): UserDefinedOutput {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new UserDefinedOutput();
+ instance.fieldName = data.fieldName;
+ instance.runtimeType = data.runtimeType;
+ instance.semanticType = data.semanticType;
+ return instance;
+ }
+}
+
export class UserDefinedOutputStrategy extends OutputStrategy {
'@class': 'org.apache.streampipes.model.output.UserDefinedOutputStrategy';
'eventProperties': EventPropertyUnion[];
diff --git
a/ui/src/app/connect/dialog/adapter-started/adapter-started-dialog.component.ts
b/ui/src/app/connect/dialog/adapter-started/adapter-started-dialog.component.ts
index 598dae37ae..3ec0778f3b 100644
---
a/ui/src/app/connect/dialog/adapter-started/adapter-started-dialog.component.ts
+++
b/ui/src/app/connect/dialog/adapter-started/adapter-started-dialog.component.ts
@@ -265,6 +265,7 @@ export class AdapterStartedDialog implements OnInit {
configuration: undefined,
id: adapter.correspondingDataStreamElementId,
connectedTo: undefined,
+ output: undefined,
});
return template;
}
