Package org.apache.pig.penny

Examples of org.apache.pig.penny.Coordinator


  // Allow to customize location of penny.jar instead of always relying on cwd.
    private final static String pennyJarFilename = System.getProperty("PENNY_JAR", "penny.jar");
  // Ibis change : end
   
    public static Object launch(PigContext pigContext, LogicalPlan queryPlan, ClassWithArgs coordinatorClass) throws Exception {
        Coordinator coord = (Coordinator) coordinatorClass.theClass().newInstance();
        CoordinatorHarness coordHarness = new CoordinatorHarness(coord);
        coord.init(coordinatorClass.args());
        ToolsPigServer pigServer = new ToolsPigServer(pigContext);
       
        if (!(new File(pennyJarFilename)).exists()) {
            throw new RuntimeException("Cannot find " + pennyJarFilename + " in working directory.");
        }
View Full Code Here

TOP

Related Classes of org.apache.pig.penny.Coordinator

Copyright © 2018 www.massapicom. 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.