Package org.apache.pig.penny

Examples of org.apache.pig.penny.ParsedPigScript.trace()

43
44
45
46
47
48
49
50
51
52
            // (can't differentiate which step in pipeline is causing delay -- can only tell if a tuple coming into the pipeline is taking longer to go through the pipeline than other tuples)
            if (parsedPigScript.isTaskEntryPoint(alias)) {
                monitorClasses.put(alias, new ClassWithArgs(LAMonitorAgent.class));
            }
        }
        parsedPigScript.trace(LACoordinator.class, monitorClasses);
       
    }
           
}
View Full Code Here
56
57
58
59
60
61
62
63
64
65
                monitorClasses.put(alias, new ClassWithArgs(BTMatchTaintMonitorAgent.class, traceTuple));
            } else {
                monitorClasses.put(alias, new ClassWithArgs(BTPropagateTaintMonitorAgent.class));
            }
        }
        Collection<Tuple> traceResults = (Collection<Tuple>) parsedPigScript.trace(BTCoordinator.class, monitorClasses);
        System.out.println("*** TRACE RESULTS:" + traceResults);
    }
           
}
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.