This is an automated email from the ASF dual-hosted git repository.
rmani pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/atlas.git
The following commit(s) were added to refs/heads/master by this push:
new 2d4edf8 ATLAS-3581:HBase hook converts qualifiedName to lowercase for
namespace, table, column-family and column
2d4edf8 is described below
commit 2d4edf87728b45b6498e2d7772d87829d7079ef8
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){