[atlas] branch master updated: ATLAS-3690: updated Storm hook to fix incorrect qualifiedName format for HBase table entities (jackylau via madhan)

[ma...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

madhan 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 ef20f8f  ATLAS-3690: updated Storm hook to fix incorrect qualifiedName format for HBase table entities (jackylau via madhan)
ef20f8f is described below

commit ef20f8ff337519166ae837d8a884ef5f875ea84b
Author: Madhan Neethiraj <ma...@apache.org>
AuthorDate: Sat Mar 28 12:08:04 2020 -0700

    ATLAS-3690: updated Storm hook to fix incorrect qualifiedName format for HBase table entities (jackylau via madhan)
    
    Signed-off-by: Madhan Neethiraj <ma...@apache.org>
---
 .../src/main/java/org/apache/atlas/storm/hook/StormAtlasHook.java      | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

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 cdfdefc..779c5cb 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
@@ -70,6 +70,7 @@ public class StormAtlasHook extends AtlasHook implements ISubmitterHook {
     public static final String RELATIONSHIP_STORM_TOPOLOGY_NODES = "storm_topology_nodes";
     public static final String RELATIONSHIP_DATASET_PROCESS_INPUTS = "dataset_process_inputs";
     public static final String RELATIONSHIP_PROCESS_DATASET_OUTPUTS = "process_dataset_outputs";
+    public static final String HBASE_TABLE_QUALIFIED_NAME_FORMAT    = "%s:%s@%s";
 
     /**
      * This is the client-side hook that storm fires when a topology is added.
@@ -389,7 +390,7 @@ public class StormAtlasHook extends AtlasHook implements ISubmitterHook {
     }
 
     public static String getHbaseTableQualifiedName(String metadataNamespace, String nameSpace, String tableName) {
-        return String.format("%s.%s@%s", nameSpace.toLowerCase(), tableName.toLowerCase(), metadataNamespace);
+        return String.format(HBASE_TABLE_QUALIFIED_NAME_FORMAT, nameSpace.toLowerCase(), tableName.toLowerCase(), metadataNamespace);
     }
 
     public static String getHdfsPathQualifiedName(String metadataNamespace, String hdfsPath) {