org.apache.hadoop.streaming.io
Class IdentifierResolver

java.lang.Object
  extended by org.apache.hadoop.streaming.io.IdentifierResolver

public class IdentifierResolver
extends Object

This class is used to resolve a string identifier into the required IO classes. By extending this class and pointing the property stream.io.identifier.resolver.class to this extension, additional IO classes can be added by external code.


Field Summary
static String RAW_BYTES_ID
           
static String TEXT_ID
           
static String TYPED_BYTES_ID
           
 
Constructor Summary
IdentifierResolver()
           
 
Method Summary
 Class<? extends InputWriter> getInputWriterClass()
          Returns the resolved InputWriter class.
 Class getOutputKeyClass()
          Returns the resolved output key class.
 Class<? extends OutputReader> getOutputReaderClass()
          Returns the resolved OutputReader class.
 Class getOutputValueClass()
          Returns the resolved output value class.
 void resolve(String identifier)
          Resolves a given identifier.
protected  void setInputWriterClass(Class<? extends InputWriter> inputWriterClass)
          Sets the InputWriter class.
protected  void setOutputKeyClass(Class outputKeyClass)
          Sets the output key class class.
protected  void setOutputReaderClass(Class<? extends OutputReader> outputReaderClass)
          Sets the OutputReader class.
protected  void setOutputValueClass(Class outputValueClass)
          Sets the output value class.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

TEXT_ID

public static final String TEXT_ID
See Also:
Constant Field Values

RAW_BYTES_ID

public static final String RAW_BYTES_ID
See Also:
Constant Field Values

TYPED_BYTES_ID

public static final String TYPED_BYTES_ID
See Also:
Constant Field Values
Constructor Detail

IdentifierResolver

public IdentifierResolver()
Method Detail

resolve

public void resolve(String identifier)
Resolves a given identifier. This method has to be called before calling any of the getters.


getInputWriterClass

public Class<? extends InputWriter> getInputWriterClass()
Returns the resolved InputWriter class.


getOutputReaderClass

public Class<? extends OutputReader> getOutputReaderClass()
Returns the resolved OutputReader class.


getOutputKeyClass

public Class getOutputKeyClass()
Returns the resolved output key class.


getOutputValueClass

public Class getOutputValueClass()
Returns the resolved output value class.


setInputWriterClass

protected void setInputWriterClass(Class<? extends InputWriter> inputWriterClass)
Sets the InputWriter class.


setOutputReaderClass

protected void setOutputReaderClass(Class<? extends OutputReader> outputReaderClass)
Sets the OutputReader class.


setOutputKeyClass

protected void setOutputKeyClass(Class outputKeyClass)
Sets the output key class class.


setOutputValueClass

protected void setOutputValueClass(Class outputValueClass)
Sets the output value class.



Copyright © 2009 The Apache Software Foundation