http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/f629d0f4/griffin-core/src/main/java/com/ebay/oss/griffin/vo/DQHealthStats.java ---------------------------------------------------------------------- diff --git a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/DQHealthStats.java b/griffin-core/src/main/java/com/ebay/oss/griffin/vo/DQHealthStats.java deleted file mode 100644 index 98399ba..0000000 --- a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/DQHealthStats.java +++ /dev/null @@ -1,43 +0,0 @@ -/* - Copyright (c) 2016 eBay Software Foundation. - 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.ebay.oss.griffin.vo; - - -public class DQHealthStats { - private int health; - private int warn; - private int invalid; - - public int getHealth() { - return health; - } - public void setHealth(int health) { - this.health = health; - } - public int getWarn() { - return warn; - } - public void setWarn(int warn) { - this.warn = warn; - } - public int getInvalid() { - return invalid; - } - public void setInvalid(int invalid) { - this.invalid = invalid; - } - - -}
http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/f629d0f4/griffin-core/src/main/java/com/ebay/oss/griffin/vo/DataAssetIndex.java ---------------------------------------------------------------------- diff --git a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/DataAssetIndex.java b/griffin-core/src/main/java/com/ebay/oss/griffin/vo/DataAssetIndex.java deleted file mode 100644 index 9c5c656..0000000 --- a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/DataAssetIndex.java +++ /dev/null @@ -1,43 +0,0 @@ -/* - Copyright (c) 2016 eBay Software Foundation. - 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.ebay.oss.griffin.vo; - - -public class DataAssetIndex{ - - private Long id; - - private String name; - - public Long getId() { - return id; - } - - public void setId(Long id) { - this.id = id; - } - - public String getName() { - return name; - } - - public void setName(String name) { - this.name = name; - } - - - - -} http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/f629d0f4/griffin-core/src/main/java/com/ebay/oss/griffin/vo/DataAssetInput.java ---------------------------------------------------------------------- diff --git a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/DataAssetInput.java b/griffin-core/src/main/java/com/ebay/oss/griffin/vo/DataAssetInput.java deleted file mode 100644 index 2c6e8b6..0000000 --- a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/DataAssetInput.java +++ /dev/null @@ -1,109 +0,0 @@ -/* - * Copyright (c) 2016 eBay Software Foundation. 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.ebay.oss.griffin.vo; - -import java.util.List; - -import com.ebay.oss.griffin.domain.DataSchema; -import com.ebay.oss.griffin.domain.PartitionFormat; - -public class DataAssetInput extends BaseObj { - - private String assetName; - - private String assetType; - - private String assetHDFSPath; - - private String system; - - private String platform; - - private String owner; - - private String partition; - - private List<DataSchema> schema; - - private List<PartitionFormat> partitions; - - public String getAssetName() { - return assetName; - } - - public void setAssetName(String assetName) { - this.assetName = assetName; - } - - public String getAssetType() { - return assetType; - } - - public void setAssetType(String assetType) { - this.assetType = assetType; - } - - public String getAssetHDFSPath() { - return assetHDFSPath; - } - - public void setAssetHDFSPath(String assetHDFSPath) { - this.assetHDFSPath = assetHDFSPath; - } - - public String getSystem() { - return system; - } - - public void setSystem(String system) { - this.system = system; - } - - public String getPlatform() { - return platform; - } - - public void setPlatform(String platform) { - this.platform = platform; - } - - public List<DataSchema> getSchema() { - return schema; - } - - public void setSchema(List<DataSchema> schema) { - this.schema = schema; - } - - public String getPartition() { - return partition; - } - - public void setPartition(String partition) { - this.partition = partition; - } - - public List<PartitionFormat> getPartitions() { - return partitions; - } - - public void setPartitions(List<PartitionFormat> partitions) { - this.partitions = partitions; - } - - public String getOwner() { - return owner; - } - - public void setOwner(String owner) { - this.owner = owner; - } - - -} http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/f629d0f4/griffin-core/src/main/java/com/ebay/oss/griffin/vo/DqModelVo.java ---------------------------------------------------------------------- diff --git a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/DqModelVo.java b/griffin-core/src/main/java/com/ebay/oss/griffin/vo/DqModelVo.java deleted file mode 100644 index d6588e7..0000000 --- a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/DqModelVo.java +++ /dev/null @@ -1,95 +0,0 @@ -/* - Copyright (c) 2016 eBay Software Foundation. - 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.ebay.oss.griffin.vo; - -import java.util.Date; - -public class DqModelVo { - private String name; - private int system; - private String description; - private int type; - private Date createDate; - private String status; - private String assetName; - private String owner; - - public DqModelVo() {} - - public String getAssetName() { - return assetName; - } - - public void setAssetName(String assetName) { - this.assetName = assetName; - } - - public String getName() { - return name; - } - - public void setName(String name) { - this.name = name; - } - - public int getSystem() { - return system; - } - - public void setSystem(int system) { - this.system = system; - } - - public String getDescription() { - return description; - } - - public void setDescription(String description) { - this.description = description; - } - - public int getType() { - return type; - } - - public void setType(int type) { - this.type = type; - } - - public String getOwner() { - return owner; - } - - public void setOwner(String owner) { - this.owner = owner; - } - - public Date getCreateDate() { - return createDate; - } - - public void setCreateDate(Date createDate) { - this.createDate = createDate; - } - - public String getStatus() { - return status; - } - - public void setStatus(String status) { - this.status = status; - } - -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/f629d0f4/griffin-core/src/main/java/com/ebay/oss/griffin/vo/LoginUser.java ---------------------------------------------------------------------- diff --git a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/LoginUser.java b/griffin-core/src/main/java/com/ebay/oss/griffin/vo/LoginUser.java deleted file mode 100644 index ee6d5cb..0000000 --- a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/LoginUser.java +++ /dev/null @@ -1,50 +0,0 @@ -/* - Copyright (c) 2016 eBay Software Foundation. - 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.ebay.oss.griffin.vo; - -import com.google.code.morphia.annotations.Entity; -import com.google.code.morphia.annotations.Property; - -@Entity("loginUser") -public class LoginUser { - @Property("username") - private String username; - @Property("password") - private String password; - - public LoginUser() { } - - public LoginUser(String username, String password) { - this.username = username; - this.password = password; - } - - public String getUsername() { - return username; - } - - public void setUsername(String username) { - this.username = username; - } - - public String getPassword() { - return password; - } - - public void setPassword(String password) { - this.password = password; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/f629d0f4/griffin-core/src/main/java/com/ebay/oss/griffin/vo/MADEntity.java ---------------------------------------------------------------------- diff --git a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/MADEntity.java b/griffin-core/src/main/java/com/ebay/oss/griffin/vo/MADEntity.java deleted file mode 100644 index ddff8c0..0000000 --- a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/MADEntity.java +++ /dev/null @@ -1,44 +0,0 @@ -/* - * Copyright (c) 2016 eBay Software Foundation. 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.ebay.oss.griffin.vo; - - -public class MADEntity { - private long upper; - private long lower; - - public MADEntity() {} - - public MADEntity(long upper, long lower) { - this.upper = upper; - this.lower = lower; - } - - public long getUpper() { - return upper; - } - - public void setUpper(long upper) { - this.upper = upper; - } - - public long getLower() { - return lower; - } - - public void setLower(long lower) { - this.lower = lower; - } - - public MADEntity clone() { - return new MADEntity(getUpper(), getLower()); - - } - -} http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/f629d0f4/griffin-core/src/main/java/com/ebay/oss/griffin/vo/MappingItemInput.java ---------------------------------------------------------------------- diff --git a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/MappingItemInput.java b/griffin-core/src/main/java/com/ebay/oss/griffin/vo/MappingItemInput.java deleted file mode 100644 index 391c199..0000000 --- a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/MappingItemInput.java +++ /dev/null @@ -1,60 +0,0 @@ -/* - Copyright (c) 2016 eBay Software Foundation. - 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.ebay.oss.griffin.vo; - -import org.codehaus.jackson.annotate.JsonIgnoreProperties; -@JsonIgnoreProperties(ignoreUnknown = true) -public class MappingItemInput { - private String target; - private String src; - private boolean isPk; - private String matchMethod; - - public MappingItemInput(){} - - public MappingItemInput(String target, String src, boolean isPk, String matchMethod) { - this.target = target; - this.src = src; - this.isPk = isPk; - this.matchMethod = matchMethod; - } - public String getTarget() { - return target; - } - public void setTarget(String target) { - this.target = target; - } - public String getSrc() { - return src; - } - public void setSrc(String src) { - this.src = src; - } - - public boolean isIsPk() { - return isPk; - } - public void setIsPk(boolean isPk) { - this.isPk = isPk; - } - public String getMatchMethod() { - return matchMethod; - } - public void setMatchMethod(String matchMethod) { - this.matchMethod = matchMethod; - } - - -} http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/f629d0f4/griffin-core/src/main/java/com/ebay/oss/griffin/vo/ModelBasicInputNew.java ---------------------------------------------------------------------- diff --git a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/ModelBasicInputNew.java b/griffin-core/src/main/java/com/ebay/oss/griffin/vo/ModelBasicInputNew.java deleted file mode 100644 index eaf57d6..0000000 --- a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/ModelBasicInputNew.java +++ /dev/null @@ -1,131 +0,0 @@ -/* - * Copyright (c) 2016 eBay Software Foundation. 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.ebay.oss.griffin.vo; - -import javax.validation.constraints.NotNull; -import javax.validation.constraints.Pattern; - -import org.codehaus.jackson.annotate.JsonIgnoreProperties; - -@JsonIgnoreProperties(ignoreUnknown = true) -public class ModelBasicInputNew extends BaseObj { - private int type = -1; - private int system = -1; - private int scheduleType = -1; - private String owner; - @NotNull - @Pattern(regexp = "\\A([0-9a-zA-Z\\_\\-])+$") - private String name; - private String desc; - @Pattern(regexp = "^[_A-Za-z0-9-\\+]+(\\.[_A-Za-z0-9-]+)*@[A-Za-z0-9-]+(\\.[A-Za-z0-9]+)*(\\.[A-Za-z]{2,})$") - private String email; - private String dataaset; - private long dataasetId = -1; - private float threshold = -1.0f; - private int status = -1; - private long starttime = 0; - - public int getType() { - return type; - } - - public void setType(int type) { - this.type = type; - } - - public int getSystem() { - return system; - } - - public void setSystem(int system) { - this.system = system; - } - - public int getScheduleType() { - return scheduleType; - } - - public void setScheduleType(int scheduleType) { - this.scheduleType = scheduleType; - } - - public String getOwner() { - return owner; - } - - public void setOwner(String owner) { - this.owner = owner; - } - - public String getName() { - return name; - } - - public void setName(String name) { - this.name = name; - } - - public String getDesc() { - return desc; - } - - public void setDesc(String desc) { - this.desc = desc; - } - - public String getEmail() { - return email; - } - - public void setEmail(String email) { - this.email = email; - } - - public String getDataaset() { - return dataaset; - } - - public void setDataaset(String dataaset) { - this.dataaset = dataaset; - } - - public long getDataasetId() { - return dataasetId; - } - - public void setDataasetId(long dataasetId) { - this.dataasetId = dataasetId; - } - - public float getThreshold() { - return threshold; - } - - public void setThreshold(float threshold) { - this.threshold = threshold; - } - - public int getStatus() { - return status; - } - - public void setStatus(int status) { - this.status = status; - } - - public long getStarttime() { - return starttime; - } - - public void setStarttime(long starttime) { - this.starttime = starttime; - } - - -} http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/f629d0f4/griffin-core/src/main/java/com/ebay/oss/griffin/vo/ModelExtraInputNew.java ---------------------------------------------------------------------- diff --git a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/ModelExtraInputNew.java b/griffin-core/src/main/java/com/ebay/oss/griffin/vo/ModelExtraInputNew.java deleted file mode 100644 index 2cc1932..0000000 --- a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/ModelExtraInputNew.java +++ /dev/null @@ -1,68 +0,0 @@ -/* - Copyright (c) 2016 eBay Software Foundation. - 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.ebay.oss.griffin.vo; - -import org.codehaus.jackson.annotate.JsonIgnoreProperties; - -@JsonIgnoreProperties(ignoreUnknown = true) -public class ModelExtraInputNew extends BaseObj{ - - private String srcDb; - - private String srcDataSet; - - private String targetDb; - - private String targetDataSet; - - /** validityType - * @see ValidityType - */ - private int vaType = -1; - - /** anomaly type - * @see AnomalyType - */ - private int anType = -1; - - private String column; - - private String publishUrl; - - public String getSrcDb() { return srcDb; } - public void setSrcDb(String srcDb) { this.srcDb = srcDb; } - - public String getSrcDataSet() { return srcDataSet; } - public void setSrcDataSet(String srcDataSet) { this.srcDataSet = srcDataSet; } - - public String getTargetDb() { return targetDb; } - public void setTargetDb(String targetDb) { this.targetDb = targetDb; } - - public String getTargetDataSet() { return targetDataSet; } - public void setTargetDataSet(String targetDataSet) { this.targetDataSet = targetDataSet; } - - public int getVaType() { return vaType; } - public void setVaType(int vaType) { this.vaType = vaType; } - - public String getColumn() { return column; } - public void setColumn(String column) { this.column = column; } - - public String getPublishUrl() { return publishUrl; } - public void setPublishUrl(String publishUrl) { this.publishUrl = publishUrl; } - - public int getAnType() { return anType; } - public void setAnType(int anType) { this.anType = anType; } - -} http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/f629d0f4/griffin-core/src/main/java/com/ebay/oss/griffin/vo/ModelInput.java ---------------------------------------------------------------------- diff --git a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/ModelInput.java b/griffin-core/src/main/java/com/ebay/oss/griffin/vo/ModelInput.java deleted file mode 100644 index e0ee881..0000000 --- a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/ModelInput.java +++ /dev/null @@ -1,99 +0,0 @@ -/* - * Copyright (c) 2016 eBay Software Foundation. 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.ebay.oss.griffin.vo; - -import java.util.ArrayList; -import java.util.List; - -import org.codehaus.jackson.annotate.JsonIgnoreProperties; - -import com.ebay.oss.griffin.error.ErrorMessage; - - -@JsonIgnoreProperties(ignoreUnknown = true) -public class ModelInput extends BaseObj { - - private ModelBasicInputNew basic; // basic info for the model - private ModelExtraInputNew extra; // extra info for the model - private List<MappingItemInput> mappings; // mappings for acc - - public ModelInput() { - basic = new ModelBasicInputNew(); - extra = new ModelExtraInputNew(); - mappings = new ArrayList<MappingItemInput>(); - } - - public ModelInput(ModelBasicInputNew basic, ModelExtraInputNew extra, - List<MappingItemInput> mappings) { - super(); - this.basic = basic; - this.extra = extra; - this.mappings = mappings; - } - - public ModelBasicInputNew getBasic() { - return basic; - } - - public void setBasic(ModelBasicInputNew basic) { - this.basic = basic; - } - - public ModelExtraInputNew getExtra() { - return extra; - } - - public void setExtra(ModelExtraInputNew extra) { - this.extra = extra; - } - - public List<MappingItemInput> getMappings() { - return mappings; - } - - public void setMappings(List<MappingItemInput> mappings) { - this.mappings = mappings; - } - - public void parseFromString(String content) - { - String[] contents = content.split("\\|"); - extra.setSrcDb(contents[0]); - extra.setSrcDataSet(contents[1]); - extra.setTargetDb(contents[2]); - extra.setTargetDataSet(contents[3]); - - - String[] mappings = contents[4].split(";"); - for (int i = 0; i < mappings.length; i++) { - String[] mappingcontents = mappings[i].split(","); - - boolean isPk = false; - if (mappingcontents[2].equals("true")) - isPk = true; - System.out.println(mappingcontents[1]); - String target = mappingcontents[1]; - System.out.println(target); - String src = mappingcontents[0]; - this.mappings.add(new MappingItemInput(target, src, isPk, mappingcontents[3])); - } - - } - - @Override - public ErrorMessage validate() { - if (this.basic == null) { - return new ErrorMessage("No basic information provided!"); - } else { - return this.basic.validate(); - } - - } - -} http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/f629d0f4/griffin-core/src/main/java/com/ebay/oss/griffin/vo/NotificationRecord.java ---------------------------------------------------------------------- diff --git a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/NotificationRecord.java b/griffin-core/src/main/java/com/ebay/oss/griffin/vo/NotificationRecord.java deleted file mode 100644 index c7d2239..0000000 --- a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/NotificationRecord.java +++ /dev/null @@ -1,102 +0,0 @@ -/* - Copyright (c) 2016 eBay Software Foundation. - 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.ebay.oss.griffin.vo; - -import com.google.code.morphia.annotations.Entity; -import com.google.code.morphia.annotations.Property; - -@Entity("NotificationRecord") -public class NotificationRecord { - @Property("id") - private int id = -1; - @Property("timestamp") - private long timestamp; - @Property("owner") - private String owner; - @Property("operation") - private String operation; - @Property("target") - private String target; - @Property("link") - private String link; - @Property("name") - private String name; - - public NotificationRecord(){ - super(); - } - - public NotificationRecord(long timestamp, String owner, String operation, - String target, String name) { - super(); - this.timestamp = timestamp; - this.owner = owner; - this.operation = operation; - this.target = target; - this.name = name; - } - - - - public String getName() { - return name; - } - - public void setName(String name) { - this.name = name; - } - - public int getId() { - return id; - } - - public void setId(int id) { - this.id = id; - } - - public long getTimestamp() { - return timestamp; - } - public void setTimestamp(long timestamp) { - this.timestamp = timestamp; - } - public String getOwner() { - return owner; - } - public void setOwner(String owner) { - this.owner = owner; - } - public String getOperation() { - return operation; - } - public void setOperation(String operation) { - this.operation = operation; - } - public String getTarget() { - return target; - } - public void setTarget(String target) { - this.target = target; - } - public String getLink() { - return link; - } - public void setLink(String link) { - this.link = link; - } - - - -} http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/f629d0f4/griffin-core/src/main/java/com/ebay/oss/griffin/vo/OverViewStatistics.java ---------------------------------------------------------------------- diff --git a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/OverViewStatistics.java b/griffin-core/src/main/java/com/ebay/oss/griffin/vo/OverViewStatistics.java deleted file mode 100644 index b0ff93f..0000000 --- a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/OverViewStatistics.java +++ /dev/null @@ -1,44 +0,0 @@ -/* - Copyright (c) 2016 eBay Software Foundation. - 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.ebay.oss.griffin.vo; - - -public class OverViewStatistics { - - private int assets; - private int metrics; - private DQHealthStats status; - - public int getAssets() { - return assets; - } - public void setAssets(int assets) { - this.assets = assets; - } - public int getMetrics() { - return metrics; - } - public void setMetrics(int metrics) { - this.metrics = metrics; - } - public DQHealthStats getStatus() { - return status; - } - public void setStatus(DQHealthStats status) { - this.status = status; - } - - -} http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/f629d0f4/griffin-core/src/main/java/com/ebay/oss/griffin/vo/PartitionConfig.java ---------------------------------------------------------------------- diff --git a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/PartitionConfig.java b/griffin-core/src/main/java/com/ebay/oss/griffin/vo/PartitionConfig.java deleted file mode 100644 index 330d2ce..0000000 --- a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/PartitionConfig.java +++ /dev/null @@ -1,41 +0,0 @@ -/* - * Copyright (c) 2016 eBay Software Foundation. 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.ebay.oss.griffin.vo; - - -public class PartitionConfig { - - public String colName; - public String colValue; - - public PartitionConfig() {} - - public PartitionConfig(String colName, String colValue) { - this.colName = colName; - this.colValue = colValue; - } - - public String getColName() { - return colName; - } - - public void setColName(String colName) { - this.colName = colName; - } - - public String getColValue() { - return colValue; - } - - public void setColValue(String colValue) { - this.colValue = colValue; - } - - -} http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/f629d0f4/griffin-core/src/main/java/com/ebay/oss/griffin/vo/PlatformMetadata.java ---------------------------------------------------------------------- diff --git a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/PlatformMetadata.java b/griffin-core/src/main/java/com/ebay/oss/griffin/vo/PlatformMetadata.java deleted file mode 100644 index e2927ce..0000000 --- a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/PlatformMetadata.java +++ /dev/null @@ -1,52 +0,0 @@ -/* - Copyright (c) 2016 eBay Software Foundation. - 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.ebay.oss.griffin.vo; - -import java.util.List; - -public class PlatformMetadata{ - - private String id; - - private String platform; - - private List<SystemMetadata> systems; - - public String getId() { - return id; - } - - public void setId(String id) { - this.id = id; - } - - public String getPlatform() { - return platform; - } - - public void setPlatform(String platform) { - this.platform = platform; - } - - public List<SystemMetadata> getSystems() { - return systems; - } - - public void setSystems(List<SystemMetadata> systems) { - this.systems = systems; - } - - -} http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/f629d0f4/griffin-core/src/main/java/com/ebay/oss/griffin/vo/PlatformSubscription.java ---------------------------------------------------------------------- diff --git a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/PlatformSubscription.java b/griffin-core/src/main/java/com/ebay/oss/griffin/vo/PlatformSubscription.java deleted file mode 100644 index 9f4433f..0000000 --- a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/PlatformSubscription.java +++ /dev/null @@ -1,58 +0,0 @@ -/* - Copyright (c) 2016 eBay Software Foundation. - 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.ebay.oss.griffin.vo; - -import java.util.ArrayList; -import java.util.List; - -public class PlatformSubscription { - - String platform; - - boolean selectAll; - - List<SystemSubscription> systems = new ArrayList<SystemSubscription>(); - - public PlatformSubscription() { } - - public PlatformSubscription(String platform) { - this.platform = platform; - } - - public String getPlatform() { - return platform; - } - - public void setPlatform(String platform) { - this.platform = platform; - } - - public boolean isSelectAll() { - return selectAll; - } - - public void setSelectAll(boolean selectAll) { - this.selectAll = selectAll; - } - - public List<SystemSubscription> getSystems() { - return systems; - } - - public void setSystems(List<SystemSubscription> systems) { - this.systems = systems; - } - -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/f629d0f4/griffin-core/src/main/java/com/ebay/oss/griffin/vo/SampleOut.java ---------------------------------------------------------------------- diff --git a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/SampleOut.java b/griffin-core/src/main/java/com/ebay/oss/griffin/vo/SampleOut.java deleted file mode 100644 index 705334c..0000000 --- a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/SampleOut.java +++ /dev/null @@ -1,36 +0,0 @@ -/* - Copyright (c) 2016 eBay Software Foundation. - 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.ebay.oss.griffin.vo; - - -public class SampleOut { - - private long date; - private String path; - - public long getDate() { - return date; - } - public void setDate(long date) { - this.date = date; - } - public String getPath() { - return path; - } - public void setPath(String path) { - this.path = path; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/f629d0f4/griffin-core/src/main/java/com/ebay/oss/griffin/vo/SystemLevelMetrics.java ---------------------------------------------------------------------- diff --git a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/SystemLevelMetrics.java b/griffin-core/src/main/java/com/ebay/oss/griffin/vo/SystemLevelMetrics.java deleted file mode 100644 index 45c674d..0000000 --- a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/SystemLevelMetrics.java +++ /dev/null @@ -1,66 +0,0 @@ -/* - Copyright (c) 2016 eBay Software Foundation. - 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.ebay.oss.griffin.vo; - -import java.util.ArrayList; -import java.util.List; - -public class SystemLevelMetrics { - private String name; - private float dq; - - private List<AssetLevelMetrics> metrics; - - public SystemLevelMetrics() - { - metrics = new ArrayList<AssetLevelMetrics>(); - } - - public SystemLevelMetrics(String name) - { - this.name = name; - metrics = new ArrayList<AssetLevelMetrics>(); - } - - public String getName() { - return name; - } - - public void setName(String name) { - this.name = name; - } - - public float getDq() { - return dq; - } - - public void setDq(float dq) { - this.dq = dq; - } - - public List<AssetLevelMetrics> getMetrics() { - return metrics; - } - - public void setMetrics(List<AssetLevelMetrics> metrics) { - this.metrics = metrics; - } - - public void addAssetLevelMetrics(AssetLevelMetrics item) - { - this.metrics.add(item); - } - -} http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/f629d0f4/griffin-core/src/main/java/com/ebay/oss/griffin/vo/SystemLevelMetricsList.java ---------------------------------------------------------------------- diff --git a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/SystemLevelMetricsList.java b/griffin-core/src/main/java/com/ebay/oss/griffin/vo/SystemLevelMetricsList.java deleted file mode 100644 index 2b85a2a..0000000 --- a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/SystemLevelMetricsList.java +++ /dev/null @@ -1,371 +0,0 @@ -/* - Copyright (c) 2016 eBay Software Foundation. - 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.ebay.oss.griffin.vo; - -import java.util.ArrayList; -import java.util.Collections; -import java.util.List; -import java.util.Map; - -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -import com.ebay.oss.griffin.domain.MetricType; -import com.ebay.oss.griffin.domain.UserSubscription; - -public class SystemLevelMetricsList { - - private static Logger logger = LoggerFactory.getLogger(SystemLevelMetricsList.class); - - public List<SystemLevelMetrics> latestDQList = new ArrayList<SystemLevelMetrics>(); - - public String limitPlatform = "Apollo"; - - boolean containsAsset(String system, String name) { - for (SystemLevelMetrics tempSystemLevelMetrics : latestDQList) { - if (tempSystemLevelMetrics.getName().equals(system)) { - for (AssetLevelMetrics tempAssetLevelMetrics : tempSystemLevelMetrics.getMetrics()) { - if (tempAssetLevelMetrics.getName().equals(name)) { - return true; - } - } - } - } - return false; - } - - public SystemLevelMetrics getSystemLevelMetrics(String system) { - for (SystemLevelMetrics tempSystemLevelMetrics : latestDQList) { - if (tempSystemLevelMetrics.getName().equals(system)) { - return tempSystemLevelMetrics; - } - } - return null; - } - - - public List<SystemLevelMetrics> getListWithLatestNAssets(int N, String system, - UserSubscription subscribe, Map<String, String> assetMap) { - - List<SystemLevelMetrics> result = new ArrayList<SystemLevelMetrics>(); - try { - - for (SystemLevelMetrics tempSystemLevelMetrics : latestDQList) { - if (tempSystemLevelMetrics.getName().equals(system) || system.equals("all")) { - - SystemLevelMetrics tempSystemLevelMetrics1 = - new SystemLevelMetrics(tempSystemLevelMetrics.getName()); - tempSystemLevelMetrics1.setDq(tempSystemLevelMetrics.getDq()); - List<AssetLevelMetrics> metrics = tempSystemLevelMetrics.getMetrics(); - - boolean isCurrentSystemSelected; - if (subscribe != null) - isCurrentSystemSelected = - subscribe.isSystemSelected(limitPlatform, - tempSystemLevelMetrics.getName()); - else - isCurrentSystemSelected = true; - - for (AssetLevelMetrics tempAssetLevelMetrics : metrics) - { - boolean isCurrentDataassetSelected; - if (subscribe != null) - isCurrentDataassetSelected = - subscribe.isDataAssetSelected(limitPlatform, - tempSystemLevelMetrics.getName(), - assetMap.get(tempAssetLevelMetrics - .getName())); - else - isCurrentDataassetSelected = true; - - if (isCurrentSystemSelected || isCurrentDataassetSelected) - { - AssetLevelMetrics tempAssetLevelMetrics1 = - new AssetLevelMetrics(tempAssetLevelMetrics.getName(), - tempAssetLevelMetrics.getMetricType(), - tempAssetLevelMetrics.getDq(), - tempAssetLevelMetrics.getTimestamp(), - tempAssetLevelMetrics.getDqfail()); - List<AssetLevelMetricsDetail> otherdetails = - tempAssetLevelMetrics.getDetails(); - List<AssetLevelMetricsDetail> tempdetails = - new ArrayList<AssetLevelMetricsDetail>(); - if (otherdetails != null) - { - Collections.sort(otherdetails); - for (int i = 0; i < otherdetails.size() && i < N; i++) - { - tempdetails.add(otherdetails.get(i)); - } - } - - tempAssetLevelMetrics1.setDetails(tempdetails); - - tempSystemLevelMetrics1.addAssetLevelMetrics(tempAssetLevelMetrics1); - } - } - - if (tempSystemLevelMetrics1.getMetrics().size() > 0) - result.add(tempSystemLevelMetrics1); - } - } - } catch (Exception e) { - logger.error("{}", e); - } - return result; - } - - public AssetLevelMetrics getListWithSpecificAssetName(String name) - { - for (SystemLevelMetrics tempSystemLevelMetrics : latestDQList) - { - SystemLevelMetrics tempSystemLevelMetrics1 = - new SystemLevelMetrics(tempSystemLevelMetrics.getName()); - tempSystemLevelMetrics1.setDq(tempSystemLevelMetrics.getDq()); - for (AssetLevelMetrics tempAssetLevelMetrics : tempSystemLevelMetrics.getMetrics()) - { - if (tempAssetLevelMetrics.getName().equals(name)) - { - return tempAssetLevelMetrics; - } - } - } - - return null; - } - - public AssetLevelMetrics getListWithSpecificAssetName(String name, int count) - { - for (SystemLevelMetrics tempSystemLevelMetrics : latestDQList) - { - SystemLevelMetrics tempSystemLevelMetrics1 = - new SystemLevelMetrics(tempSystemLevelMetrics.getName()); - tempSystemLevelMetrics1.setDq(tempSystemLevelMetrics.getDq()); - for (AssetLevelMetrics tempAssetLevelMetrics : tempSystemLevelMetrics.getMetrics()) - { - if (tempAssetLevelMetrics.getName().equals(name)) - { - return new AssetLevelMetrics(tempAssetLevelMetrics, count); - } - } - } - - return null; - } - - public void updateDQFail(Map<String, String> thresholds) - { - for (SystemLevelMetrics tempSystemLevelMetrics : latestDQList) - { - for (AssetLevelMetrics tempAssetLevelMetrics : tempSystemLevelMetrics.getMetrics()) - { - if (thresholds.containsKey(tempAssetLevelMetrics.getName())) - { - if (tempAssetLevelMetrics.getDq() < Float.parseFloat(thresholds - .get(tempAssetLevelMetrics.getName()))) - { - tempAssetLevelMetrics.setDqfail(1); - } - } - } - } - } - - - public List<SystemLevelMetrics> getHeatMap(Map<String, String> thresholds) { - List<SystemLevelMetrics> result = new ArrayList<SystemLevelMetrics>(); - - SystemLevelMetricsList latestSysMetricsList = new SystemLevelMetricsList(); - latestSysMetricsList.setLatestDQList(latestDQList); - SystemLevelMetricsList resultSysMetricsList = new SystemLevelMetricsList(); - - for (SystemLevelMetrics tempSystemMetrics : latestDQList) { - int size = 0; - for (AssetLevelMetrics tempAssetLevelMetrics : tempSystemMetrics.getMetrics()) { - if (thresholds.containsKey(tempAssetLevelMetrics.getName())) { - if (tempAssetLevelMetrics.getDq() < Float.parseFloat(thresholds - .get(tempAssetLevelMetrics.getName()))) { - tempAssetLevelMetrics.setDqfail(1); - resultSysMetricsList.upsertNewAssetExecute( - tempAssetLevelMetrics.getName(), - tempAssetLevelMetrics.getMetricType(), - tempAssetLevelMetrics.getTimestamp(), - tempAssetLevelMetrics.getDq(), - tempSystemMetrics.getName(), - tempAssetLevelMetrics.getDqfail(), false, null); - - size++; - } - } - } - if (size == 0) { - SystemLevelMetrics sysMetric = new SystemLevelMetrics(tempSystemMetrics.getName()); - resultSysMetricsList.getLatestDQList().add(sysMetric); - } - } - - result = resultSysMetricsList.getLatestDQList(); - for (SystemLevelMetrics tempSystemLevelMetrics : result) { - int size = tempSystemLevelMetrics.getMetrics().size(); - String system = tempSystemLevelMetrics.getName(); - if (size >= 8) { - continue; - } - - SystemLevelMetrics latestSystLvlMetrics = latestSysMetricsList.getSystemLevelMetrics(tempSystemLevelMetrics - .getName()); - for (AssetLevelMetrics latestAssMetrics : latestSystLvlMetrics .getMetrics()) { - if (!resultSysMetricsList.containsAsset(system, latestAssMetrics.getName())) { - resultSysMetricsList.upsertNewAssetExecute( - latestAssMetrics.getName(), - latestAssMetrics.getMetricType(), - latestAssMetrics.getTimestamp(), - latestAssMetrics.getDq(), - system, - latestAssMetrics.getDqfail(), - false, null); - size++; - if (size >= 8) - break; - } - } - } - - return result; - } - - public void upsertNewAssetExecute(String metricName, String metricType, long metricTs, - float metricValue, String currentSystem, - int dqfail, boolean needdetail, - AssetLevelMetricsDetail otherAttributes) { - boolean systemFound = false; - if (currentSystem == null) { - currentSystem = "unknown"; - } - try { - for (SystemLevelMetrics tmpSysMetrics : latestDQList) { - // find the system item - if (!tmpSysMetrics.getName().equals(currentSystem)) { - continue; - } - systemFound = true; - - List<AssetLevelMetrics> tmpAssMetricsList = tmpSysMetrics.getMetrics(); - boolean metricFound = false; - for (int k = 0; k < tmpAssMetricsList.size(); k++) { - AssetLevelMetrics tempAssetLevelMetrics = tmpAssMetricsList.get(k); - // find the metric - if (!tempAssetLevelMetrics.getName().equals(metricName)) { - continue; - } - metricFound = true; - - if (tempAssetLevelMetrics.getTimestamp() - (metricTs) < 0) { - tempAssetLevelMetrics.setTimestamp(metricTs); - tempAssetLevelMetrics.setDq(metricValue); - tempAssetLevelMetrics.setDqfail(dqfail); - tmpAssMetricsList.set(k, tempAssetLevelMetrics); // FIXME why??? - } - if (!needdetail) { - continue; - } - - if (metricType.equals(MetricType.Bollinger.toString())) { - AssetLevelMetricsDetail detail = new AssetLevelMetricsDetail( - metricTs, - metricValue, otherAttributes.getBolling().clone() - ); - tempAssetLevelMetrics.addAssetLevelMetricsDetail(detail); - } else if (metricType.equals(MetricType.Trend.toString())) { - AssetLevelMetricsDetail detail = new AssetLevelMetricsDetail( - metricTs, - metricValue, - otherAttributes.getComparisionValue()); - tempAssetLevelMetrics.addAssetLevelMetricsDetail(detail); - } else if (metricType.equals(MetricType.MAD.toString())) { - tempAssetLevelMetrics - .addAssetLevelMetricsDetail(new AssetLevelMetricsDetail( - metricTs, metricValue, otherAttributes - .getMAD())); - } else { - tempAssetLevelMetrics - .addAssetLevelMetricsDetail(new AssetLevelMetricsDetail( - metricTs, metricValue)); - } - } - - // didn't find the metric, create one - if (!metricFound ) { - AssetLevelMetrics newTempAssetLevelMetrics = - new AssetLevelMetrics(metricName, metricType, metricValue, - metricTs, dqfail); - if (needdetail ) { - if (metricType.equals(MetricType.Bollinger.toString())) { - AssetLevelMetricsDetail detail = - new AssetLevelMetricsDetail( - metricTs, - metricValue, - otherAttributes.getBolling().clone()); - newTempAssetLevelMetrics .addAssetLevelMetricsDetail(detail); - } else if (metricType.equals(MetricType.Trend.toString())) { - newTempAssetLevelMetrics - .addAssetLevelMetricsDetail(new AssetLevelMetricsDetail( - metricTs, - metricValue, - otherAttributes.getComparisionValue())); - } else if (metricType.equals(MetricType.MAD.toString())) { - newTempAssetLevelMetrics - .addAssetLevelMetricsDetail(new AssetLevelMetricsDetail( - metricTs, metricValue, otherAttributes - .getMAD())); - } else { - newTempAssetLevelMetrics - .addAssetLevelMetricsDetail(new AssetLevelMetricsDetail( - metricTs, metricValue)); - } - } - tmpAssMetricsList.add(newTempAssetLevelMetrics); - } - } - } catch (Exception e) { - logger.error("{}", e); - } - - // can't find the system - if (!systemFound ) { - SystemLevelMetrics newSystemLevelMetrics = new SystemLevelMetrics(currentSystem); - newSystemLevelMetrics.addAssetLevelMetrics(new AssetLevelMetrics(metricName, - metricType, metricValue, metricTs, dqfail)); - if (needdetail ) { - List<AssetLevelMetricsDetail> tempDetailList = - new ArrayList<AssetLevelMetricsDetail>(); - tempDetailList.add(new AssetLevelMetricsDetail(metricTs, metricValue)); - newSystemLevelMetrics.getMetrics().get(0).setDetails(tempDetailList); - } - latestDQList.add(newSystemLevelMetrics); - } - } - - - public List<SystemLevelMetrics> getLatestDQList() { - return latestDQList; - } - - public void setLatestDQList(List<SystemLevelMetrics> latestDQList) { - this.latestDQList = latestDQList; - } - - -} http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/f629d0f4/griffin-core/src/main/java/com/ebay/oss/griffin/vo/SystemMetadata.java ---------------------------------------------------------------------- diff --git a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/SystemMetadata.java b/griffin-core/src/main/java/com/ebay/oss/griffin/vo/SystemMetadata.java deleted file mode 100644 index 6f91479..0000000 --- a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/SystemMetadata.java +++ /dev/null @@ -1,52 +0,0 @@ -/* - Copyright (c) 2016 eBay Software Foundation. - 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.ebay.oss.griffin.vo; - -import java.util.List; - -public class SystemMetadata{ - - private String id; - - private String name; - - private List<DataAssetIndex> assets; - - public String getId() { - return id; - } - - public void setId(String id) { - this.id = id; - } - - public String getName() { - return name; - } - - public void setName(String name) { - this.name = name; - } - - public List<DataAssetIndex> getAssets() { - return assets; - } - - public void setAssets(List<DataAssetIndex> assets) { - this.assets = assets; - } - - -} http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/f629d0f4/griffin-core/src/main/java/com/ebay/oss/griffin/vo/SystemSubscription.java ---------------------------------------------------------------------- diff --git a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/SystemSubscription.java b/griffin-core/src/main/java/com/ebay/oss/griffin/vo/SystemSubscription.java deleted file mode 100644 index a1da9e8..0000000 --- a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/SystemSubscription.java +++ /dev/null @@ -1,58 +0,0 @@ -/* - Copyright (c) 2016 eBay Software Foundation. - 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.ebay.oss.griffin.vo; - -import java.util.ArrayList; -import java.util.List; - -public class SystemSubscription { - String system; - boolean selectAll; - List<String> dataassets = new ArrayList<String>(); - - public SystemSubscription() { } - - public SystemSubscription(String system) { - this.system = system; - } - - public String getSystem() { - return system; - } - - public void setSystem(String system) { - this.system = system; - } - - public boolean isSelectAll() { - return selectAll; - } - - public void setSelectAll(boolean selectAll) { - this.selectAll = selectAll; - } - - public List<String> getDataassets() { - return dataassets; - } - - public void setDataassets(List<String> dataassets) { - this.dataassets = dataassets; - } - - - - -} http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/f629d0f4/griffin-core/src/main/java/com/ebay/oss/griffin/vo/ValidateHiveJobConfig.java ---------------------------------------------------------------------- diff --git a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/ValidateHiveJobConfig.java b/griffin-core/src/main/java/com/ebay/oss/griffin/vo/ValidateHiveJobConfig.java deleted file mode 100644 index 9561f65..0000000 --- a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/ValidateHiveJobConfig.java +++ /dev/null @@ -1,99 +0,0 @@ -/* - Copyright (c) 2016 eBay Software Foundation. - 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.ebay.oss.griffin.vo; - -import java.util.ArrayList; -import java.util.List; - -public class ValidateHiveJobConfig { - public String dataSet; - public List<ValidateHiveJobConfigLv1Detail> validityReq = new ArrayList<ValidateHiveJobConfigLv1Detail>(); - public List<PartitionConfig> timePartitions = new ArrayList<PartitionConfig>(); - - public ValidateHiveJobConfig() { } - - public ValidateHiveJobConfig(String dataSet) { - this.dataSet = dataSet; - } - - public String getDataSet() { - return dataSet; - } - - public void setDataSet(String dataSet) { - this.dataSet = dataSet; - } - - public List<ValidateHiveJobConfigLv1Detail> getValidityReq() { - return validityReq; - } - - public void setValidityReq(List<ValidateHiveJobConfigLv1Detail> validityReq) { - this.validityReq = validityReq; - } - - public List<PartitionConfig> getTimePartitions() { - return timePartitions; - } - - public void setTimePartitions(List<PartitionConfig> timePartitions) { - this.timePartitions = timePartitions; - } - - public void addColumnCalculation(int colId, String colName, int type) - { - if(validityReq == null) validityReq = new ArrayList<ValidateHiveJobConfigLv1Detail>(); - int lv1index = 0; - for(ValidateHiveJobConfigLv1Detail tempValidateHiveJobConfigLv1Detail : validityReq) - { - if(tempValidateHiveJobConfigLv1Detail.getColId() == colId && tempValidateHiveJobConfigLv1Detail.getColName().equals(colName)) - { - lv1index = 1; - tempValidateHiveJobConfigLv1Detail.getMetrics().add(new ValidateHiveJobConfigLv2Detail(type)); - } - } - if(lv1index == 0) - { - List<ValidateHiveJobConfigLv2Detail> newMetrics = new ArrayList<ValidateHiveJobConfigLv2Detail>(); - newMetrics.add(new ValidateHiveJobConfigLv2Detail(type)); - ValidateHiveJobConfigLv1Detail newValidateHiveJobConfigLv1Detail = new ValidateHiveJobConfigLv1Detail(colId, colName, newMetrics); - validityReq.add(newValidateHiveJobConfigLv1Detail); - } - } - - public long getValue(String colName, int type) - { - long result = Long.MIN_VALUE; - for(ValidateHiveJobConfigLv1Detail tempValidateHiveJobConfigLv1Detail : validityReq) - { - if(tempValidateHiveJobConfigLv1Detail.getColName().equals(colName)) - { - for(ValidateHiveJobConfigLv2Detail tempValidateHiveJobConfigLv2Detail : tempValidateHiveJobConfigLv1Detail.getMetrics()) - { - if(tempValidateHiveJobConfigLv2Detail.getName()==type) - { - return (long) tempValidateHiveJobConfigLv2Detail.getResult(); - } - } - } - } - - return result; - } - - - - -} http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/f629d0f4/griffin-core/src/main/java/com/ebay/oss/griffin/vo/ValidateHiveJobConfigLv1Detail.java ---------------------------------------------------------------------- diff --git a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/ValidateHiveJobConfigLv1Detail.java b/griffin-core/src/main/java/com/ebay/oss/griffin/vo/ValidateHiveJobConfigLv1Detail.java deleted file mode 100644 index b64ef77..0000000 --- a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/ValidateHiveJobConfigLv1Detail.java +++ /dev/null @@ -1,59 +0,0 @@ -/* - Copyright (c) 2016 eBay Software Foundation. - 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.ebay.oss.griffin.vo; - -import java.util.ArrayList; -import java.util.List; - -public class ValidateHiveJobConfigLv1Detail { - public int colId; - public String colName; - public List<ValidateHiveJobConfigLv2Detail> metrics = new ArrayList<ValidateHiveJobConfigLv2Detail>(); - - public ValidateHiveJobConfigLv1Detail() { } - - public ValidateHiveJobConfigLv1Detail(int colId, String colName, List<ValidateHiveJobConfigLv2Detail> metrics) { - this.colId = colId; - this.colName = colName; - this.metrics = metrics; - } - - public int getColId() { - return colId; - } - - public void setColId(int colId) { - this.colId = colId; - } - - public String getColName() { - return colName; - } - - public void setColName(String colName) { - this.colName = colName; - } - - public List<ValidateHiveJobConfigLv2Detail> getMetrics() { - return metrics; - } - - public void setMetrics(List<ValidateHiveJobConfigLv2Detail> metrics) { - this.metrics = metrics; - } - - - -} http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/f629d0f4/griffin-core/src/main/java/com/ebay/oss/griffin/vo/ValidateHiveJobConfigLv2Detail.java ---------------------------------------------------------------------- diff --git a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/ValidateHiveJobConfigLv2Detail.java b/griffin-core/src/main/java/com/ebay/oss/griffin/vo/ValidateHiveJobConfigLv2Detail.java deleted file mode 100644 index 1a2e805..0000000 --- a/griffin-core/src/main/java/com/ebay/oss/griffin/vo/ValidateHiveJobConfigLv2Detail.java +++ /dev/null @@ -1,52 +0,0 @@ -/* - Copyright (c) 2016 eBay Software Foundation. - 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.ebay.oss.griffin.vo; - - -public class ValidateHiveJobConfigLv2Detail { - private int name; - private double result; - - public ValidateHiveJobConfigLv2Detail() { } - - public ValidateHiveJobConfigLv2Detail(int name) { - this.name = name; - } - - public ValidateHiveJobConfigLv2Detail(int name, double result) { - this.name = name; - this.result = result; - } - - public int getName() { - return name; - } - - public void setName(int name) { - this.name = name; - } - - public double getResult() { - return result; - } - - public void setResult(double result) { - this.result = result; - } - - - - -} http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/f629d0f4/griffin-core/src/main/resources/application.properties ---------------------------------------------------------------------- diff --git a/griffin-core/src/main/resources/application.properties b/griffin-core/src/main/resources/application.properties deleted file mode 100644 index 2eda2b9..0000000 --- a/griffin-core/src/main/resources/application.properties +++ /dev/null @@ -1,36 +0,0 @@ -# -# Copyright (c) 2016 eBay Software Foundation. -# 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. - -#ldap query, this is used for user login service -# ldap.server=localhost -# ldap.port=389 -#ldap.user=test -#ldap.pass=test - -####QA version -env=prod -#job.local.folder=C:\\bark -#This is used to store the temporary files, make sure the process has write -#permission on this folder -job.local.folder=/griffin/tmp -#This is used to store the job running files on hadoop, make sure the process -#has write permission on this folder -job.hdfs.folder=/user/griffin -job.hdfs.runningfoldername=running -job.hdfs.historyfoldername=history -job.hdfs.failurefoldername=failure -#Specify the mongodb information here -#spring.data.mongodb.host=dart-8984.phx02.dev.ebayc3.com -spring.data.mongodb.host=localhost -spring.data.mongodb.port=27017 http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/f629d0f4/griffin-core/src/main/resources/log4j.properties ---------------------------------------------------------------------- diff --git a/griffin-core/src/main/resources/log4j.properties b/griffin-core/src/main/resources/log4j.properties deleted file mode 100644 index a1be8fc..0000000 --- a/griffin-core/src/main/resources/log4j.properties +++ /dev/null @@ -1,5 +0,0 @@ -log4j.rootLogger=INFO, stdout -log4j.appender.stdout=org.apache.log4j.ConsoleAppender -log4j.appender.stdout.Target=System.out -log4j.appender.stdout.layout=org.apache.log4j.PatternLayout -log4j.appender.stdout.layout.ConversionPattern=%d{yyyy-MM-dd'T'HH:mm:ss.SSS} %-5p [%c] - %m%n \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/f629d0f4/griffin-core/src/main/webapp/WEB-INF/spring/context.xml ---------------------------------------------------------------------- diff --git a/griffin-core/src/main/webapp/WEB-INF/spring/context.xml b/griffin-core/src/main/webapp/WEB-INF/spring/context.xml deleted file mode 100644 index 6117bb9..0000000 --- a/griffin-core/src/main/webapp/WEB-INF/spring/context.xml +++ /dev/null @@ -1,49 +0,0 @@ -<?xml version="1.0" encoding="UTF-8"?> -<!-- Copyright (c) 2016 eBay Software Foundation. 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. --> -<beans xmlns="http://www.springframework.org/schema/beans"; - xmlns:context="http://www.springframework.org/schema/context"; - xmlns:mvc="http://www.springframework.org/schema/mvc"; - xmlns:task="http://www.springframework.org/schema/task"; - xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; - xsi:schemaLocation="http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-3.1.xsd - http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.1.xsd - http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.1.xsd - http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.1.xsd - http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-3.1.xsd";> - - - <context:annotation-config /> - - <context:component-scan base-package="com.ebay.oss.griffin.common" /> - <context:component-scan base-package="com.ebay.oss.griffin.domain" /> - <context:component-scan base-package="com.ebay.oss.griffin.repo" /> - <context:component-scan base-package="com.ebay.oss.griffin.error" /> - <context:component-scan base-package="com.ebay.oss.griffin.service" /> - <context:component-scan base-package="com.ebay.oss.griffin.ebay" /> - <context:component-scan base-package="com.ebay.oss.griffin.resources" /> - - <bean id="modelCreatorChain" class="com.ebay.oss.griffin.service.modelcreator.DqModelCreatorChain"> - <constructor-arg> - <list> - <ref bean="accuracyModelCreator"/> - <ref bean="anomalyModelCreator"/> - <ref bean="publishModelCreator"/> - <ref bean="validityModelCreator"/> - </list> - </constructor-arg> - </bean> - - - <task:scheduled-tasks scheduler="griffinScheduler"> - <task:scheduled ref="dqmetrics" method="updateLatestDQList" fixed-delay="180000"/> - <task:scheduled ref="scheduleService" method="schedulingJobs" fixed-delay="120000"/> - </task:scheduled-tasks> - <task:scheduler id="griffinScheduler" pool-size="5"/> - -</beans> http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/f629d0f4/griffin-core/src/main/webapp/WEB-INF/spring/static-context.xml ---------------------------------------------------------------------- diff --git a/griffin-core/src/main/webapp/WEB-INF/spring/static-context.xml b/griffin-core/src/main/webapp/WEB-INF/spring/static-context.xml deleted file mode 100644 index 58756c8..0000000 --- a/griffin-core/src/main/webapp/WEB-INF/spring/static-context.xml +++ /dev/null @@ -1,25 +0,0 @@ -<?xml version="1.0" encoding="UTF-8"?> -<beans:beans xmlns="http://www.springframework.org/schema/mvc"; - xmlns:mvc="http://www.springframework.org/schema/mvc"; - xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; - xmlns:beans="http://www.springframework.org/schema/beans"; - xmlns:context="http://www.springframework.org/schema/context"; - xmlns:aop="http://www.springframework.org/schema/aop"; - xmlns:task="http://www.springframework.org/schema/task"; - xsi:schemaLocation=" - http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-3.1.xsd - http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.1.xsd - http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.1.xsd - http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.1.xsd - http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-3.1.xsd";> - - <!-- DispatcherServlet Context: defines this servlet's request-processing infrastructure --> - - <!-- Allow proxys --> - <aop:aspectj-autoproxy /> - <mvc:annotation-driven></mvc:annotation-driven> - - <mvc:resources mapping="/**" location="/" /> - - -</beans:beans> http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/f629d0f4/griffin-core/src/main/webapp/WEB-INF/web.xml ---------------------------------------------------------------------- diff --git a/griffin-core/src/main/webapp/WEB-INF/web.xml b/griffin-core/src/main/webapp/WEB-INF/web.xml deleted file mode 100644 index 519295a..0000000 --- a/griffin-core/src/main/webapp/WEB-INF/web.xml +++ /dev/null @@ -1,77 +0,0 @@ -<?xml version="1.0" encoding="UTF-8"?> -<!-- Copyright (c) 2016 eBay Software Foundation. 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. --> -<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; - xmlns="http://java.sun.com/xml/ns/javaee"; xmlns:web="http://java.sun.com/xml/ns/javaee"; - xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd"; - id="WebApp_ID" version="3.0"> - <display-name>bark-core</display-name> - <welcome-file-list> - <welcome-file>index.html</welcome-file> - <welcome-file>index.htm</welcome-file> - <welcome-file>index.jsp</welcome-file> - <welcome-file>default.html</welcome-file> - <welcome-file>default.htm</welcome-file> - <welcome-file>index</welcome-file> - </welcome-file-list> - <listener> - <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class> - </listener> - <context-param> - <param-name>contextConfigLocation</param-name> - <param-value>/WEB-INF/spring/context.xml</param-value> - </context-param> - <filter> - <filter-name>CORSFilter</filter-name> - <filter-class>com.ebay.oss.griffin.common.SimpleCORSFilter</filter-class> - </filter> - <filter-mapping> - <filter-name>CORSFilter</filter-name> - <servlet-name>*</servlet-name> - <dispatcher>REQUEST</dispatcher> - <dispatcher>INCLUDE</dispatcher> - <dispatcher>FORWARD</dispatcher> - </filter-mapping> - <servlet> - <servlet-name>jersey-serlvet</servlet-name> - <servlet-class> - com.sun.jersey.spi.spring.container.servlet.SpringServlet - </servlet-class> - <init-param> - <param-name>com.sun.jersey.config.property.packages</param-name> - <param-value>org.apache.griffin.resources</param-value> - </init-param> - <init-param> - <param-name>com.sun.jersey.api.json.POJOMappingFeature</param-name> - <param-value>true</param-value> - </init-param> - <load-on-startup>1</load-on-startup> - </servlet> - - <servlet> - <servlet-name>StaticServlet</servlet-name> - <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class> - - <init-param> - <param-name>contextConfigLocation</param-name> - <param-value>/WEB-INF/spring/static-context.xml</param-value> - </init-param> - - <load-on-startup>1</load-on-startup> - </servlet> - - <servlet-mapping> - <servlet-name>jersey-serlvet</servlet-name> - <url-pattern>/api/v1/*</url-pattern> - </servlet-mapping> - - <servlet-mapping> - <servlet-name>StaticServlet</servlet-name> - <url-pattern>/</url-pattern> - </servlet-mapping> -</web-app> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/f629d0f4/griffin-core/src/main/webapp/WEB-INF/webres/resource.properties ---------------------------------------------------------------------- diff --git a/griffin-core/src/main/webapp/WEB-INF/webres/resource.properties b/griffin-core/src/main/webapp/WEB-INF/webres/resource.properties deleted file mode 100644 index e69de29..0000000 http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/f629d0f4/griffin-core/src/test/java/com/ebay/oss/griffin/common/CommonResourceTest.java ---------------------------------------------------------------------- diff --git a/griffin-core/src/test/java/com/ebay/oss/griffin/common/CommonResourceTest.java b/griffin-core/src/test/java/com/ebay/oss/griffin/common/CommonResourceTest.java deleted file mode 100644 index 03aa6fd..0000000 --- a/griffin-core/src/test/java/com/ebay/oss/griffin/common/CommonResourceTest.java +++ /dev/null @@ -1,34 +0,0 @@ -package com.ebay.oss.griffin.common; - -import org.junit.Test; - -import com.ebay.oss.griffin.common.Pair; - -import java.util.*; - -import static org.junit.Assert.*; - -public class CommonResourceTest { - - @Test - public void testPair() { - Pair pair = new Pair("key", "value"); - Pair pair1 = new Pair("key", "value"); - Pair pair2 = new Pair("key", "notVal"); - Pair pair3 = new Pair("notKey", "notVal"); - - assertEquals(pair.hashCode(), pair1.hashCode()); - assertTrue(pair.hashCode() != pair2.hashCode()); - - assertTrue(pair.equals(pair)); - assertFalse(pair.equals(null)); - assertTrue(pair.equals(pair1)); - assertFalse(pair.equals(pair2)); - assertFalse(pair.equals(pair3)); - assertFalse(pair.equals("key value")); - assertTrue(new Pair(null, null).equals(new Pair(null, null))); - assertFalse(new Pair(null, null).equals(new Pair("key", null))); - assertTrue(new Pair("key", null).equals(new Pair("key", null))); - assertFalse(new Pair("key", null).equals(new Pair("key", "val"))); - } -} http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/f629d0f4/griffin-core/src/test/java/com/ebay/oss/griffin/domain/DomainResourceTest.java ---------------------------------------------------------------------- diff --git a/griffin-core/src/test/java/com/ebay/oss/griffin/domain/DomainResourceTest.java b/griffin-core/src/test/java/com/ebay/oss/griffin/domain/DomainResourceTest.java deleted file mode 100644 index 9e09a68..0000000 --- a/griffin-core/src/test/java/com/ebay/oss/griffin/domain/DomainResourceTest.java +++ /dev/null @@ -1,255 +0,0 @@ -package com.ebay.oss.griffin.domain; - -import com.ebay.oss.griffin.domain.DataAsset; -import com.ebay.oss.griffin.domain.DataSchema; -import com.ebay.oss.griffin.domain.DqJob; -import com.ebay.oss.griffin.domain.DqMetricsValue; -import com.ebay.oss.griffin.domain.DqModel; -import com.ebay.oss.griffin.domain.DqSchedule; -import com.ebay.oss.griffin.domain.IdEntity; -import com.ebay.oss.griffin.domain.JobStatus; -import com.ebay.oss.griffin.domain.PartitionFormat; -import com.ebay.oss.griffin.domain.SampleFilePathLKP; -import com.ebay.oss.griffin.domain.UserSubscription; -import com.ebay.oss.griffin.vo.PlatformSubscription; -import com.ebay.oss.griffin.vo.SystemSubscription; - -import org.junit.Test; - -import java.util.ArrayList; -import java.util.Date; -import java.util.List; - -import static org.junit.Assert.*; - -public class DomainResourceTest { - - @Test - public void testDataAsset() { - DataAsset asset = new DataAsset(); - - asset.setPlatform("platform"); - assertEquals("platform", asset.getPlatform()); - asset.setSystem("system"); - assertEquals("system", asset.getSystem()); - asset.setAssetName("name"); - assertEquals("name", asset.getAssetName()); - asset.setAssetType("type"); - assertEquals("type", asset.getAssetType()); - asset.setAssetHDFSPath("path"); - assertEquals("path", asset.getAssetHDFSPath()); - asset.setOwner("owner"); - assertEquals("owner", asset.getOwner()); - Date dt = new Date(); - asset.setTimestamp(dt); - assertEquals(dt, asset.getTimestamp()); - - List<DataSchema> schema = new ArrayList<DataSchema>(); - schema.add(new DataSchema("sname", "stype", "sdesc", "ssample")); - asset.setSchema(schema); - assertEquals(schema, asset.getSchema()); - - List<PartitionFormat> partitions = new ArrayList<PartitionFormat>(); - partitions.add(new PartitionFormat("pname", "pformat")); - asset.setPartitions(partitions); - assertEquals(partitions, asset.getPartitions()); - - assertEquals(asset.getColId("sname"), 0); - assertEquals(asset.getColId("sname_unknown"), -1); - } - - @Test - public void testDataSchema() { - DataSchema schema = new DataSchema(); - - schema.setName("name"); - assertEquals("name", schema.getName()); - schema.setType("type"); - assertEquals("type", schema.getType()); - schema.setDesc("desc"); - assertEquals("desc", schema.getDesc()); - schema.setSample("sample"); - assertEquals("sample", schema.getSample()); - } - - @Test - public void testDqMetricsValue() { - DqMetricsValue dmv = new DqMetricsValue(); - - dmv.setAssetId("id"); - assertEquals("id", dmv.getAssetId()); - dmv.setValue(3.56f); - assertTrue(3.56f == dmv.getValue()); - dmv.setMetricName("name"); - assertEquals("name", dmv.getMetricName()); - dmv.setTimestamp(12345L); - assertEquals(12345L, dmv.getTimestamp()); - dmv.set_id(12345L); - assertEquals(new Long(12345L), dmv.get_id()); - - DqMetricsValue dmv1 = new DqMetricsValue("name", 12345L, 20.3f); - assertEquals(0, dmv1.compareTo(dmv)); - - dmv1.setTimestamp(12346L); - assertEquals(-1, dmv1.compareTo(dmv)); - dmv1.setTimestamp(12344L); - assertEquals(1, dmv1.compareTo(dmv)); - } - - @Test - public void testDqModel() { - DqModel dm = new DqModel(); - - dm.setModelId("id"); - assertEquals("id", dm.getModelId()); - dm.setModelName("name"); - assertEquals("name", dm.getModelName()); - dm.setModelType(2); - assertEquals(2, dm.getModelType()); - dm.setModelDesc("desc"); - assertEquals("desc", dm.getModelDesc()); - dm.setAssetId(12345L); - assertEquals(12345L, dm.getAssetId()); - dm.setThreshold(1.2f); - assertTrue(1.2f == dm.getThreshold()); - dm.setNotificationEmail("[email protected]"); - assertEquals("[email protected]", dm.getNotificationEmail()); - dm.setOwner("owner"); - assertEquals("owner", dm.getOwner()); - dm.setStatus(1); - assertEquals(1, dm.getStatus()); - dm.setModelContent("content"); - assertEquals("content", dm.getModelContent()); - dm.setTimestamp(12345L); - assertEquals(12345L, dm.getTimestamp()); - dm.setSchedule(3); - assertEquals(3, dm.getSchedule()); - dm.setSystem(1); - assertEquals(1, dm.getSystem()); - dm.setAssetName("asset"); - assertEquals("asset", dm.getAssetName()); - dm.setReferenceModel("ref"); - assertEquals("ref", dm.getReferenceModel()); - dm.setStarttime(12345L); - assertEquals(12345L, dm.getStarttime()); - - } - - @Test - public void testDqJob() { - DqJob dj = new DqJob(); - - dj.setId("id"); - assertEquals("id", dj.getId()); - dj.setModelList("list"); - assertEquals("list", dj.getModelList()); - dj.setContent("content"); - assertEquals("content", dj.getContent()); - dj.setStatus(3); - assertEquals(3, dj.getStatus()); - dj.setStarttime(12345L); - assertEquals(12345L, dj.getStarttime()); - dj.setEndtime(12345L); - assertEquals(12345L, dj.getEndtime()); - dj.setValue(12345L); - assertEquals(12345L, dj.getValue()); - dj.setJobType(2); - assertEquals(2, dj.getJobType()); - } - - @Test - public void testDqSchedule() { - DqSchedule ds = new DqSchedule(); - - ds.setStatus(1); - assertEquals(1, ds.getStatus()); - ds.setStarttime(12345L); - assertEquals(12345L, ds.getStarttime()); - ds.setContent("content"); - assertEquals("content", ds.getContent()); - ds.setScheduleType(2); - assertEquals(2, ds.getScheduleType()); - ds.setModelList("list"); - assertEquals("list", ds.getModelList()); - ds.setAssetId(12345L); - assertEquals(12345L, ds.getAssetId()); - ds.setJobType(3); - assertEquals(3, ds.getJobType()); - - } - - @Test - public void testIdEntity() { - IdEntity ide = new IdEntity(); - - ide.set_id(12345L); - assertEquals(new Long(12345L), ide.get_id()); - } - - @Test - public void testJobStatus() { - assertEquals(0, JobStatus.READY); - } - - @Test - public void testPartitionFormat() { - PartitionFormat pf = new PartitionFormat(); - - pf.setName("name"); - assertEquals("name", pf.getName()); - pf.setFormat("format"); - assertEquals("format", pf.getFormat()); - - PartitionFormat pf1 = new PartitionFormat("name1", "format1"); - assertEquals("name1", pf1.getName()); - assertEquals("format1", pf1.getFormat()); - } - - @Test - public void testSampleFilePathLKP() { - SampleFilePathLKP sfp = new SampleFilePathLKP(); - - sfp.setModelName("name"); - assertEquals("name", sfp.getModelName()); - sfp.setHdfsPath("path"); - assertEquals("path", sfp.getHdfsPath()); - sfp.setTimestamp(12345L); - assertEquals(12345L, sfp.getTimestamp()); - } - - @Test - public void testUserSubscription() { - UserSubscription us = new UserSubscription(); - - us.setId("id"); - assertEquals("id", us.getId()); - us.setNtaccount("count"); - assertEquals("count", us.getNtaccount()); - - List<PlatformSubscription> psList = new ArrayList<PlatformSubscription>(); - PlatformSubscription ps = new PlatformSubscription("platform"); - ps.setSelectAll(true); - List<SystemSubscription> ssList = new ArrayList<SystemSubscription>(); - SystemSubscription ss = new SystemSubscription("system"); - ss.setSelectAll(true); - List<String> daList = new ArrayList<String>(); - daList.add("dataAsset"); - ss.setDataassets(daList); - ssList.add(ss); - ps.setSystems(ssList); - psList.add(ps); - us.setSubscribes(psList); - assertEquals(psList, us.getSubscribes()); - - assertTrue(us.isPlatformSelected("platform")); - assertFalse(us.isPlatformSelected("platform1")); - - assertTrue(us.isSystemSelected("platform", "system")); - assertFalse(us.isSystemSelected("platform", "system1")); - - assertTrue(us.isDataAssetSelected("platform", "system", "dataAsset")); - assertFalse(us.isDataAssetSelected("platform", "system", "dataAsset1")); - - UserSubscription us1 = new UserSubscription("user"); - } -}
