You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ranger.apache.org by ma...@apache.org on 2015/12/18 18:11:50 UTC
incubator-ranger git commit: RANGER-792: updates for Atlas API
changes in ATLAS-394
Repository: incubator-ranger
Updated Branches:
refs/heads/master 2d3bf53d9 -> 93b562951
RANGER-792: updates for Atlas API changes in ATLAS-394
Project: http://git-wip-us.apache.org/repos/asf/incubator-ranger/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ranger/commit/93b56295
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ranger/tree/93b56295
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ranger/diff/93b56295
Branch: refs/heads/master
Commit: 93b562951f5ec61c31edf9f7bc8b85a583ea8870
Parents: 2d3bf53
Author: Madhan Neethiraj <ma...@apache.org>
Authored: Fri Dec 18 08:57:09 2015 -0800
Committer: Madhan Neethiraj <ma...@apache.org>
Committed: Fri Dec 18 08:57:09 2015 -0800
----------------------------------------------------------------------
.../org/apache/ranger/tagsync/source/atlas/TagAtlasSource.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ranger/blob/93b56295/tagsync/src/main/java/org/apache/ranger/tagsync/source/atlas/TagAtlasSource.java
----------------------------------------------------------------------
diff --git a/tagsync/src/main/java/org/apache/ranger/tagsync/source/atlas/TagAtlasSource.java b/tagsync/src/main/java/org/apache/ranger/tagsync/source/atlas/TagAtlasSource.java
index fd64d12..42ba7c7 100644
--- a/tagsync/src/main/java/org/apache/ranger/tagsync/source/atlas/TagAtlasSource.java
+++ b/tagsync/src/main/java/org/apache/ranger/tagsync/source/atlas/TagAtlasSource.java
@@ -164,9 +164,9 @@ public class TagAtlasSource implements TagSource {
private class ConsumerRunnable implements Runnable {
- private final Iterator<EntityNotification> consumerIterator;
+ private final NotificationConsumer<EntityNotification> consumerIterator;
- private ConsumerRunnable(Iterator<EntityNotification> consumerIterator) {
+ private ConsumerRunnable(NotificationConsumer<EntityNotification> consumerIterator) {
this.consumerIterator = consumerIterator;
}