apex-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vro...@apache.org
Subject apex-core git commit: APEXCORE-611 Added log levels for Stram Events
Date Sat, 28 Jan 2017 05:23:21 GMT
Repository: apex-core
Updated Branches:
  refs/heads/master 42c695c6f -> a8b60f68e


APEXCORE-611 Added log levels for Stram Events


Project: http://git-wip-us.apache.org/repos/asf/apex-core/repo
Commit: http://git-wip-us.apache.org/repos/asf/apex-core/commit/a8b60f68
Tree: http://git-wip-us.apache.org/repos/asf/apex-core/tree/a8b60f68
Diff: http://git-wip-us.apache.org/repos/asf/apex-core/diff/a8b60f68

Branch: refs/heads/master
Commit: a8b60f68e5711a9d365d2cf749a13f84aef18b0a
Parents: 42c695c
Author: ajaygit158 <ajaygit158@gmail.com>
Authored: Wed Jan 25 15:11:23 2017 +0530
Committer: ajaygit158 <ajaygit158@gmail.com>
Committed: Sat Jan 28 08:30:26 2017 +0530

----------------------------------------------------------------------
 .../com/datatorrent/stram/api/StramEvent.java   | 106 ++++++++++++++++---
 1 file changed, 94 insertions(+), 12 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/apex-core/blob/a8b60f68/engine/src/main/java/com/datatorrent/stram/api/StramEvent.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/com/datatorrent/stram/api/StramEvent.java b/engine/src/main/java/com/datatorrent/stram/api/StramEvent.java
index ba9b55d..e9c5f13 100644
--- a/engine/src/main/java/com/datatorrent/stram/api/StramEvent.java
+++ b/engine/src/main/java/com/datatorrent/stram/api/StramEvent.java
@@ -34,12 +34,14 @@ public abstract class StramEvent
   private final long id;
   private long timestamp = System.currentTimeMillis();
   private String reason;
+  private LogLevel logLevel;
 
   public abstract String getType();
 
-  protected StramEvent()
+  protected StramEvent(LogLevel logLevel)
   {
     id = nextId.getAndIncrement();
+    this.logLevel = logLevel;
   }
 
   public long getId()
@@ -67,12 +69,28 @@ public abstract class StramEvent
     this.reason = reason;
   }
 
