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.
PigStreamingUDF
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.
StreamingDelimiters
StreamingUDFInputHandler
StreamingUDFOutputHandler
StreamingUtil

Enum Summary

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

Exception Summary

StreamingUDFException
StreamingUDFOutputSchemaException