Oozie NPM | npm.io

Development status

Still in testing, not ready for production

Usage

  var Oozie = require('./index.js');

  var wfconfig = {
    // name: '${wfName}',
    // startTo: 'terserah-biasanya-ada-node',  // ini node action, bisa dikosongkan.
    endName: 'end',
    killName: 'fail',
    killMessage: 'Workflow failed, error message[${wf:errorMessage(wf:lastErrorNode())}]',  // pesan error ketika gagal.
    action: {
      // name: 'terserah-biasanya-ada-node',  // action name bisa dikosongkan.
      java: {                             // ini kalau action ini menjalankan aplikasi java, selain java belum
        'job-tracker': '${jobTracker}',   // property yang ada di dalam java harus lengkap, minimal seperti ini.
        'name-node': '${nameNode}',
        configuration: {
          property: [{
            name: 'mapred.job.queue.name',
            value: '${queueName}'
          }]
        },
        'main-class': '${classname}',
        'java-opts': [],
        arg: [
          '/user/apps/asep/testin.txt',
          '/user/apps/asep/output'
        ],
        // file: 'file.jar'  // lokasi jar didefinisikan saat new oozie.
      }
    }
  };

  var config = {
    node: {
      hdfs: {
        protocol: 'http',
        hostname: '192.168.1.225',
        port: 50070,
        user: 'apps',
        overwrite: true
      },
      jobTracker: {
        protocol: 'http',
        hostname: '192.168.1.225',
        port: 8032
      },
      nameNode: {
        hostname: '192.168.1.225',
        port: 8020
      },
      oozie: {
        protocol: 'http',
        hostname: '192.168.1.225',
        port: 11000,
        user: 'apps'
      }
    },
    libpath: '/user/apps/lib/247',
    queueName: 'root.default',
    artefact: {
      jar: '/user/apps/oozie-artefact/jar/',
      workflow: '/user/apps/oozie-artefact/workflow/'
    }
  };

  var oozie = new Oozie(config);

  oozie.on('ready', function () {
    oozie.submit('java', null, 'casetwo.jar', 'dummy.casetwo', [], [{
      name: 'namajar',
      value: 'casetwo.jar'
    }], wfconfig, function () {}, false);

    oozie.on('jobSubmitted', function () {
      console.log(subject01.jobid);
    });
  });

Functions

Oozie(config)

Oozie class constructor

Kind: global function

Param	Type	Description
config	Object	Config object.

Oozie(config)

oozie.setName(name)

Set name of running job.

Kind: instance method of Oozie

Param	Type	Description
name	String	Name of job

oozie.getName() ⇒ String

get name of job.

Kind: instance method of Oozie
Returns: String - job name

oozie.setProperty(property)

Set private property

Kind: instance method of Oozie

Param	Type	Description
property	Object	Property to be set.

oozie.genwf(arg, wfconfig, cb)

Generate oozie workflow-app

Kind: instance method of Oozie

Param	Type	Description
arg	Array	Job workflow arguments
wfconfig	Object	Full workflow config
cb	function	Callback function

oozie.gencoord(coordconfig, cb)

Generate oozie coordinator-app

Kind: instance method of Oozie

Param	Type	Description
coordconfig	Object	Full coordinator config
cb	function	Callback function

oozie.getDefaultProperty() ⇒ Object

Get default property

Kind: instance method of Oozie
Returns: Object - Default property object.

oozie.getDefaultWorkflow() ⇒ Object

Get default workflow

Kind: instance method of Oozie
Returns: Object - Default workflow object.

oozie.submit(type, name, jobfile, className, arg, prop, wfconfig, start, cb)

submit job to oozie

Kind: instance method of Oozie

Param	Type	Description
type	String	Type of submitted job
name	String	Name of job, set to random if null
jobfile	String	Name of file, only name without path, path have been set on constructor.
className	String	Class path of job.
arg	Array	Array of job arguments, set empty array to set no argument.
prop	Array	Array of object properties, this array will be concatenated to default properties, set empty array if using default properties only.
wfconfig	Object	Object of custom workflow config
start	Boolean	Start job immediately after submitted
cb	function	Callback function.

oozie.submitcoord(name, prop, coordconfig, cb)

submit coordinator to oozie

Kind: instance method of Oozie

Param	Type	Description
name	String	Name of job, set to random if null
prop	Array	Array of object properties, this array will be concatenated to default properties, set empty array if using default properties only.
coordconfig	Object	Object of custom workflow config
cb	function	Callback function.