Repository: atlas Updated Branches: refs/heads/master dee8a2da4 -> 6e02ec5b3
http://git-wip-us.apache.org/repos/asf/atlas/blob/6e02ec5b/addons/sqoop-bridge/src/main/java/org/apache/atlas/sqoop/hook/SqoopHook.java ---------------------------------------------------------------------- diff --git a/addons/sqoop-bridge/src/main/java/org/apache/atlas/sqoop/hook/SqoopHook.java b/addons/sqoop-bridge/src/main/java/org/apache/atlas/sqoop/hook/SqoopHook.java index 06a0e9c..794e3c3 100644 --- a/addons/sqoop-bridge/src/main/java/org/apache/atlas/sqoop/hook/SqoopHook.java +++ b/addons/sqoop-bridge/src/main/java/org/apache/atlas/sqoop/hook/SqoopHook.java @@ -68,6 +68,7 @@ public class SqoopHook extends SqoopJobDataPublisher { public static final String CMD_LINE_OPTS = "commandlineOpts"; public static final String INPUTS = "inputs"; public static final String OUTPUTS = "outputs"; + public static final String ATTRIBUTE_DB = "db"; static { org.apache.hadoop.conf.Configuration.addDefaultResource("sqoop-site.xml"); @@ -114,7 +115,7 @@ public class SqoopHook extends SqoopJobDataPublisher { entHiveTable.setAttribute(AtlasClient.NAME, tableName.toLowerCase()); entHiveTable.setAttribute(AtlasClient.REFERENCEABLE_ATTRIBUTE_NAME, qualifiedName); - entHiveTable.setAttribute(HiveMetaStoreBridge.DB, AtlasTypeUtil.getAtlasObjectId(entHiveDb)); + entHiveTable.setAttribute(ATTRIBUTE_DB, AtlasTypeUtil.getAtlasObjectId(entHiveDb)); return entHiveTable; } http://git-wip-us.apache.org/repos/asf/atlas/blob/6e02ec5b/addons/storm-bridge/src/main/java/org/apache/atlas/storm/hook/StormAtlasHook.java ---------------------------------------------------------------------- diff --git a/addons/storm-bridge/src/main/java/org/apache/atlas/storm/hook/StormAtlasHook.java b/addons/storm-bridge/src/main/java/org/apache/atlas/storm/hook/StormAtlasHook.java index b0a4dab..110ec52 100644 --- a/addons/storm-bridge/src/main/java/org/apache/atlas/storm/hook/StormAtlasHook.java +++ b/addons/storm-bridge/src/main/java/org/apache/atlas/storm/hook/StormAtlasHook.java @@ -64,6 +64,7 @@ public class StormAtlasHook extends AtlasHook implements ISubmitterHook { public static final String ANONYMOUS_OWNER = "anonymous"; public static final String HBASE_NAMESPACE_DEFAULT = "default"; + public static final String ATTRIBUTE_DB = "db"; private final HdfsNameServiceResolver hdfsNameServiceResolver = HdfsNameServiceResolver.getInstance(); @@ -271,7 +272,7 @@ public class StormAtlasHook extends AtlasHook implements ISubmitterHook { final String tableQualifiedName = HiveMetaStoreBridge.getTableQualifiedName(clusterName, databaseName, hiveTableName); dataSetReferenceable.set(AtlasClient.NAME, hiveTableName); - dataSetReferenceable.set(HiveMetaStoreBridge.DB, dbReferenceable); + dataSetReferenceable.set(ATTRIBUTE_DB, dbReferenceable); dataSetReferenceable.set(AtlasClient.REFERENCEABLE_ATTRIBUTE_NAME, tableQualifiedName); break;
