ramitg254 commented on code in PR #6413:
URL: https://github.com/apache/hive/pull/6413#discussion_r3490983021
##########
ql/src/java/org/apache/hadoop/hive/ql/session/LineageState.java:
##########
@@ -90,6 +91,19 @@ public synchronized void updateDirToOpMap(Path newPath, Path
oldPath) {
}
}
+ /**
+ * Set the lineage information for the associated directory.
+ *
+ * @param dir The directory containing the query results.
+ * @param dc The associated data container.
+ * @param table table metadata used to resolve written columns for lineage
mapping.
+ */
+ public synchronized void setLineage(Path dir, DataContainer dc, Table table)
{
+ List<FieldSchema> cols = table.hasNonNativePartitionSupport() ?
+ table.getAllCols() : table.getCols();
Review Comment:
It was the earlier behaviour in which getCols() ( which is data cols) is
called for native tables so kept the same instead of changing it
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
