You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by ak...@apache.org on 2019/01/17 20:30:23 UTC
[incubator-pinot] branch master updated: [TE] Remove new pipeline
prefix and inject yaml in Detection Config (#3708)
This is an automated email from the ASF dual-hosted git repository.
akshayrai09 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git
The following commit(s) were added to refs/heads/master by this push:
new 9cc609d [TE] Remove new pipeline prefix and inject yaml in Detection Config (#3708)
9cc609d is described below
commit 9cc609d70840f61a48c8f28750badac287c80c9d
Author: Akshay Rai <ak...@gmail.com>
AuthorDate: Thu Jan 17 12:30:17 2019 -0800
[TE] Remove new pipeline prefix and inject yaml in Detection Config (#3708)
---
.../pinot/thirdeye/detection/DetectionMigrationResource.java | 2 +-
.../thirdeye/detection/yaml/YamlDetectionConfigTranslator.java | 8 ++++++++
2 files changed, 9 insertions(+), 1 deletion(-)
diff --git a/thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/detection/DetectionMigrationResource.java b/thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/detection/DetectionMigrationResource.java
index 7aec064..400de25 100644
--- a/thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/detection/DetectionMigrationResource.java
+++ b/thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/detection/DetectionMigrationResource.java
@@ -94,7 +94,7 @@ public class DetectionMigrationResource {
AnomalyFunctionDTO anomalyFunctionDTO = this.anomalyFunctionDAO.findById(anomalyFunctionId);
Preconditions.checkArgument(anomalyFunctionDTO.getIsActive(), "try to migrate inactive anomaly function");
Map<String, Object> yamlConfigs = new LinkedHashMap<>();
- yamlConfigs.put("detectionName", "new_pipeline_" + anomalyFunctionDTO.getFunctionName());
+ yamlConfigs.put("detectionName", anomalyFunctionDTO.getFunctionName());
yamlConfigs.put("metric", anomalyFunctionDTO.getMetric());
yamlConfigs.put("dataset", anomalyFunctionDTO.getCollection());
yamlConfigs.put("pipelineType", "Composite");
diff --git a/thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/detection/yaml/YamlDetectionConfigTranslator.java b/thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/detection/yaml/YamlDetectionConfigTranslator.java
index 9fbe6f5..eaea987 100644
--- a/thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/detection/yaml/YamlDetectionConfigTranslator.java
+++ b/thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/detection/yaml/YamlDetectionConfigTranslator.java
@@ -27,6 +27,8 @@ import java.util.Map;
import org.apache.commons.collections.MapUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+import org.yaml.snakeyaml.DumperOptions;
+import org.yaml.snakeyaml.Yaml;
/**
@@ -84,6 +86,12 @@ public abstract class YamlDetectionConfigTranslator {
config.setProperties(translationResult.getProperties());
config.setComponentSpecs(translationResult.getComponents());
config.setCron(translationResult.getCron());
+
+ DumperOptions options = new DumperOptions();
+ options.setDefaultFlowStyle(DumperOptions.FlowStyle.BLOCK);
+ options.setPrettyFlow(true);
+ config.setYaml(new Yaml(options).dump(yamlConfig));
+
if (existingConfig != null) {
config.setId(existingConfig.getId());
config.setLastTimestamp(existingConfig.getLastTimestamp());
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org