Oracle® In-Database Container for Hadoop Java API Reference
Release 1.0.1

E54638-01

oracle.sql.hadoop
Class PipelinedJob

java.lang.Object
  extended by oracle.sql.hadoop.PipelinedJob

public class PipelinedJob
extends java.lang.Object

It executes several jobs in pipeline

Example:

 Job job1 = new Job(Configuration conf1);
 job1.init();
 Job job2 = new Job(Configuration conf2);
 job2.init();
 Job job3 = new Job(Configuration conf3);
 job3.init();
 PipelinedJob.run("InTable", "OutTable", job1, job2, job3);
 
 Jobs will run in following sequence:
 InTable->job1->job2->job3->OutTable
 


Constructor Summary
PipelinedJob()
           
 
Method Summary
static void run(java.lang.String inTable, java.lang.String outTable, Job... jobs)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

PipelinedJob

public PipelinedJob()
Method Detail

run

public static void run(java.lang.String inTable,
                       java.lang.String outTable,
                       Job... jobs)
                throws java.lang.Exception
Parameters:
inTable - Input table name for first job in pipeline
outTable - Output table name for last job in pipeline
jobs - Jobs which needs to be pipelined in the sequence
Throws:
java.lang.Exception

Oracle® In-Database Container for Hadoop Java API Reference
Release 1.0.1

E54638-01

Copyright © 2014, Oracle and/or its affiliates. All rights reserved.