org.apache.hadoop.hive.ql.io

Class FlatFileInputFormat.SerializationContextFromConf<S>

java.lang.Object

org.apache.hadoop.hive.ql.io.FlatFileInputFormat.SerializationContextFromConf<S>

All Implemented Interfaces:

FlatFileInputFormat.SerializationContext<S>

Enclosing class:

FlatFileInputFormat<T>

public static class FlatFileInputFormat.SerializationContextFromConf<S>
extends java.lang.Object
implements FlatFileInputFormat.SerializationContext<S>

An implementation of FlatFileInputFormat.SerializationContext that reads the Serialization class and specific subclass to be deserialized from the JobConf.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	SerializationSubclassKey The JobConf keys for the Class that is being deserialized.

Constructor Summary

Constructors

Constructor and Description
SerializationContextFromConf()

Method Summary

Modifier and Type	Method and Description
Configuration	getConf()
java.lang.Class<S>	getRealClass() Produces the specific class to deserialize.
<any>	getSerialization() Looks up and instantiates the Serialization Object Important to note here that we are not relying on the Hadoop SerializationFactory part of the Serialization framework.
void	setConf(Configuration conf)

Methods inherited from class java.lang.Object

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

Field Detail

SerializationSubclassKey

public static final java.lang.String SerializationSubclassKey

The JobConf keys for the Class that is being deserialized.

See Also:

Constant Field Values

Constructor Detail

SerializationContextFromConf

public SerializationContextFromConf()

Method Detail

setConf

public void setConf(Configuration conf)

getConf

public Configuration getConf()

getRealClass

public java.lang.Class<S> getRealClass()
                                throws java.io.IOException

Description copied from interface: FlatFileInputFormat.SerializationContext

Produces the specific class to deserialize.

Specified by:

getRealClass in interface FlatFileInputFormat.SerializationContext<S>

Returns:

the actual class being deserialized.

Throws:

does - not currently throw IOException

java.io.IOException

getSerialization

public <any> getSerialization()
                       throws java.io.IOException

Looks up and instantiates the Serialization Object Important to note here that we are not relying on the Hadoop SerializationFactory part of the Serialization framework. This is because in the case of Non-Writable Objects, we cannot make any assumptions about the uniformity of the serialization class APIs - i.e., there may not be a "write" method call and a subclass may need to implement its own Serialization classes. The SerializationFactory currently returns the first (de)serializer that is compatible with the class to be deserialized; in this context, that assumption isn't necessarily true.

Specified by:

getSerialization in interface FlatFileInputFormat.SerializationContext<S>

Returns:

the serialization object for this context

Throws:

does - not currently throw any IOException

java.io.IOException