+  public LogLevel getLogLevel()
+  {
+    return logLevel;
+  }
+
+  public static enum LogLevel
+  {
+    TRACE,
+    DEBUG,
+    INFO,
+    WARN,
+    ERROR,
+    FATAL;
+  }
+
   public abstract static class OperatorEvent extends StramEvent
   {
     private String operatorName;
 
-    public OperatorEvent(String operatorName)
+    public OperatorEvent(String operatorName, LogLevel logLevel)
     {
+      super(logLevel);
       this.operatorName = operatorName;
     }
 
@@ -95,7 +113,12 @@ public abstract class StramEvent
 
     public SetOperatorPropertyEvent(String operatorName, String propertyName, String propertyValue)
     {
-      super(operatorName);
+      this(operatorName, propertyName, propertyValue, LogLevel.INFO);
+    }
+
+    public SetOperatorPropertyEvent(String operatorName, String propertyName, String propertyValue,
LogLevel logLevel)
+    {
+      super(operatorName, logLevel);
       this.propertyName = propertyName;
       this.propertyValue = propertyValue;
     }
@@ -135,7 +158,12 @@ public abstract class StramEvent
 
     public PartitionEvent(String operatorName, int oldNumPartitions, int newNumPartitions)
     {
-      super(operatorName);
+      this(operatorName, oldNumPartitions, newNumPartitions, LogLevel.INFO);
+    }
+
+    public PartitionEvent(String operatorName, int oldNumPartitions, int newNumPartitions,
LogLevel logLevel)
+    {
+      super(operatorName, logLevel);
       this.oldNumPartitions = oldNumPartitions;
       this.newNumPartitions = newNumPartitions;
     }
@@ -172,9 +200,9 @@ public abstract class StramEvent
   {
     private final int operatorId;
 
-    public PhysicalOperatorEvent(String operatorName, int operatorId)
+    public PhysicalOperatorEvent(String operatorName, int operatorId, LogLevel logLevel)
     {
-      super(operatorName);
+      super(operatorName, logLevel);
       this.operatorId = operatorId;
     }
 
@@ -189,7 +217,12 @@ public abstract class StramEvent
   {
     public CreateOperatorEvent(String operatorName, int operatorId)
     {
-      super(operatorName, operatorId);
+      this(operatorName, operatorId, LogLevel.INFO);
+    }
+
+    public CreateOperatorEvent(String operatorName, int operatorId, LogLevel logLevel)
+    {
+      super(operatorName, operatorId, logLevel);
     }
 
     @Override
@@ -204,7 +237,12 @@ public abstract class StramEvent
   {
     public RemoveOperatorEvent(String operatorName, int operatorId)
     {
-      super(operatorName, operatorId);
+      this(operatorName, operatorId, LogLevel.INFO);
+    }
+
+    public RemoveOperatorEvent(String operatorName, int operatorId, LogLevel logLevel)
+    {
+      super(operatorName, operatorId, logLevel);
     }
 
     @Override
@@ -221,7 +259,12 @@ public abstract class StramEvent
 
     public StartOperatorEvent(String operatorName, int operatorId, String containerId)
     {
-      super(operatorName, operatorId);
+      this(operatorName, operatorId, containerId, LogLevel.INFO);
+    }
+
+    public StartOperatorEvent(String operatorName, int operatorId, String containerId, LogLevel
logLevel)
+    {
+      super(operatorName, operatorId, logLevel);
       this.containerId = containerId;
     }
 
@@ -249,7 +292,12 @@ public abstract class StramEvent
 
     public StopOperatorEvent(String operatorName, int operatorId, String containerId)
     {
-      super(operatorName, operatorId);
+      this(operatorName, operatorId, containerId, LogLevel.WARN);
+    }
+
+    public StopOperatorEvent(String operatorName, int operatorId, String containerId, LogLevel
logLevel)
+    {
+      super(operatorName, operatorId, logLevel);
       this.containerId = containerId;
     }
 
@@ -278,7 +326,12 @@ public abstract class StramEvent
 
     public SetPhysicalOperatorPropertyEvent(String operatorName, int operatorId, String propertyName,
String propertyValue)
     {
-      super(operatorName, operatorId);
+      this(operatorName, operatorId, propertyName, propertyValue, LogLevel.INFO);
+    }
+
+    public SetPhysicalOperatorPropertyEvent(String operatorName, int operatorId, String propertyName,
String propertyValue, LogLevel logLevel)
+    {
+      super(operatorName, operatorId, logLevel);
       this.propertyName = propertyName;
       this.propertyValue = propertyValue;
     }
@@ -318,6 +371,12 @@ public abstract class StramEvent
 
     public StartContainerEvent(String containerId, String containerNodeId)
     {
+      this(containerId, containerNodeId, LogLevel.INFO);
+    }
+
+    public StartContainerEvent(String containerId, String containerNodeId, LogLevel logLevel)
+    {
+      super(logLevel);
       this.containerId = containerId;
       this.containerNodeId = containerNodeId;
     }
@@ -357,6 +416,12 @@ public abstract class StramEvent
 
     public StopContainerEvent(String containerId, int exitStatus)
     {
+      this(containerId, exitStatus, LogLevel.INFO);
+    }
+
+    public StopContainerEvent(String containerId, int exitStatus, LogLevel logLevel)
+    {
+      super(logLevel);
       this.containerId = containerId;
       this.exitStatus = exitStatus;
     }
@@ -395,6 +460,12 @@ public abstract class StramEvent
 
     public ChangeLogicalPlanEvent(LogicalPlanRequest request)
     {
+      this(request, LogLevel.INFO);
+    }
+
+    public ChangeLogicalPlanEvent(LogicalPlanRequest request, LogLevel logLevel)
+    {
+      super(logLevel);
       this.request = request;
     }
 
@@ -423,7 +494,12 @@ public abstract class StramEvent
 
     public OperatorErrorEvent(String operatorName, int operatorId, String containerId, String
errorMessage)
     {
-      super(operatorName, operatorId);
+      this(operatorName, operatorId, containerId, errorMessage, LogLevel.ERROR);
+    }
+
+    public OperatorErrorEvent(String operatorName, int operatorId, String containerId, String
errorMessage, LogLevel logLevel)
+    {
+      super(operatorName, operatorId, logLevel);
       this.containerId = containerId;
       this.errorMessage = errorMessage;
     }
@@ -463,6 +539,12 @@ public abstract class StramEvent
 
     public ContainerErrorEvent(String containerId, String errorMessage)
     {
+      this(containerId, errorMessage, LogLevel.ERROR);
+    }
+
+    public ContainerErrorEvent(String containerId, String errorMessage, LogLevel logLevel)
+    {
+      super(logLevel);
       this.containerId = containerId;
       this.errorMessage = errorMessage;
     }


Mime
View raw message