org.apache.hadoop.streaming.io

类 IdentifierResolver

java.lang.Object

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.

字段概要

字段

限定符和类型	字段和说明
static String	RAW_BYTES_ID
static String	TEXT_ID
static String	TYPED_BYTES_ID

构造器概要

构造器

构造器和说明
IdentifierResolver()

方法概要

方法

限定符和类型	方法和说明
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.

从类继承的方法 java.lang.Object

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

字段详细资料

TEXT_ID

public static final String TEXT_ID

另请参阅:

常量字段值

RAW_BYTES_ID

public static final String RAW_BYTES_ID

另请参阅:

常量字段值

TYPED_BYTES_ID

public static final String TYPED_BYTES_ID

另请参阅:

常量字段值

构造器详细资料

IdentifierResolver

public IdentifierResolver()

方法详细资料

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.