Commit ef20f8ff by Madhan Neethiraj

ATLAS-3690: updated Storm hook to fix incorrect qualifiedName format for HBase…

ATLAS-3690: updated Storm hook to fix incorrect qualifiedName format for HBase table entities (jackylau via madhan) Signed-off-by: 's avatarMadhan Neethiraj <madhan@apache.org>
parent 22ca98b0
......@@ -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) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment