Class | Description |
---|---|
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 | Description |
---|---|
InputHandler.InputType | |
OutputHandler.OutputType | |
StreamingCommand.Handle |
Handle to communicate with the external process.
|
Exception | Description |
---|---|
StreamingUDFException | |
StreamingUDFOutputSchemaException |
Copyright © 2007-2017 The Apache Software Foundation