atlas-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From suma...@apache.org
Subject incubator-atlas git commit: ATLAS-674 Falcon Hook should use timestamps instead of long(ayubkhan via sumasai)
Date Thu, 18 Aug 2016 15:36:08 GMT
Repository: incubator-atlas
Updated Branches:
  refs/heads/master 1a405f9c1 -> 7b7f4e0b6


ATLAS-674 Falcon Hook should use timestamps instead of long(ayubkhan via sumasai)


Project: http://git-wip-us.apache.org/repos/asf/incubator-atlas/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-atlas/commit/7b7f4e0b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-atlas/tree/7b7f4e0b
Diff: http://git-wip-us.apache.org/repos/asf/incubator-atlas/diff/7b7f4e0b

Branch: refs/heads/master
Commit: 7b7f4e0b68637fec82af4443aedcecc63cf10747
Parents: 1a405f9
Author: Suma Shivaprasad <sumasai.shivaprasad@gmail.com>
Authored: Thu Aug 18 08:35:43 2016 -0700
Committer: Suma Shivaprasad <sumasai.shivaprasad@gmail.com>
Committed: Thu Aug 18 08:35:43 2016 -0700

----------------------------------------------------------------------
 .../main/java/org/apache/atlas/falcon/event/FalconEvent.java | 8 +-------
 .../java/org/apache/atlas/falcon/service/AtlasService.java   | 3 ++-
 release-log.txt                                              | 1 +
 3 files changed, 4 insertions(+), 8 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-atlas/blob/7b7f4e0b/addons/falcon-bridge/src/main/java/org/apache/atlas/falcon/event/FalconEvent.java
----------------------------------------------------------------------
diff --git a/addons/falcon-bridge/src/main/java/org/apache/atlas/falcon/event/FalconEvent.java
b/addons/falcon-bridge/src/main/java/org/apache/atlas/falcon/event/FalconEvent.java
index e6203ed..0b918ba 100644
--- a/addons/falcon-bridge/src/main/java/org/apache/atlas/falcon/event/FalconEvent.java
+++ b/addons/falcon-bridge/src/main/java/org/apache/atlas/falcon/event/FalconEvent.java
@@ -28,13 +28,11 @@ import java.util.Date;
 public class FalconEvent {
     protected String user;
     protected OPERATION operation;
-    protected long timestamp;
     protected Entity entity;
 
-    public FalconEvent(String doAsUser, OPERATION falconOperation, long timestamp, Entity
entity) {
+    public FalconEvent(String doAsUser, OPERATION falconOperation, Entity entity) {
         this.user = doAsUser;
         this.operation = falconOperation;
-        this.timestamp = timestamp;
         this.entity = entity;
     }
 
@@ -55,10 +53,6 @@ public class FalconEvent {
         return operation;
     }
 
-    public Date getTimestamp() {
-        return new Date(timestamp);
-    }
-
     public Entity getEntity() {
         return entity;
     }

http://git-wip-us.apache.org/repos/asf/incubator-atlas/blob/7b7f4e0b/addons/falcon-bridge/src/main/java/org/apache/atlas/falcon/service/AtlasService.java
----------------------------------------------------------------------
diff --git a/addons/falcon-bridge/src/main/java/org/apache/atlas/falcon/service/AtlasService.java
b/addons/falcon-bridge/src/main/java/org/apache/atlas/falcon/service/AtlasService.java
index b2afb03..7482ba7 100644
--- a/addons/falcon-bridge/src/main/java/org/apache/atlas/falcon/service/AtlasService.java
+++ b/addons/falcon-bridge/src/main/java/org/apache/atlas/falcon/service/AtlasService.java
@@ -30,6 +30,7 @@ import org.apache.falcon.service.FalconService;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+
 /**
  * Atlas service to publish Falcon events
  */
@@ -124,7 +125,7 @@ public class AtlasService implements FalconService, ConfigurationChangeListener
 
         try {
             FalconEvent event =
-                    new FalconEvent(EventUtil.getUser(), operation, System.currentTimeMillis(),
entity);
+                    new FalconEvent(EventUtil.getUser(), operation, entity);
             FalconEventPublisher.Data data = new FalconEventPublisher.Data(event);
             publisher.publish(data);
         } catch (Exception ex) {

http://git-wip-us.apache.org/repos/asf/incubator-atlas/blob/7b7f4e0b/release-log.txt
----------------------------------------------------------------------
diff --git a/release-log.txt b/release-log.txt
index e79caa6..31582ed 100644
--- a/release-log.txt
+++ b/release-log.txt
@@ -3,6 +3,7 @@ Apache Atlas Release Notes
 
 --trunk - unreleased
 INCOMPATIBLE CHANGES:
+ATLAS-674 Falcon Hook should use timestamps instead of long(ayubkhan via sumasai)
 ATLAS-675 Storm Hook should use timetsamps as Date type instead of Long (ayubkhan via sumasai)
 ATLAS-1122 Change trait edge labels to have trait name alone (sumasai)
 ATLAS-1060 Add composite indexes for exact match performance improvements for all attributes
(sumasai via shwethags)


Mime
View raw message