Package | Description |
---|---|
org.apache.pig.impl.streaming |
Modifier and Type | Class and Description |
---|---|
class |
DefaultInputHandler
DefaultInputHandler handles the input for the Pig-Streaming
executable in a synchronous manner by feeding it input
via its
stdin . |
class |
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.
|
class |
StreamingUDFInputHandler |
Modifier and Type | Method and Description |
---|---|
static InputHandler |
HandlerFactory.createInputHandler(StreamingCommand command)
Create an
InputHandler for the given input specification
of the StreamingCommand . |
Copyright © 2007-2017 The Apache Software Foundation