org.apache.pig.impl.streaming
Class HandlerFactory

java.lang.Object
  org.apache.pig.impl.streaming.HandlerFactory

public class HandlerFactory
extends Object

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

Constructor Summary

HandlerFactory()

Method Summary

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