org.apache.pig.impl.streaming
Class DefaultInputHandler

java.lang.Object
  extended by org.apache.pig.impl.streaming.InputHandler
      extended by 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
DefaultInputHandler()
           
DefaultInputHandler(StreamingCommand.HandleSpec spec)
           
 
Method Summary
 void close(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(Process process)
           throws 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:
IOException


Copyright © 2007-2012 The Apache Software Foundation