This is an automated email from the ASF dual-hosted git repository.
rmani pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/atlas.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new 0a4b1ec ATLAS-3581:HBase hook converts qualifiedName to lowercase for
namespace, table, column-family and column
0a4b1ec is described below
commit 0a4b1ec82287bfc398996e61231c8a37f660f208
Author: Ramesh Mani <[email protected]>
AuthorDate: Fri Jan 10 11:17:39 2020 -0800
ATLAS-3581:HBase hook converts qualifiedName to lowercase for namespace,
table, column-family and column
Signed-off-by: Ramesh Mani <[email protected]>
---
.../java/org/apache/atlas/hbase/bridge/HBaseAtlasHook.java | 6 +++---
.../main/java/org/apache/atlas/hbase/bridge/HBaseBridge.java | 10 +++++-----
2 files changed, 8 insertions(+), 8 deletions(-)
diff --git
a/addons/hbase-bridge/src/main/java/org/apache/atlas/hbase/bridge/HBaseAtlasHook.java
b/addons/hbase-bridge/src/main/java/org/apache/atlas/hbase/bridge/HBaseAtlasHook.java
index 26be9b3..0ab06f2 100644
---
a/addons/hbase-bridge/src/main/java/org/apache/atlas/hbase/bridge/HBaseAtlasHook.java
+++
b/addons/hbase-bridge/src/main/java/org/apache/atlas/hbase/bridge/HBaseAtlasHook.java
@@ -316,7 +316,7 @@ public class HBaseAtlasHook extends AtlasHook {
if (metadataNamespace == null || nameSpace == null || tableName ==
null || columnFamily == null) {
return null;
} else {
- return String.format(HBASE_COLUMN_FAMILY_QUALIFIED_NAME_FORMAT,
nameSpace.toLowerCase(), stripNameSpace(tableName.toLowerCase()),
columnFamily.toLowerCase(), metadataNamespace);
+ return String.format(HBASE_COLUMN_FAMILY_QUALIFIED_NAME_FORMAT,
nameSpace, stripNameSpace(tableName), columnFamily, metadataNamespace);
}
}
@@ -332,7 +332,7 @@ public class HBaseAtlasHook extends AtlasHook {
if (metadataNamespace == null || nameSpace == null || tableName ==
null) {
return null;
} else {
- return String.format(HBASE_TABLE_QUALIFIED_NAME_FORMAT,
nameSpace.toLowerCase(), stripNameSpace(tableName.toLowerCase()),
metadataNamespace);
+ return String.format(HBASE_TABLE_QUALIFIED_NAME_FORMAT, nameSpace,
stripNameSpace(tableName), metadataNamespace);
}
}
@@ -347,7 +347,7 @@ public class HBaseAtlasHook extends AtlasHook {
if (metadataNamespace == null || nameSpace == null) {
return null;
} else {
- return String.format(HBASE_NAMESPACE_QUALIFIED_NAME,
nameSpace.toLowerCase(), metadataNamespace);
+ return String.format(HBASE_NAMESPACE_QUALIFIED_NAME, nameSpace,
metadataNamespace);
}
}
diff --git
a/addons/hbase-bridge/src/main/java/org/apache/atlas/hbase/bridge/HBaseBridge.java
b/addons/hbase-bridge/src/main/java/org/apache/atlas/hbase/bridge/HBaseBridge.java
index fde70f1..f012664 100644
---
a/addons/hbase-bridge/src/main/java/org/apache/atlas/hbase/bridge/HBaseBridge.java
+++
b/addons/hbase-bridge/src/main/java/org/apache/atlas/hbase/bridge/HBaseBridge.java
@@ -652,8 +652,8 @@ public class HBaseBridge {
* @return Unique qualified name to identify the Table instance in Atlas.
*/
private static String getColumnFamilyQualifiedName(String
metadataNamespace, String nameSpace, String tableName, String columnFamily) {
- tableName = stripNameSpace(tableName.toLowerCase());
- return String.format(HBASE_COLUMN_FAMILY_QUALIFIED_NAME_FORMAT,
nameSpace.toLowerCase(), tableName, columnFamily.toLowerCase(),
metadataNamespace);
+ tableName = stripNameSpace(tableName);
+ return String.format(HBASE_COLUMN_FAMILY_QUALIFIED_NAME_FORMAT,
nameSpace, tableName, columnFamily, metadataNamespace);
}
/**
@@ -664,8 +664,8 @@ public class HBaseBridge {
* @return Unique qualified name to identify the Table instance in Atlas.
*/
private static String getTableQualifiedName(String metadataNamespace,
String nameSpace, String tableName) {
- tableName = stripNameSpace(tableName.toLowerCase());
- return String.format(HBASE_TABLE_QUALIFIED_NAME_FORMAT,
nameSpace.toLowerCase(), tableName, metadataNamespace);
+ tableName = stripNameSpace(tableName);
+ return String.format(HBASE_TABLE_QUALIFIED_NAME_FORMAT, nameSpace,
tableName, metadataNamespace);
}
/**
@@ -675,7 +675,7 @@ public class HBaseBridge {
* @return Unique qualified name to identify the HBase NameSpace instance
in Atlas.
*/
private static String getNameSpaceQualifiedName(String metadataNamespace,
String nameSpace) {
- return String.format(HBASE_NAMESPACE_QUALIFIED_NAME,
nameSpace.toLowerCase(), metadataNamespace);
+ return String.format(HBASE_NAMESPACE_QUALIFIED_NAME, nameSpace,
metadataNamespace);
}
private static String stripNameSpace(String tableName){