org.apache.pig.impl.streaming

Class FileInputHandler

java.lang.Object

org.apache.pig.impl.streaming.InputHandler

org.apache.pig.impl.streaming.FileInputHandler

public class FileInputHandler
extends InputHandler

FileInputHandler handles the input for the Pig-Streaming executable in an asynchronous manner by feeding it input via an external file specified by the user.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.pig.impl.streaming.InputHandler

InputHandler.InputType

Field Summary

Fields inherited from class org.apache.pig.impl.streaming.InputHandler

alreadyClosed, serializer

Constructor Summary

Constructors

Constructor and Description
FileInputHandler(StreamingCommand.HandleSpec handleSpec)

Method Summary

Methods

Modifier and Type	Method and Description
void	bindTo(java.io.OutputStream os) Bind the InputHandler to the OutputStream from which it reads input and sends it to the managed process.
void	close(java.lang.Process process) Close the InputHandler since there is no more input to be sent to the managed process.
InputHandler.InputType	getInputType() Get the handled InputType

Methods inherited from class org.apache.pig.impl.streaming.InputHandler

putNext

Methods inherited from class java.lang.Object

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

Constructor Detail

FileInputHandler

public FileInputHandler(StreamingCommand.HandleSpec handleSpec)
                 throws ExecException

Throws:

ExecException

Method Detail

getInputType

public InputHandler.InputType getInputType()

Description copied from class: InputHandler

Get the handled InputType

Specified by:

getInputType in class InputHandler

Returns:

the handled InputType

bindTo

public void bindTo(java.io.OutputStream os)
            throws java.io.IOException

Description copied from class: InputHandler

Bind the InputHandler to the OutputStream from which it reads input and sends it to the managed process.

Overrides:

bindTo in class InputHandler

Parameters:

os - OutputStream from which to read input data for the managed process

Throws:

java.io.IOException

close

public void close(java.lang.Process process)
           throws java.io.IOException

Description copied from class: InputHandler

Close the InputHandler since there is no more input to be sent to the managed process.

Overrides:

close in class InputHandler

Parameters:

process - the managed process - this could be null in some cases like when input is through files. In that case, the process would not have been exec'ed yet - if this method if overridden it is the responsibility of the implementer to check that the process is usable. The managed process object is supplied by the ExecutableManager to this call so that this method can check if the process is alive if it needs to know.

Throws:

java.io.IOException