![[Jenkins]](/kapua/static/bc58d2fb/images/svgs/logo.svg){kind=logo}
Package: JobStepDefinitionImpl
JobStepDefinitionImpl
| name | instruction | branch | complexity | line | method | ||||||||||||||||||||
|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
| JobStepDefinitionImpl() |
|
|
|
|
|
||||||||||||||||||||
| JobStepDefinitionImpl(JobStepDefinition) |
|
|
|
|
|
||||||||||||||||||||
| JobStepDefinitionImpl(KapuaId) |
|
|
|
|
|
||||||||||||||||||||
| getProcessorName() |
|
|
|
|
|
||||||||||||||||||||
| getReaderName() |
|
|
|
|
|
||||||||||||||||||||
| getStepProperties() |
|
|
|
|
|
||||||||||||||||||||
| getStepType() |
|
|
|
|
|
||||||||||||||||||||
| getWriterName() |
|
|
|
|
|
||||||||||||||||||||
| setProcessorName(String) |
|
|
|
|
|
||||||||||||||||||||
| setReaderName(String) |
|
|
|
|
|
||||||||||||||||||||
| setStepProperties(List) |
|
|
|
|
|
||||||||||||||||||||
| setStepType(JobStepType) |
|
|
|
|
|
||||||||||||||||||||
| setWriterName(String) |
|
|
|
|
|
||||||||||||||||||||
Coverage
1: /*******************************************************************************
2: * Copyright (c) 2017, 2022 Eurotech and/or its affiliates and others
3: *
4: * This program and the accompanying materials are made
5: * available under the terms of the Eclipse Public License 2.0
6: * which is available at https://www.eclipse.org/legal/epl-2.0/
7: *
8: * SPDX-License-Identifier: EPL-2.0
9: *
10: * Contributors:
11: * Eurotech - initial API and implementation
12: *******************************************************************************/
13: package org.eclipse.kapua.service.job.step.definition.internal;
14:
15: import org.eclipse.kapua.KapuaException;
16: import org.eclipse.kapua.commons.model.AbstractKapuaNamedEntity;
17: import org.eclipse.kapua.model.id.KapuaId;
18: import org.eclipse.kapua.service.job.step.definition.JobStepDefinition;
19: import org.eclipse.kapua.service.job.step.definition.JobStepProperty;
20: import org.eclipse.kapua.service.job.step.definition.JobStepType;
21:
22: import javax.persistence.Basic;
23: import javax.persistence.CollectionTable;
24: import javax.persistence.Column;
25: import javax.persistence.ElementCollection;
26: import javax.persistence.Entity;
27: import javax.persistence.EnumType;
28: import javax.persistence.Enumerated;
29: import javax.persistence.JoinColumn;
30: import javax.persistence.Table;
31: import java.util.ArrayList;
32: import java.util.List;
33:
34: /**
35: * {@link JobStepDefinition} implementation.
36: *
37: * @since 1.0.0
38: */
39: @Entity(name = "JobStepDefinition")
40: @Table(name = "job_job_step_definition")
41: public class JobStepDefinitionImpl extends AbstractKapuaNamedEntity implements JobStepDefinition {
42:
43: private static final long serialVersionUID = 3747451706859757246L;
44:
45: @Enumerated(EnumType.STRING)
46: @Column(name = "job_step_type", nullable = false, updatable = false)
47: private JobStepType jobStepType;
48:
49: @Basic
50: @Column(name = "reader_name", nullable = false, updatable = false)
51: private String readerName;
52:
53: @Basic
54: @Column(name = "processor_name", nullable = false, updatable = false)
55: private String processorName;
56:
57: @Basic
58: @Column(name = "writer_name", nullable = false, updatable = false)
59: private String writerName;
60:
61: @ElementCollection
62: @CollectionTable(name = "job_job_step_definition_properties", joinColumns = @JoinColumn(name = "step_definition_id", referencedColumnName = "id"))
63: private List<JobStepPropertyImpl> jobStepProperties;
64:
65: /**
66: * Constructor.
67: *
68: * @since 1.0.0
69: */
70: public JobStepDefinitionImpl() {
71: }
72:
73: /**
74: * Constructor.
75: *
76: * @param scopeId The scope {@link KapuaId} to set into the {@link JobStepDefinition}
77: * @since 1.0.0
78: */
79: public JobStepDefinitionImpl(KapuaId scopeId) {
80: super(scopeId);
81: }
82:
83: /**
84: * Clone constructor.
85: *
86: * @param jobStepDefinition
87: * @throws KapuaException
88: * @since 1.1.0
89: */
90: public JobStepDefinitionImpl(JobStepDefinition jobStepDefinition) throws KapuaException {
91: super(jobStepDefinition);
92:
93: setStepType(jobStepDefinition.getStepType());
94: setReaderName(jobStepDefinition.getReaderName());
95: setProcessorName(jobStepDefinition.getProcessorName());
96: setWriterName(jobStepDefinition.getWriterName());
97: setStepProperties(jobStepDefinition.getStepProperties());
98: }
99:
100: @Override
101: public JobStepType getStepType() {
102: return jobStepType;
103: }
104:
105: @Override
106: public void setStepType(JobStepType jobStepType) {
107: this.jobStepType = jobStepType;
108:
109: }
110:
111: @Override
112: public String getReaderName() {
113: return readerName;
114: }
115:
116: @Override
117: public void setReaderName(String readerName) {
118: this.readerName = readerName;
119: }
120:
121: @Override
122: public String getProcessorName() {
123: return processorName;
124: }
125:
126: @Override
127: public void setProcessorName(String processorName) {
128: this.processorName = processorName;
129: }
130:
131: @Override
132: public String getWriterName() {
133: return writerName;
134: }
135:
136: @Override
137: public void setWriterName(String writesName) {
138: this.writerName = writesName;
139: }
140:
141: @Override
142: public List<JobStepPropertyImpl> getStepProperties() {
143:• if (jobStepProperties == null) {
144: jobStepProperties = new ArrayList<>();
145: }
146:
147: return jobStepProperties;
148: }
149:
150: @Override
151: public void setStepProperties(List<JobStepProperty> jobStepProperties) {
152: this.jobStepProperties = new ArrayList<>();
153:
154:• for (JobStepProperty sp : jobStepProperties) {
155: this.jobStepProperties.add(JobStepPropertyImpl.parse(sp));
156: }
157:
158: }
159: }