org.apache.pig.impl.streaming
Class HandlerFactory

java.lang.Object
  extended by 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


Copyright © 2007-2012 The Apache Software Foundation