Examples of OozieProcessWorkflowBuilder

org.apache.falcon.workflow.OozieProcessWorkflowBuilder
Oozie workflow builder for falcon entities.

Examples of org.apache.falcon.workflow.OozieProcessWorkflowBuilder

        resource = this.getClass().getResource("/config/process/hive-process.xml");
        Process process = (Process) EntityType.PROCESS.getUnmarshaller().unmarshal(resource);
        ConfigurationStore.get().publish(EntityType.PROCESS, process);


        prepare(process);
        OozieProcessWorkflowBuilder builder = new OozieProcessWorkflowBuilder(process);
        Path bundlePath = new Path("/falcon/staging/workflows", process.getName());
        builder.map(cluster, bundlePath);
        assertTrue(fs.exists(bundlePath));


        BUNDLEAPP bundle = getBundle(bundlePath);
        assertEquals(EntityUtil.getWorkflowName(process).toString(), bundle.getName());
        assertEquals(1, bundle.getCoordinator().size());

View Full Code Here

Examples of org.apache.falcon.workflow.OozieProcessWorkflowBuilder


        resource = this.getClass().getResource("/config/process/pig-process-table.xml");
        Process process = (Process) EntityType.PROCESS.getUnmarshaller().unmarshal(resource);
        ConfigurationStore.get().publish(EntityType.PROCESS, process);


        OozieProcessWorkflowBuilder builder = new OozieProcessWorkflowBuilder(process);
        Path bundlePath = new Path("/falcon/staging/workflows", process.getName());
        builder.map(cluster, bundlePath);
        assertTrue(fs.exists(bundlePath));


        BUNDLEAPP bundle = getBundle(bundlePath);
        assertEquals(EntityUtil.getWorkflowName(process).toString(), bundle.getName());
        assertEquals(1, bundle.getCoordinator().size());

View Full Code Here

Examples of org.apache.falcon.workflow.OozieProcessWorkflowBuilder

        }
    }


    private WORKFLOWAPP initializeProcessMapper(Process process, String throttle, String timeout)
        throws Exception {
        OozieProcessWorkflowBuilder builder = new OozieProcessWorkflowBuilder(process);
        Path bundlePath = new Path("/falcon/staging/workflows", process.getName());
        builder.map(cluster, bundlePath);
        assertTrue(fs.exists(bundlePath));


        BUNDLEAPP bundle = getBundle(bundlePath);
        assertEquals(EntityUtil.getWorkflowName(process).toString(), bundle.getName());
        assertEquals(1, bundle.getCoordinator().size());

View Full Code Here

Examples of org.apache.falcon.workflow.OozieProcessWorkflowBuilder


        URL resource = this.getClass().getResource("/config/process/dumb-process.xml");
        Process processEntity = (Process) EntityType.PROCESS.getUnmarshaller().unmarshal(resource);
        ConfigurationStore.get().publish(EntityType.PROCESS, processEntity);


        OozieProcessWorkflowBuilder builder = new OozieProcessWorkflowBuilder(processEntity);
        Path bundlePath = new Path("/falcon/staging/workflows", processEntity.getName());
        builder.map(cluster, bundlePath);
        assertTrue(fs.exists(bundlePath));


        BUNDLEAPP bundle = getBundle(bundlePath);
        assertEquals(EntityUtil.getWorkflowName(processEntity).toString(), bundle.getName());
        assertEquals(1, bundle.getCoordinator().size());

View Full Code Here

TOP

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.