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)
  • .setName(name)
  • .getName() ⇒ String
  • .setProperty(property)
  • .genwf(arg, wfconfig, cb)
  • .gencoord(coordconfig, cb)
  • .getDefaultProperty() ⇒ Object
  • .getDefaultWorkflow() ⇒ Object
  • .submit(type, name, jobfile, className, arg, prop, wfconfig, start, cb)
  • .submitcoord(name, prop, coordconfig, cb)
  • .start(jobid)
  • .kill(jobid)
  • .suspend(jobid)
  • .resume(jobid)
  • .rerun(jobid)
  • .get(jobid)

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. |

oozie.start(jobid)

Start Job

Kind: instance method of Oozie

| Param | Type | Description | | --- | --- | --- | | jobid | String | Job ID to be Start. |

oozie.kill(jobid)

Kill Job

Kind: instance method of Oozie

| Param | Type | Description | | --- | --- | --- | | jobid | String | Job ID to be Killed. |

oozie.suspend(jobid)

Suspend Job

Kind: instance method of Oozie

| Param | Type | Description | | --- | --- | --- | | jobid | String | Job ID to be Suspended. |

oozie.resume(jobid)

Resume Job

Kind: instance method of Oozie

| Param | Type | Description | | --- | --- | --- | | jobid | String | Job ID to be Resumed. |

oozie.rerun(jobid)

Re running job, identified by jobid.

Kind: instance method of Oozie

| Param | Type | Description | | --- | --- | --- | | jobid | String | Job id that needed to run. |

oozie.get(jobid)

Get job info identified by jobId.

Kind: instance method of Oozie

| Param | Type | Description | | --- | --- | --- | | jobid | String | Job Id that needed to get. |

defaultResponse(e, r, b)

Response default for start, rerun, get.

Kind: global function

| Param | Type | Description | | --- | --- | --- | | e | Object | Error Object from request. | | r | Object | Response Object from request. | | b | Mixed | Response body from request. |