org.apache.pig.impl.streaming

Class DefaultInputHandler

java.lang.Object

org.apache.pig.impl.streaming.InputHandler

org.apache.pig.impl.streaming.DefaultInputHandler

Direct Known Subclasses:

StreamingUDFInputHandler

public class DefaultInputHandler
extends InputHandler

DefaultInputHandler handles the input for the Pig-Streaming executable in a synchronous manner by feeding it input via its stdin.

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
DefaultInputHandler()
DefaultInputHandler(StreamingCommand.HandleSpec spec)

Method Summary

Methods

Modifier and Type	Method and Description
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

bindTo, putNext

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultInputHandler

public DefaultInputHandler()

DefaultInputHandler

public DefaultInputHandler(StreamingCommand.HandleSpec spec)

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

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