org.apache.pig.scripting.js

Class JSPig

java.lang.Object

org.apache.pig.scripting.js.JSPig

public class JSPig
extends java.lang.Object

Pig entry point from javascript

Author:

Julien Le Dem

Method Summary

Modifier and Type	Method and Description
BoundScript	bind() See: Pig.bind()
BoundScript	bind(java.lang.Object o) javascript helper for binding parameters.
static JSPig	compile(java.lang.String pl) Define a Pig pipeline.
static JSPig	compile(java.lang.String name, java.lang.String pl) Define a named portion of a Pig pipeline.
static JSPig	compileFromFile(java.lang.String filename) Define a Pig pipeline based on Pig Latin in a separate file.
static JSPig	compileFromFile(java.lang.String name, java.lang.String filename) Define a named Pig pipeline based on Pig Latin in a separate file.
static void	define(java.lang.String alias, java.lang.String definition) See Pig
static int	fs(java.lang.String cmd) See Pig
static void	registerJar(java.lang.String jarfile) See Pig
static void	registerUDF(java.lang.String udffile, java.lang.String namespace) See Pig
static void	set(java.lang.String var, java.lang.String value) See Pig

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

fs

public static int fs(java.lang.String cmd)
              throws java.io.IOException

See Pig

Parameters:

cmd - Filesystem command to run along with its arguments as one string.

Throws:

java.io.IOException

registerJar

public static void registerJar(java.lang.String jarfile)
                        throws java.io.IOException

See Pig

Parameters:

jarfile - Path of jar to include.

Throws:

java.io.IOException - if the indicated jarfile cannot be found.

registerUDF

public static void registerUDF(java.lang.String udffile,
                               java.lang.String namespace)
                        throws java.io.IOException

See Pig

Parameters:

udffile - Path of the script UDF file

namespace - namespace of the UDFs

Throws:

java.io.IOException

define

public static void define(java.lang.String alias,
                          java.lang.String definition)
                   throws java.io.IOException

See Pig

Parameters:

alias - name of the defined alias

definition - string this alias is defined as

Throws:

java.io.IOException

set

public static void set(java.lang.String var,
                       java.lang.String value)
                throws java.io.IOException

See Pig

Parameters:

var - variable to set

value - to set it to

Throws:

java.io.IOException

compile

public static JSPig compile(java.lang.String pl)
                     throws java.io.IOException

Define a Pig pipeline.

Parameters:

pl - Pig Latin definition of the pipeline.

Returns:

Pig object representing this pipeline.

Throws:

java.io.IOException - if the Pig Latin does not compile.

compile

public static JSPig compile(java.lang.String name,
                            java.lang.String pl)
                     throws java.io.IOException

Define a named portion of a Pig pipeline. This allows it to be imported into another pipeline.

Parameters:

name - Name that will be used to define this pipeline. The namespace is global.

pl - Pig Latin definition of the pipeline.

Returns:

Pig object representing this pipeline.

Throws:

java.io.IOException - if the Pig Latin does not compile.

compileFromFile

public static JSPig compileFromFile(java.lang.String filename)
                             throws java.io.IOException

Define a Pig pipeline based on Pig Latin in a separate file.

Parameters:

filename - File to read Pig Latin from. This must be a purely Pig Latin file. It cannot contain host language constructs in it.

Returns:

Pig object representing this pipeline.

Throws:

java.io.IOException - if the Pig Latin does not compile or the file cannot be found.

compileFromFile

public static JSPig compileFromFile(java.lang.String name,
                                    java.lang.String filename)
                             throws java.io.IOException

Define a named Pig pipeline based on Pig Latin in a separate file. This allows it to be imported into another pipeline.

Parameters:

name - Name that will be used to define this pipeline. The namespace is global.

filename - File to read Pig Latin from. This must be a purely Pig Latin file. It cannot contain host language constructs in it.

Returns:

Pig object representing this pipeline.

Throws:

java.io.IOException - if the Pig Latin does not compile or the file cannot be found.

bind

public BoundScript bind(java.lang.Object o)
                 throws java.io.IOException

javascript helper for binding parameters. See: Pig.bind(Map)

Parameters:

o - a javascript object to be converted into a Map

Returns:

the bound script

Throws:

java.io.IOException - if Pig.bind(Map) throws an IOException

bind

public BoundScript bind()
                 throws java.io.IOException

See: Pig.bind()

Throws:

java.io.IOException - if host language variables are not found to resolve all Pig Latin parameters or if they contain unsupported types.