public static class FlatFileInputFormat.SerializationContextFromConf<S> extends java.lang.Object implements FlatFileInputFormat.SerializationContext<S>
FlatFileInputFormat.SerializationContext
that reads the
Serialization class and specific subclass to be deserialized from the
JobConf.Modifier and Type | Field and Description |
---|---|
static java.lang.String |
SerializationSubclassKey
The JobConf keys for the Class that is being deserialized.
|
Constructor and Description |
---|
SerializationContextFromConf() |
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) |
public static final java.lang.String SerializationSubclassKey
public void setConf(Configuration conf)
public Configuration getConf()
public java.lang.Class<S> getRealClass() throws java.io.IOException
FlatFileInputFormat.SerializationContext
getRealClass
in interface FlatFileInputFormat.SerializationContext<S>
does
- not currently throw IOExceptionjava.io.IOException
public <any> getSerialization() throws java.io.IOException
getSerialization
in interface FlatFileInputFormat.SerializationContext<S>
does
- not currently throw any IOExceptionjava.io.IOException
Copyright © 2012 The Apache Software Foundation