Package org.apache.pig.impl.streaming

Class Summary
DefaultInputHandler DefaultInputHandler handles the input for the Pig-Streaming executable in a synchronous manner by feeding it input via its stdin.
DefaultOutputHandler FileOutputHandler handles the output from the Pig-Streaming executable in an synchronous manner by reading its output via its stdout.
ExecutableManager ExecutableManager manages an external executable which processes data in a Pig query.
FileInputHandler 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.
FileOutputHandler FileOutputHandler handles the output from the Pig-Streaming executable in an asynchronous manner by reading it from an external file specified by the user.
HandlerFactory Factory to create an InputHandler or OutputHandler depending on the specification of the StreamingCommand.
InputHandler InputHandler is responsible for handling the input to the Pig-Streaming external command.
OutputHandler OutputHandler is responsible for handling the output of the Pig-Streaming external command.
StreamingCommand StreamingCommand represents the specification of an external command to be executed in a Pig Query.
StreamingCommand.HandleSpec Specification about the usage of the StreamingCommand.Handle to communicate with the external process.
 

Enum Summary
InputHandler.InputType  
OutputHandler.OutputType  
StreamingCommand.Handle Handle to communicate with the external process.
 



Copyright © ${year} The Apache Software Foundation