org.apache.pig.impl.streaming

Class HandlerFactory

java.lang.Object

org.apache.pig.impl.streaming.HandlerFactory

public class HandlerFactory
extends java.lang.Object

Factory to create an InputHandler or OutputHandler depending on the specification of the StreamingCommand.

Constructor Summary

Constructors

Constructor and Description
HandlerFactory()

Method Summary

Modifier and Type	Method and Description
static InputHandler	createInputHandler(StreamingCommand command) Create an InputHandler for the given input specification of the StreamingCommand.
static OutputHandler	createOutputHandler(StreamingCommand command) Create an OutputHandler for the given output specification of the StreamingCommand.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HandlerFactory

public HandlerFactory()

Method Detail

createInputHandler

public static InputHandler createInputHandler(StreamingCommand command)
                                       throws ExecException

Create an InputHandler for the given input specification of the StreamingCommand.

Parameters:

command - StreamingCommand

Returns:

InputHandler for the given input specification

Throws:

ExecException

createOutputHandler

public static OutputHandler createOutputHandler(StreamingCommand command)
                                         throws ExecException

Create an OutputHandler for the given output specification of the StreamingCommand.

Parameters:

command - StreamingCommand

Returns:

OutputHandler for the given output specification

Throws:

ExecException