-
Notifications
You must be signed in to change notification settings - Fork 306
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #194 from Tangjiafeng/master
add new feature
- Loading branch information
Showing
574 changed files
with
35,910 additions
and
5,439 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
180 changes: 180 additions & 0 deletions
180
core/analysis/src/main/java/com/webank/wedatasphere/qualitis/entity/FieldsAnalyse.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,180 @@ | ||
| /* | ||
| * Copyright 2019 WeBank | ||
| * | ||
| * Licensed 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. | ||
| */ | ||
|
|
||
| package com.webank.wedatasphere.qualitis.entity; | ||
|
|
||
| import javax.persistence.*; | ||
| import java.math.BigDecimal; | ||
| import java.util.Date; | ||
|
|
||
| /** | ||
| * @author v_wenxuanzhang | ||
| */ | ||
| @Entity | ||
| @Table(name = "qualitis_imsmetric_fields_analyse") | ||
| @IdClass(FieldsAnalysePrimaryKey.class) | ||
| public class FieldsAnalyse { | ||
|
|
||
| @Id | ||
| @Column(name = "rule_id") | ||
| private Long ruleId; | ||
|
|
||
| @Id | ||
| @Column(name = "data_date") | ||
| private Integer dataDate; | ||
|
|
||
| @Column(name = "analyse_type", columnDefinition = "TINYINT(5)") | ||
| private Integer analyseType; | ||
|
|
||
| @Column(name = "datasource_type", columnDefinition = "TINYINT(5)") | ||
| private Integer datasourceType; | ||
|
|
||
| @Column(name = "database_name") | ||
| private String databaseName; | ||
|
|
||
| @Column(name = "table_name") | ||
| private String tableName; | ||
|
|
||
| @Column(name = "field_name") | ||
| private String fieldName; | ||
|
|
||
| @Column(name = "value") | ||
| private BigDecimal value; | ||
|
|
||
| @Column(name = "partition_attrs") | ||
| private String partitionAttrs; | ||
|
|
||
| @Column(name = "create_time") | ||
| private Date createTime; | ||
|
|
||
| @Column(name = "update_time") | ||
| private Date updateTime; | ||
|
|
||
| @Column(name = "datasource_user") | ||
| private String datasourceUser; | ||
|
|
||
| @Column(name = "remark") | ||
| private String remark; | ||
|
|
||
|
|
||
| public FieldsAnalyse() { | ||
| // Default Constructor | ||
| } | ||
|
|
||
| public Long getRuleId() { | ||
| return ruleId; | ||
| } | ||
|
|
||
| public void setRuleId(Long ruleId) { | ||
| this.ruleId = ruleId; | ||
| } | ||
|
|
||
| public Integer getDataDate() { | ||
| return dataDate; | ||
| } | ||
|
|
||
| public void setDataDate(Integer dataDate) { | ||
| this.dataDate = dataDate; | ||
| } | ||
|
|
||
| public Integer getAnalyseType() { | ||
| return analyseType; | ||
| } | ||
|
|
||
| public void setAnalyseType(Integer analyseType) { | ||
| this.analyseType = analyseType; | ||
| } | ||
|
|
||
| public Integer getDatasourceType() { | ||
| return datasourceType; | ||
| } | ||
|
|
||
| public void setDatasourceType(Integer datasourceType) { | ||
| this.datasourceType = datasourceType; | ||
| } | ||
|
|
||
| public String getDatabaseName() { | ||
| return databaseName; | ||
| } | ||
|
|
||
| public void setDatabaseName(String databaseName) { | ||
| this.databaseName = databaseName; | ||
| } | ||
|
|
||
| public String getTableName() { | ||
| return tableName; | ||
| } | ||
|
|
||
| public void setTableName(String tableName) { | ||
| this.tableName = tableName; | ||
| } | ||
|
|
||
| public String getFieldName() { | ||
| return fieldName; | ||
| } | ||
|
|
||
| public void setFieldName(String fieldName) { | ||
| this.fieldName = fieldName; | ||
| } | ||
|
|
||
| public BigDecimal getValue() { | ||
| return value; | ||
| } | ||
|
|
||
| public void setValue(BigDecimal value) { | ||
| this.value = value; | ||
| } | ||
|
|
||
| public String getPartitionAttrs() { | ||
| return partitionAttrs; | ||
| } | ||
|
|
||
| public void setPartitionAttrs(String partitionAttrs) { | ||
| this.partitionAttrs = partitionAttrs; | ||
| } | ||
|
|
||
| public Date getCreateTime() { | ||
| return createTime; | ||
| } | ||
|
|
||
| public void setCreateTime(Date createTime) { | ||
| this.createTime = createTime; | ||
| } | ||
|
|
||
| public Date getUpdateTime() { | ||
| return updateTime; | ||
| } | ||
|
|
||
| public void setUpdateTime(Date updateTime) { | ||
| this.updateTime = updateTime; | ||
| } | ||
|
|
||
| public String getDatasourceUser() { | ||
| return datasourceUser; | ||
| } | ||
|
|
||
| public void setDatasourceUser(String datasourceUser) { | ||
| this.datasourceUser = datasourceUser; | ||
| } | ||
|
|
||
| public String getRemark() { | ||
| return remark; | ||
| } | ||
|
|
||
| public void setRemark(String remark) { | ||
| this.remark = remark; | ||
| } | ||
| } |
42 changes: 42 additions & 0 deletions
42
...alysis/src/main/java/com/webank/wedatasphere/qualitis/entity/FieldsAnalysePrimaryKey.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,42 @@ | ||
| package com.webank.wedatasphere.qualitis.entity; | ||
|
|
||
| import java.io.Serializable; | ||
| import java.util.Objects; | ||
|
|
||
| /** | ||
| * @author v_wenxuanzhang | ||
| */ | ||
| public class FieldsAnalysePrimaryKey implements Serializable { | ||
| private Long ruleId; | ||
| private Integer dataDate; | ||
|
|
||
| @Override | ||
| public boolean equals(Object o) { | ||
| if (this == o) return true; | ||
| if (o == null || getClass() != o.getClass()) return false; | ||
| FieldsAnalysePrimaryKey that = (FieldsAnalysePrimaryKey) o; | ||
| return ruleId.equals(that.ruleId) && | ||
| dataDate.equals(that.dataDate); | ||
| } | ||
|
|
||
| @Override | ||
| public int hashCode() { | ||
| return Objects.hash(ruleId, dataDate); | ||
| } | ||
|
|
||
| public Long getMetricId() { | ||
| return ruleId; | ||
| } | ||
|
|
||
| public void setMetricId(Long metricId) { | ||
| this.ruleId = metricId; | ||
| } | ||
|
|
||
| public Integer getDs() { | ||
| return dataDate; | ||
| } | ||
|
|
||
| public void setDs(Integer ds) { | ||
| this.dataDate = ds; | ||
| } | ||
| } |
Oops, something went wrong.