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/06/28 22:14:28 UTC

[incubator-pinot] branch master updated: [TE] Log the registry components (#4384)

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 e28eeb3  [TE] Log the registry components (#4384)
e28eeb3 is described below

commit e28eeb3de33ec52e7d0a25e372ad0fd61acb3cc6
Author: Akshay Rai <ak...@gmail.com>
AuthorDate: Fri Jun 28 15:14:23 2019 -0700

    [TE] Log the registry components (#4384)
---
 .../thirdeye/detection/annotation/registry/DetectionRegistry.java    | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/detection/annotation/registry/DetectionRegistry.java b/thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/detection/annotation/registry/DetectionRegistry.java
index a66a728..d7f8070 100644
--- a/thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/detection/annotation/registry/DetectionRegistry.java
+++ b/thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/detection/annotation/registry/DetectionRegistry.java
@@ -82,10 +82,12 @@ public class DetectionRegistry {
             REGISTRY_MAP.put(componentsAnnotation.type(),
                 ImmutableMap.of(KEY_CLASS_NAME, className, KEY_ANNOTATION, componentsAnnotation,
                     KEY_IS_BASELINE_PROVIDER, isBaselineProvider(clazz)));
+            LOG.info("Registered component {} - {}", componentsAnnotation.type(), className);
           }
           if (annotation instanceof Tune) {
             Tune tunableAnnotation = (Tune) annotation;
             TUNE_MAP.put(className, tunableAnnotation);
+            LOG.info("Registered tuner {}", className);
           }
         }
       }
@@ -98,6 +100,7 @@ public class DetectionRegistry {
     try {
       Class<? extends BaseComponent> clazz = (Class<? extends BaseComponent>) Class.forName(className);
       REGISTRY_MAP.put(type, ImmutableMap.of(KEY_CLASS_NAME, className, KEY_IS_BASELINE_PROVIDER, isBaselineProvider(clazz)));
+      LOG.info("Registered component {} {}", type, className);
     } catch (Exception e) {
       LOG.warn("Encountered exception when registering component {}", className, e);
     }
@@ -119,6 +122,7 @@ public class DetectionRegistry {
         }
       };
       TUNE_MAP.put(className, tune);
+      LOG.info("Registered tunable component {} {}", type, className);
     } catch (Exception e) {
       LOG.warn("Encountered exception when registering component {}", className, e);
     }
@@ -126,6 +130,7 @@ public class DetectionRegistry {
 
   public static void registerYamlConvertor(String className, String type) {
     YAML_MAP.put(type, className);
+    LOG.info("Registered yaml convertor {} {}", type, className);
   }
 
   /**


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org