Commit 7b7f4e0b by Suma Shivaprasad

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

parent 1a405f9c
...@@ -28,13 +28,11 @@ import java.util.Date; ...@@ -28,13 +28,11 @@ import java.util.Date;
public class FalconEvent { public class FalconEvent {
protected String user; protected String user;
protected OPERATION operation; protected OPERATION operation;
protected long timestamp;
protected Entity entity; 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.user = doAsUser;
this.operation = falconOperation; this.operation = falconOperation;
this.timestamp = timestamp;
this.entity = entity; this.entity = entity;
} }
...@@ -55,10 +53,6 @@ public class FalconEvent { ...@@ -55,10 +53,6 @@ public class FalconEvent {
return operation; return operation;
} }
public Date getTimestamp() {
return new Date(timestamp);
}
public Entity getEntity() { public Entity getEntity() {
return entity; return entity;
} }
......
...@@ -30,6 +30,7 @@ import org.apache.falcon.service.FalconService; ...@@ -30,6 +30,7 @@ import org.apache.falcon.service.FalconService;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
/** /**
* Atlas service to publish Falcon events * Atlas service to publish Falcon events
*/ */
...@@ -124,7 +125,7 @@ public class AtlasService implements FalconService, ConfigurationChangeListener ...@@ -124,7 +125,7 @@ public class AtlasService implements FalconService, ConfigurationChangeListener
try { try {
FalconEvent event = FalconEvent event =
new FalconEvent(EventUtil.getUser(), operation, System.currentTimeMillis(), entity); new FalconEvent(EventUtil.getUser(), operation, entity);
FalconEventPublisher.Data data = new FalconEventPublisher.Data(event); FalconEventPublisher.Data data = new FalconEventPublisher.Data(event);
publisher.publish(data); publisher.publish(data);
} catch (Exception ex) { } catch (Exception ex) {
......
...@@ -3,6 +3,7 @@ Apache Atlas Release Notes ...@@ -3,6 +3,7 @@ Apache Atlas Release Notes
--trunk - unreleased --trunk - unreleased
INCOMPATIBLE CHANGES: 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-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-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) ATLAS-1060 Add composite indexes for exact match performance improvements for all attributes (sumasai via shwethags)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment