org.apache.hive.hcatalog.templeton

Class ExecServiceImpl

java.lang.Object

org.apache.hive.hcatalog.templeton.ExecServiceImpl

All Implemented Interfaces:

ExecService

public class ExecServiceImpl
extends java.lang.Object
implements ExecService

Execute a local program. This is a singleton service that will execute programs as non-privileged users on the local box. See ExecService.run and ExecService.runUnlimited for details.

Method Summary

Modifier and Type	Method and Description
java.util.Map<java.lang.String,java.lang.String>	execEnv(java.util.Map<java.lang.String,java.lang.String> env) Build the environment used for all exec calls.
static ExecServiceImpl	getInstance() Retrieve the singleton.
ExecBean	run(java.lang.String program, java.util.List<java.lang.String> args, java.util.Map<java.lang.String,java.lang.String> env) Run the program synchronously as the given user.
ExecBean	runUnlimited(java.lang.String program, java.util.List<java.lang.String> args, java.util.Map<java.lang.String,java.lang.String> env) Run the program synchronously as the given user.
java.lang.String	validateProgram(java.lang.String path) Given a program name, lookup the fully qualified path.

Methods inherited from class java.lang.Object

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

Method Detail

getInstance

public static ExecServiceImpl getInstance()

Retrieve the singleton.

run

public ExecBean run(java.lang.String program,
                    java.util.List<java.lang.String> args,
                    java.util.Map<java.lang.String,java.lang.String> env)
             throws NotAuthorizedException,
                    BusyException,
                    ExecuteException,
                    java.io.IOException

Run the program synchronously as the given user. We rate limit the number of processes that can simultaneously created for this instance.

Specified by:

run in interface ExecService

Parameters:

program - The program to run

args - Arguments to pass to the program

env - Any extra environment variables to set

Returns:

The result of the run.

Throws:

NotAuthorizedException

BusyException

ExecuteException

java.io.IOException

runUnlimited

public ExecBean runUnlimited(java.lang.String program,
                             java.util.List<java.lang.String> args,
                             java.util.Map<java.lang.String,java.lang.String> env)
                      throws NotAuthorizedException,
                             ExecuteException,
                             java.io.IOException

Run the program synchronously as the given user. Warning: CommandLine will trim the argument strings.

Specified by:

runUnlimited in interface ExecService

Parameters:

program - The program to run.

args - Arguments to pass to the program

env - Any extra environment variables to set

Returns:

The result of the run.

Throws:

NotAuthorizedException

ExecuteException

java.io.IOException

execEnv

public java.util.Map<java.lang.String,java.lang.String> execEnv(java.util.Map<java.lang.String,java.lang.String> env)

Build the environment used for all exec calls.

Returns:

The environment variables.

validateProgram

public java.lang.String validateProgram(java.lang.String path)
                                 throws NotAuthorizedException,
                                        java.io.IOException

Given a program name, lookup the fully qualified path. Throws an exception if the program is missing or not authorized.

Parameters:

path - The path of the program.

Returns:

The path of the validated program.

Throws:

NotAuthorizedException

java.io.IOException