[systemds] branch master updated: [MINOR] Lineage trace and cache transform frame operations

[arnabp20]

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

arnabp20 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/systemds.git


The following commit(s) were added to refs/heads/master by this push:
     new c05f8e2  [MINOR] Lineage trace and cache transform frame operations
c05f8e2 is described below

commit c05f8e2538ec2a05ccd99658f02a4beeb2823604
Author: arnabp <arnab.ph...@tugraz.at>
AuthorDate: Sun Oct 25 10:55:49 2020 +0100

    [MINOR] Lineage trace and cache transform frame operations
---
 .../runtime/instructions/cp/ParameterizedBuiltinCPInstruction.java     | 3 ++-
 src/main/java/org/apache/sysds/runtime/lineage/LineageCacheConfig.java | 3 ++-
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/src/main/java/org/apache/sysds/runtime/instructions/cp/ParameterizedBuiltinCPInstruction.java
 
b/src/main/java/org/apache/sysds/runtime/instructions/cp/ParameterizedBuiltinCPInstruction.java
index 5c71780..c082f3c 100644
--- 
a/src/main/java/org/apache/sysds/runtime/instructions/cp/ParameterizedBuiltinCPInstruction.java
+++ 
b/src/main/java/org/apache/sysds/runtime/instructions/cp/ParameterizedBuiltinCPInstruction.java
@@ -444,7 +444,8 @@ public class ParameterizedBuiltinCPInstruction extends 
ComputationCPInstruction
                        return Pair.of(output.getName(), new 
LineageItem(getOpcode(),
                                LineageItemUtils.getLineage(ec, target, max, 
dir, cast, ignore)));
                }
-               else if (opcode.equalsIgnoreCase("transformdecode")) {
+               else if (opcode.equalsIgnoreCase("transformdecode") ||
+                               opcode.equalsIgnoreCase("transformapply")) {
                        CPOperand target = getTargetOperand();
                        CPOperand meta = getLiteral("meta", ValueType.UNKNOWN, 
DataType.FRAME);
                        CPOperand spec = getStringLiteral("spec");
diff --git 
a/src/main/java/org/apache/sysds/runtime/lineage/LineageCacheConfig.java 
b/src/main/java/org/apache/sysds/runtime/lineage/LineageCacheConfig.java
index 26742ac..c5d8298 100644
--- a/src/main/java/org/apache/sysds/runtime/lineage/LineageCacheConfig.java
+++ b/src/main/java/org/apache/sysds/runtime/lineage/LineageCacheConfig.java
@@ -39,7 +39,8 @@ public class LineageCacheConfig
                "rightIndex", "leftIndex", "groupedagg", "r'", "solve", "spoof",
                "uamean", "max", "min", "ifelse", "-", "sqrt", ">", "uak+", 
"<=",
                "^", "uamax", "uark+", "uacmean", "eigen", "ctableexpand", 
"replace",
-               "^2", "uack+", "tak+*", "uacsqk+", "uark+", "n+", "uarimax", 
"qsort", "qpick"
+               "^2", "uack+", "tak+*", "uacsqk+", "uark+", "n+", "uarimax", 
"qsort", 
+               "qpick", "transformencode", "transformapply"
                //TODO: Reuse everything. 
        };
        private static String[] REUSE_OPCODES  = new String[] {};